Slack 入站 Webhook 通知操作指南¶

简介¶

Slack 入站 Webhook 通知器 (airflow.providers.slack.notifications.slack_webhook.SlackWebhookNotifier) 允许用户通过入站 Webhook 使用各种 on_*_callbacks 在 DAG 级别和任务级别向 Slack 频道发送消息

你还可以使用具有 sla_miss_callback 的通知器。

注意

当通知器与 sla_miss_callback 一起使用时，上下文将仅包含传递给回调的值，请参阅 sla_miss_callback。

示例代码：¶

from datetime import datetime, timezone
from airflow import DAG
from airflow.operators.bash import BashOperator
from airflow.providers.slack.notifications.slack_webhook import send_slack_webhook_notification

dag_failure_slack_webhook_notification = send_slack_webhook_notification(
    slack_webhook_conn_id="slackwebhook", text="The dag {{ dag.dag_id }} failed"
)
task_failure_slack_webhook_notification = send_slack_webhook_notification(
    slack_webhook_conn_id="slackwebhook",
    text="The task {{ ti.task_id }} failed",
)

with DAG(
    dag_id="mydag",
    schedule="@once",
    start_date=datetime(2023, 1, 1, tzinfo=timezone.utc),
    on_failure_callback=[dag_failure_slack_webhook_notification],
    catchup=False,
):
    BashOperator(
        task_id="mytask", on_failure_callback=[task_failure_slack_webhook_notification], bash_command="fail"
    )