การประมวลผล endpoint หลายรายการด้วย expand

ทีมของคุณดึงข้อมูลจาก API endpoint หลายรายการที่มีการเปลี่ยนแปลงอยู่เสมอ การเขียน task แยกไว้ตายตัวสำหรับแต่ละ endpoint หมายความว่าต้องแก้ไข DAG ทุกครั้งที่มีการเพิ่มหรือลบ endpoint ในแบบฝึกหัดนี้ คุณจะแปลง pipeline ที่ตายตัวนั้นให้ขับเคลื่อนด้วยข้อมูล: ด้วย expand() Airflow จะอ่านรายการ endpoint ในขณะรันไทม์และสร้าง task instance หนึ่งรายการต่อหนึ่ง item โดยอัตโนมัติ ทำให้ pipeline ปรับตัวได้เองเมื่อจำนวน endpoint เปลี่ยนไป