SqlToSlackWebhookOperator¶

使用 SqlToSlackWebhookOperator 通过 Incoming Webhook 将查询结果作为消息发布到预定义的 Slack 频道。

使用操作符¶

此操作符将在提供的 SQL 连接中执行自定义查询，并发布一条 Slack 消息，该消息可以格式化并包含结果数据集（例如，ASCII 格式化的数据帧）。

以下是 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 }}",
)