Xác định thứ tự Task
Giờ bạn đã biết về cú pháp bitshift, hãy định nghĩa thứ tự chạy của các task. Hiện bạn có ba task: cleanup, consolidate và push_data.
Các decorator dag và task từ airflow.sdk đã được import sẵn.
Bài tập này là một phần của khóa học
Giới thiệu về Apache Airflow bằng Python
Hướng dẫn bài tập
- Cấu hình task
cleanupchạy trước taskconsolidatebằng cú pháp bitshift. - Cấu hình
consolidatechạy kế tiếp và taskpush_datachạy cuối cùng.
Bài tập tương tác thực hành trực tiếp
Hãy thử làm bài tập này bằng cách hoàn thành đoạn mã mẫu này.
@dag(
dag_id="analytics_dag",
start_date=datetime(2026, 3, 1),
)
def analytics_dag():
# Run cleanup before consolidate
cleanup() ____ consolidate()
# Run consolidate before push_data
____
analytics_dag()