Slack 通知操作指南¶

简介¶

Slack 通知程序 (airflow.providers.slack.notifications.slack.SlackNotifier) 允许用户使用 DAG 级别和任务级别的各种 on_*_callbacks 向 Slack 频道发送消息

你还可以将通知程序与 sla_miss_callback 结合使用。

注意

当通知程序与 sla_miss_callback 结合使用时，上下文将仅包含传递给回调的值，请参阅 sla_miss_callback。

示例代码：¶

from datetime import datetime
from airflow import DAG
from airflow.operators.bash import BashOperator
from airflow.providers.slack.notifications.slack import send_slack_notification

with DAG(
    start_date=datetime(2023, 1, 1),
    on_success_callback=[
        send_slack_notification(
            text="The DAG {{ dag.dag_id }} succeeded",
            channel="#general",
            username="Airflow",
        )
    ],
):
    BashOperator(
        task_id="mytask",
        on_failure_callback=[
            send_slack_notification(
                text="The task {{ ti.task_id }} failed",
                channel="#general",
                username="Airflow",
            )
        ],
        bash_command="fail",
    )