Dag ต้นทาง sales_pipeline_v3 และ Dag ปลายทาง sales_report จากแบบฝึกหัดก่อนหน้าถูก deploy และพร้อมใช้งานแล้ว pipeline ของ sales จะรันทุกนาทีและส่ง partitioned daily_sales event ในแต่ละครั้งที่รัน ส่วน report ต้องการเพียงข้อมูลวันที่เท่านั้น — นั่นคือหน้าที่ของ StartOfDayMapper มาดูการทำงานร่วมกันของทั้งสองกัน

ทำตามขั้นตอนเหล่านี้ตามลำดับ:

ในหน้า Dags view ให้เปิดใช้งาน sales_report ก่อน เพื่อให้พร้อมรับ asset event ที่จะเข้ามา
จากนั้นเปิดใช้งาน sales_pipeline_v3 ซึ่งจะรันทุกนาทีและส่ง partitioned daily_sales event ในแต่ละครั้ง
รอประมาณหนึ่งนาทีให้ sales_pipeline_v3 ทำงานเสร็จ — sales_report จะถูกกระตุ้นโดยอัตโนมัติจาก asset event
เปิด sales_report ไปที่แท็บ Runs แล้วเปิด run ล่าสุด จากนั้นดู Mapped Partition key ที่ด้านบนของรายละเอียด run

Mapped Partition key มีรูปแบบวันที่แบบใด?

ยินดีด้วย!

Create Your Free Account