SqlToSlackWebhookOperator¶
使用 SqlToSlackWebhookOperator
将查询结果作为消息通过 Incoming Webhook 发送到预定义的 Slack 频道。
使用运算符¶
此运算符将在提供的 SQL 连接中执行自定义查询,并发布一条可以格式化并包含结果数据集(例如 ASCII 格式的数据框)的 Slack 消息。
SqlToSlackWebhookOperator 的示例用法如下
tests/system/slack/example_sql_to_slack_webhook.py
SqlToSlackWebhookOperator(
task_id="presto_to_slack",
sql_conn_id=SQL_CONN_ID,
sql=f"SELECT col FROM {SQL_TABLE}",
slack_channel="my_channel",
slack_webhook_conn_id="slack_default",
slack_message="message: {{ ds }}, {{ results_df }}",
)