Định nghĩa thứ tự thực thi của pipeline
Sau khi xây dựng DAG, đã đến lúc bạn xác định thứ tự thực thi cho các tác vụ trong DAG.
Ở bài trước, bạn đã cấu hình tác vụ đầu tiên để kiểm tra API. Tất cả các tác vụ còn lại trong pipeline đã được thiết lập sẵn cho bạn.
Bạn cần tuân theo thứ tự tác vụ theo sơ đồ bên dưới.
Bài tập này là một phần của khóa học
Thiết kế Pipeline Dự báo cho Môi trường Production
Hướng dẫn bài tập
- Thiết lập các tác vụ pipeline kiểm tra API và kiểm tra trạng thái.
- Thiết lập các tác vụ pipeline xác thực dữ liệu.
- Thiết lập các tác vụ pipeline dự báo.
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.
# Set the API check pipeline tasks
____ >> ____ >> [data_refresh, no_updates]
data_refresh >> [data_validation, data_failure]
# Set the data validation pipeline tasks
data_validation >> check_validation >> [____, ____]
# Set the forecast pipeline tasks
data_valid >> ____ >> ____
print(f"DAG '{dag.dag_id}' ready with {len(dag.tasks)} tasks")