การกำหนดเวลาแบบ Asset-based ในทางปฏิบัติ

DAG sales_producer และ sales_consumer จากแบบฝึกหัดก่อนหน้าได้ถูกโหลดเข้า Airflow UI แล้ว โดย producer จะเขียนข้อมูลยอดขายและอัปเดต asset s3://data-lake/sales/daily.csv ส่วน consumer ถูกกำหนดเวลาให้ทำงานตาม asset นั้น

ทำตามขั้นตอนต่อไปนี้:

ในหน้า DAGs ให้ค้นหา sales_producer และ sales_consumer จากนั้นเปิดใช้งานทั้งสองโดยใช้สวิตช์ toggle
Trigger sales_producer โดยคลิกไอคอน play แล้วเลือก Single Run จากนั้นคลิก Trigger
รอให้ producer ทำงานเสร็จสมบูรณ์ (task ทั้งหมดเป็นสีเขียว)
ตรวจสอบว่า sales_consumer ถูก trigger โดยอัตโนมัติโดยไม่ต้องคลิกอะไรเพิ่มเติมหรือไม่

หลังจากที่ sales_producer ทำงานเสร็จสมบูรณ์ จะเกิดอะไรขึ้นกับ sales_consumer?

แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร

การสร้าง Data Pipeline ด้วย Airflow

ดูคอร์ส

แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำจริง

เปลี่ยนทฤษฎีให้เป็นการลงมือทำด้วยแบบฝึกหัดเชิงโต้ตอบหนึ่งในของเรา

เริ่มแบบฝึกหัด