跳到主要内容
版本:Next

Slack

Slack 接收器连接器

支持以下引擎

Spark
Flink
SeaTunnel Zeta

关键特性

描述

用于将数据发送到Slack Channel.两者都支持流媒体和批处理模式.

例如,如果来自上游的数据是 [age: 12, name: huan], 则发送到套接字服务器的内容如下: {"name":"huan","age":17}

数据类型映射

所有数据类型都映射到字符串.

选项

名称类型必需默认值描述
webhooks_urlStringYes-Slack webhook 的 url
oauth_tokenStringYes-用于实际身份验证的Slack oauth令牌
slack_channelStringYes-用于数据写入的slack channel
common-optionsno-接收器插件常用参数, 详见 Sink 常见选项

任务示例

简单示例:

sink {
SlackSink {
webhooks_url = "https://hooks.slack.com/services/xxxxxxxxxxxx/xxxxxxxxxxxx/xxxxxxxxxxxxxxxx"
oauth_token = "xoxp-xxxxxxxxxx-xxxxxxxx-xxxxxxxxx-xxxxxxxxxxx"
slack_channel = "channel name"
}
}

变更日志

Change Log
ChangeCommitVersion
[improve] Slack connector options (#8738)https://github.com/apache/seatunnel/commit/eb706743fedev
[Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786)https://github.com/apache/seatunnel/commit/6b7c53d03c2.3.9
[Improve] Remove use SeaTunnelSink::getConsumedType method and mark it as deprecated (#5755)https://github.com/apache/seatunnel/commit/8de74081002.3.4
[Improve][build] Give the maven module a human readable name (#4114)https://github.com/apache/seatunnel/commit/d7cd6010512.3.1
[Improve][Project] Code format with spotless plugin. (#4101)https://github.com/apache/seatunnel/commit/a2ab1665612.3.1
[Hotfix][OptionRule] Fix option rule about all connectors (#3592)https://github.com/apache/seatunnel/commit/226dc6a1192.3.0
[Feature][Connector-V2][Slack] Add Slack sink connector (#3226)https://github.com/apache/seatunnel/commit/7a836f2d442.3.0