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