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

Định nghĩa một BranchPythonOperator

Sau khi tìm hiểu về sức mạnh của logic rẽ nhánh trong Airflow, bạn muốn thử BranchPythonOperator. Bạn muốn chạy một nhánh mã khác nếu ngày chạy hiện tại đánh dấu sang năm mới (ví dụ, 2020 so với 2019).

DAG và các tác vụ liên quan đã được định nghĩa sẵn. Nhiệm vụ hiện tại của bạn là triển khai BranchPythonOperator.

Hướng dẫn

100 XP
  • Trong hàm year_check, cấu hình mã để xác định xem năm của ngày chạy hiện tại có khác với ngày chạy trước đó hay không (tức là so sánh năm giữa các biến template tương ứng của Airflow).
  • Hoàn thiện BranchPythonOperator bằng cách bổ sung các tham số phù hợp.
  • Thiết lập quan hệ phụ thuộc cho current_year_task và new_year_task.