การกำหนดเวลา Consumer Dag บน Asset

เมื่อ Sales Producer ส่งสัญญาณว่าข้อมูลพร้อมแล้ว ขั้นตอนต่อไปคือสร้าง Consumer Dag ที่รันโดยอัตโนมัติทุกครั้งที่ Asset ได้รับการอัปเดต ให้กำหนด Asset เดิม (s3://data-lake/sales/daily.csv) และตั้งค่า Schedule ของ Consumer ให้ใช้ Asset นั้น เพื่อให้ Airflow ทริกเกอร์ Dag หลังจากแต่ละการอัปเดต