Slack Sink Connector

The Slack Sink Connector allows you to send events from the GlassFlow pipeline directly to a Slack channel via Slack Incoming Webhooks. This integration enables real-time notifications, alerts, and messages to be delivered to your team, helping you stay informed about key events in your data pipeline.

Connector Details

To configure the Slack Sink Connector, you will need the following details:

• Slack Webhook URL: The unique URL provided by Slack to send messages to a specific channel.
• Message Format: JSON payload containing the message structure Slack expects.

Obtain a Slack Webhook URL

1. Go to the Slack Incoming Webhooks page.
2. Select your Slack workspace and create a new Incoming Webhook.
3. Choose the Slack channel where messages should be sent.
4. Copy the generated Webhook URL for use in GlassFlow. The Webhook URL typically looks like

Setting Up the Slack Sink Connector

Using WebApp

1. Log in to the GlassFlow WebApp and navigate to the "Pipelines" section.
2. Create a new pipeline.
3. Configure the Data Sink:
   • Choose "Webhook" as the connector type under the Data Sink configuration.
   • Enter the Slack Webhook URL obtained earlier.
   • Set HTTP Method to POST.
   • Configure the Request Headers:
     • Content-Type: application/json
   • Define the Payload to match Slack’s expected message format.
4. Click Next Step and confirm your pipeline configuration.

Using Python SDK

If you are using GlassFlow Python SDK to deploy and manage the pipeline, the following code shows how to configure Slack connector via the SDK.

Using GitHub Actions

If you are using GitHub Actions to deploy and manage the pipeline, the following snippet shows the YAML configuration of the Slack sink connector component:

Expected Data Structure

Slack messages sent via Webhooks should only contain one feild text which should have the message you want to post in the slack channel. All the other details are already configured when creating the Webhook on Slack.

Example Use Cases

• Real-Time Alerts: Notify teams of anomalies or critical events in data processing.
• Workflow Updates: Inform stakeholders when a pipeline completes successfully.
• Operational Insights: Streamline incident management by pushing logs and errors to a Slack channel.

For a hands on example on using Slack to send alerts on suspicious user logins is available on glassflow-examples github repo.

With this setup, your GlassFlow pipeline can seamlessly send events and updates directly to Slack, keeping your team informed in real time!