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

Viết với Jinja

Khi làm việc nhiều hơn với Airflow, bạn đã thêm nhiều callback thông báo nhưng nhận ra rằng mỗi lần đều nhận cùng một nội dung trong hộp thư. Rất khó tìm đúng email khi dòng tiêu đề lúc nào cũng giống nhau. Sau khi đọc về việc Airflow hỗ trợ Jinja, bạn nhận ra mình có thể thêm thông tin nhận diện để đảm bảo mỗi Dag gửi báo cáo cho từng ngày chạy. Bạn quyết định bắt đầu bằng cách cập nhật Dag sales_update để gửi email cho bạn với tiêu đề dùng template khi hoàn tất thành công.

Tất cả import cần thiết của Airflow đã có sẵn, và các tác vụ pull_sales_data và generate_sales_report đã được định nghĩa.

Hướng dẫn

100 XP

  • Cấu hình Dag để gửi email cho bạn khi hoàn tất mà không có lỗi.

  • Thiết lập thuộc tính subject cho email thông báo.

  • Dùng mẫu Jinja để đưa ngày chạy vào dòng tiêu đề:

    Sales update successfully processed for YYYY-MM-DD