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:

  1. sink {
  2.  SlackSink {
  3.   webhooks_url = "https://hooks.slack.com/services/xxxxxxxxxxxx/xxxxxxxxxxxx/xxxxxxxxxxxxxxxx"
  4.   oauth_token = "xoxp-xxxxxxxxxx-xxxxxxxx-xxxxxxxxx-xxxxxxxxxxx"
  5.   slack_channel = "channel name"
  6.  }
  7. }

Changelog

new version

  • Add Slack Sink Connector