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 SmtpNotifier

Sau khi bạn đã tạo thành công một callback cho trường hợp thất bại, trưởng nhóm yêu cầu mọi lần chạy Dag thành công đều được gửi email đến alias của nhóm. Sau khi xem tài liệu Airflow, bạn quyết định dùng framework notifier tích hợp sẵn của Airflow là lựa chọn tốt nhất.

Các đối tượng dag và task đã được import, hàm callback alert_on_failure và các tác vụ get_sales_data và process_sales_data đã được định nghĩa sẵn cho bạn.

Hướng dẫn

100 XP
  • Import đối tượng notifier SMTP.
  • Thêm thuộc tính success callback cho Dag.
  • Gửi thông báo đến [email protected].
  • Bao gồm một tiêu đề (subject).