Chime 通知操作指南¶

简介¶

Chime 通知器 (airflow.providers.amazon.aws.notifications.chime.ChimeNotifier) 允许用户使用 DAG 级别和任务级别的各种 on_*_callbacks 将消息发送到通过 webhook 设置的 Chime 聊天室

您还可以将通知器与 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.amazon.aws.notifications.chime import send_chime_notification

with DAG(
    dag_id="mydag",
    schedule="@once",
    start_date=datetime(2023, 6, 27),
    on_success_callback=[
        send_chime_notification(chime_conn_id="my_chime_conn", message="The DAG {{ dag.dag_id }} succeeded")
    ],
    catchup=False,
):
    BashOperator(
        task_id="mytask",
        on_failure_callback=[
            send_chime_notification(chime_conn_id="my_chime_conn", message="The task {{ ti.task_id }} failed")
        ],
        bash_command="fail",
    )