Xem lịch chạy dựa trên asset hoạt động như thế nào
Cả hai Dag sales_producer và sales_consumer từ các bài tập trước đã được tải vào Airflow UI. Producer ghi dữ liệu bán hàng và cập nhật asset s3://data-lake/sales/daily.csv. Consumer được lập lịch dựa trên asset đó.
Hãy làm theo các bước sau:
- Trong chế độ xem Dags, tìm
sales_producervàsales_consumerrồi bật chúng bằng công tắc chuyển. - Kích hoạt
sales_producerbằng cách nhấp biểu tượng phát, chọn Single Run, rồi Trigger. - Chờ lượt chạy của producer hoàn tất (tất cả tác vụ chuyển sang màu xanh lá).
- Kiểm tra xem
sales_consumercó được kích hoạt tự động mà bạn không cần nhấp gì không.
Sau khi chạy xong sales_producer, điều gì xảy ra với sales_consumer?
Bài tập này là một phần của khóa học
Xây dựng Data Pipeline với Airflow
Bài tập tương tác thực hành
Biến lý thuyết thành hành động với một trong các bài tập tương tác của chúng tôi
Bắt đầu bài tập