SnowflakeToSlackOperator¶

Warning

This operator is deprecated. Please use airflow.providers.slack.transfers.sql_to_slack.SqlToSlackOperator or airflow.providers.slack.transfers.sql_to_slack.SqlToSlackApiFileOperator.

Use the SnowflakeToSlackOperator to post messages to predefined Slack channels.

Slack Webhook Airflow Connection Metadata¶
Parameter	Input
Host: string	Slack Webhook URL
Extra: dictionary	`webhook_token` (optional)

Using the Operator¶

Similarly to the SnowflakeOperator, use the snowflake_conn_id and the additional relevant parameters to establish connection with your Snowflake instance. This operator will execute a custom query on a selected Snowflake table and publish a Slack message that can be formatted and contain the resulting dataset (e.g. ASCII formatted dataframe).

An example usage of the SnowflakeToSlackOperator is as follows:

tests/system/providers/snowflake/example_snowflake_to_slack.py[source]

slack_report = SnowflakeToSlackOperator(
    task_id="slack_report",
    sql=SNOWFLAKE_SLACK_SQL,
    slack_message=SNOWFLAKE_SLACK_MESSAGE,
    slack_conn_id=SLACK_CONN_ID,
)