การ Backfill ข้อมูลย้อนหลัง
ข้อมูลที่มาถึงล่าช้าเป็นเรื่องที่พบได้เสมอ Dag daily_sales_load ของคุณทำงานได้ปกติ แต่ข้อมูลออเดอร์ของวันที่ 20-22 เมษายนเพิ่งเข้ามาใน raw_orders วันนี้ ทำให้ daily_summary ขาดข้อมูลไปสามวัน วิธีแก้คือการทำ backfill โดย Dag ยังคง active อยู่ ดังนั้นจะเห็นรัน scheduled ของวันนี้ควบคู่กับรัน backfill ที่จะสร้างขึ้น
- รัน
airflow backfill create --dag-id daily_sales_load --from-date 2026-04-20 --to-date 2026-04-22 --max-active-runs 1ในเทอร์มินัล - รอประมาณ 30 วินาทีให้รัน backfill เสร็จสมบูรณ์
- รัน
airflow dags list-runs daily_sales_loadเพื่อดูรันทั้งหมด
ดูที่คอลัมน์ run_id ในผลลัพธ์ รัน backfill ขึ้นต้นด้วย prefix อะไร?
แบบฝึกหัดนี้เป็นส่วนหนึ่งของหลักสูตร
การสร้าง Data Pipeline ด้วย Airflow
แบบฝึกหัดเชิงโต้ตอบแบบลงมือทำจริง
เปลี่ยนทฤษฎีให้เป็นการลงมือทำด้วยแบบฝึกหัดเชิงโต้ตอบหนึ่งในของเรา
เริ่มแบบฝึกหัด