1. Học hỏi
    2. /
  2. Khoa Học
    3. /
  3. Giới thiệu về Apache Airflow bằng Python
Connected

Bài tập

Triển khai hàm callback

Gần đây bạn được giao nhiệm vụ thêm các failure callback cho các Dag do đội của bạn tạo. Để bắt đầu, bạn muốn thêm một failure callback đơn giản để ghi một thông điệp vào audit log khi sales_etl_dag thất bại.

Các đối tượng dag và task đã được import và các task get_sales_data và process_sales_data đã được tạo.

Hướng dẫn

100 XP
  • Tạo một hàm callback tên alert_on_failure.
  • Định nghĩa hàm để chấp nhận bất kỳ đối tượng nào Airflow truyền vào.
  • Chỉ định một failure callback sử dụng hàm alert_on_failure.