Lập lịch cho một Dag tiêu thụ dựa trên Asset

Giờ đây producer cho sales đã phát tín hiệu khi dữ liệu sẵn sàng, bạn cần một Dag tiêu thụ chạy tự động mỗi khi asset được cập nhật. Hãy định nghĩa cùng asset (s3://data-lake/sales/daily.csv) và đặt lịch của Dag tiêu thụ theo asset đó để Airflow kích hoạt Dag sau mỗi lần cập nhật.