1. Learn
    2. /
  2. 课程
    3. /
  3. Python 中的 Apache Airflow 入门
Connected

道练习

实现回调函数

您最近被指派为团队创建的多个 Dag 添加失败回调。作为开始，您希望在 sales_etl_dag 失败时，添加一个简单的失败回调，将消息写入审计日志。

dag 和 task 对象已导入，get_sales_data 与 process_sales_data 这两个任务也已创建。

说明

100 XP
  • 创建一个名为 alert_on_failure 的回调函数。
  • 定义该函数以接受 Airflow 传入的任意对象。
  • 使用 alert_on_failure 函数指定失败回调。