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

Bài tập

EmailOperator và quan hệ phụ thuộc

Sau khi bạn đã định nghĩa thành công các PythonOperator cho quy trình, quản lý muốn nhận một bản sao tệp JSON đã được phân tích qua email khi quy trình hoàn tất. Các tác vụ trước đó vẫn được giữ nguyên và DAG process_sales_dag đã được cấu hình. Lưu ý: tác vụ này dùng phương pháp định nghĩa DAG kiểu cũ và đã được thêm sẵn cho bạn.

Hướng dẫn

100 XP
  • Import lớp để gửi email.
  • Định nghĩa Operator và thêm các đối số phù hợp (to, subject, files).
  • Thiết lập thứ tự để các tác vụ chạy tuần tự (Kéo tệp, phân tích tệp, rồi gửi email cho quản lý của bạn).