Bắt đầu ngayBắt đầu miễn phí

Xem lịch chạy dựa trên asset hoạt động như thế nào

Cả hai Dag sales_producersales_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:

  1. Trong chế độ xem Dags, tìm sales_producersales_consumer rồi bật chúng bằng công tắc chuyển.
  2. Kích hoạt sales_producer bằng cách nhấp biểu tượng phát, chọn Single Run, rồi Trigger.
  3. 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á).
  4. Kiểm tra xem sales_consumer có đượ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

Xem khóa học

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