การ Trigger Pipeline จาก CLI
โดยทั่วไป scheduler จะรัน DAG ให้โดยอัตโนมัติ แต่บางครั้งก็จำเป็นต้องรันเองสำหรับวันที่เฉพาะเจาะจงหรือการประมวลผลซ้ำอย่างรวดเร็ว DAG daily_sales_load ทำงานอยู่แล้ว และ scheduler ได้สร้าง run แบบ scheduled ไว้หนึ่งรายการ ให้ลอง trigger run ที่สองจาก CLI แล้วดูว่า Airflow ติด tag ให้แต่ละ run อย่างไร
- รัน
airflow dags trigger daily_sales_load --logical-date 2026-04-20ใน terminal เพื่อ trigger run สำหรับวันที่ที่กำหนด - รอประมาณ 30 วินาทีให้ manual run ทำงานเสร็จ
- รัน
airflow dags list-runs daily_sales_loadเพื่อดู run ทั้งหมด
หลังจากรัน airflow dags list-runs แล้วจะเห็น run สองรายการ ให้ดูที่คอลัมน์ run_id — run ที่ trigger ด้วยตนเองขึ้นต้นด้วย prefix อะไร?
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
การสร้าง Data Pipeline ด้วย Airflow
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำจริง
เปลี่ยนทฤษฎีให้เป็นการลงมือทำด้วยแบบฝึกหัดเชิงโต้ตอบหนึ่งในของเรา
เริ่มแบบฝึกหัด