เริ่มต้นใช้งานเริ่มต้นใช้งานได้ฟรี

การ Trigger Pipeline จาก CLI

โดยทั่วไป scheduler จะรัน DAG ให้โดยอัตโนมัติ แต่บางครั้งก็จำเป็นต้องรันเองสำหรับวันที่เฉพาะเจาะจงหรือการประมวลผลซ้ำอย่างรวดเร็ว DAG daily_sales_load ทำงานอยู่แล้ว และ scheduler ได้สร้าง run แบบ scheduled ไว้หนึ่งรายการ ให้ลอง trigger run ที่สองจาก CLI แล้วดูว่า Airflow ติด tag ให้แต่ละ run อย่างไร

  1. รัน airflow dags trigger daily_sales_load --logical-date 2026-04-20 ใน terminal เพื่อ trigger run สำหรับวันที่ที่กำหนด
  2. รอประมาณ 30 วินาทีให้ manual run ทำงานเสร็จ
  3. รัน airflow dags list-runs daily_sales_load เพื่อดู run ทั้งหมด

หลังจากรัน airflow dags list-runs แล้วจะเห็น run สองรายการ ให้ดูที่คอลัมน์ run_id — run ที่ trigger ด้วยตนเองขึ้นต้นด้วย prefix อะไร?

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

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

ดูคอร์ส

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

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

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