⭐️
Slack
Slack 接收器连接器
支持以下引擎
Spark
Flink
SeaTunnel Zeta
关键特性
描述
用于将数据发送到Slack Channel.两者都支持流媒体和批处理模式.
例如，如果来自上游的数据是 [
age: 12, name: huan], 则发送到套接字服务器的内容如下:{"name":"huan","age":17}
数据类型映射
所有数据类型都映射到字符串.
选项
| 名称 | 类型 | 必需 | 默认值 | 描述 |
|---|---|---|---|---|
| webhooks_url | String | Yes | - | Slack webhook 的 url |
| oauth_token | String | Yes | - | 用于实际身份验证的Slack oauth令牌 |
| slack_channel | String | Yes | - | 用于数据写入的slack channel |
| common-options | no | - | 接收器插件常用参数, 详见 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
| Change | Commit | Version |
|---|---|---|
| [improve] Slack connector options (#8738) | https://github.com/apache/seatunnel/commit/eb706743fe | dev |
| [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 |