⭐️
Slack
Slack sink connector
Support Those Engines
Spark
Flink
SeaTunnel Zeta
Key features
Description
Used to send data to Slack Channel. Both support streaming and batch mode.
For example, if the data from upstream is [
age: 12, name: huan], the content send to socket server is the following:{"name":"huan","age":17}
Data Type Mapping
All data types are mapped to string.
Options
| Name | Type | Required | Default | Description |
|---|---|---|---|---|
| webhooks_url | String | Yes | - | Slack webhook url |
| oauth_token | String | Yes | - | Slack oauth token used for the actual authentication |
| slack_channel | String | Yes | - | slack channel for data write |
| common-options | no | - | Sink plugin common parameters, please refer to Sink Common Options for details |
Task Example
Simple
sink {
SlackSink {
webhooks_url = "https://hooks.slack.com/services/xxxxxxxxxxxx/xxxxxxxxxxxx/xxxxxxxxxxxxxxxx"
oauth_token = "xoxp-xxxxxxxxxx-xxxxxxxx-xxxxxxxxx-xxxxxxxxxxx"
slack_channel = "channel name"
}
}
Changelog
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 |