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