⭐️
Slack
Slack 接收器连接器
支持以下引擎
Spark
Flink
SeaTunnel Zeta
关键特性
描述
用于将 SeaTunnel 行数据发送到 Slack 频道。流处理和批处理作业都支持。
连接器会把一行中的字段值拼成一条用逗号分隔的 Slack 消息。例如，字段值为
huan和17时， 发送内容为huan,17。
数据类型映射
所有字段值在发送到 Slack 前都会转换为字符串。
选项
| 名称 | 类型 | 必需 | 默认值 | 描述 |
|---|---|---|---|---|
| webhooks_url | String | 是 | - | Slack webhook URL。 |
| oauth_token | String | 是 | - | 用于列出频道并发送消息的 Slack OAuth 令牌。 |
| slack_channel | String | 是 | - | 写入数据的 Slack 频道名称。 |
| common-options | 否 | - | 接收器插件通用参数，详见 Sink 常见选项。 |
任务示例
简单示例
sink {
Slack {
webhooks_url = "https://hooks.slack.com/services/xxxxxxxxxxxx/xxxxxxxxxxxx/xxxxxxxxxxxxxxxx"
oauth_token = "xoxp-xxxxxxxxxx-xxxxxxxx-xxxxxxxxx-xxxxxxxxxxx"
slack_channel = "seatunnel-alerts"
}
}
变更日志
Change Log
| Change | Commit | Version |
|---|---|---|
| [improve] Slack connector options (#8738) | https://github.com/apache/seatunnel/commit/eb706743fe | 2.3.10 |
| [Feature][Restapi] Allow metrics information to be associated to logical plan nodes (#7786) | https://github.com/apache/seatunnel/commit/6b7c53d03c | 2.3.9 |
[Improve] Remove use SeaTunnelSink::getConsumedType method and mark it as deprecated (#5755) | https://github.com/apache/seatunnel/commit/8de7408100 | 2.3.4 |
| [Improve][build] Give the maven module a human readable name (#4114) | https://github.com/apache/seatunnel/commit/d7cd601051 | 2.3.1 |
| [Improve][Project] Code format with spotless plugin. (#4101) | https://github.com/apache/seatunnel/commit/a2ab166561 | 2.3.1 |
| [Hotfix][OptionRule] Fix option rule about all connectors (#3592) | https://github.com/apache/seatunnel/commit/226dc6a119 | 2.3.0 |
| [Feature][Connector-V2][Slack] Add Slack sink connector (#3226) | https://github.com/apache/seatunnel/commit/7a836f2d44 | 2.3.0 |