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

การ Backfill ข้อมูลย้อนหลัง

ข้อมูลที่มาถึงล่าช้าเป็นเรื่องที่พบได้เสมอ Dag daily_sales_load ของคุณทำงานได้ปกติ แต่ข้อมูลออเดอร์ของวันที่ 20-22 เมษายนเพิ่งเข้ามาใน raw_orders วันนี้ ทำให้ daily_summary ขาดข้อมูลไปสามวัน วิธีแก้คือการทำ backfill โดย Dag ยังคง active อยู่ ดังนั้นจะเห็นรัน scheduled ของวันนี้ควบคู่กับรัน backfill ที่จะสร้างขึ้น

  1. รัน airflow backfill create --dag-id daily_sales_load --from-date 2026-04-20 --to-date 2026-04-22 --max-active-runs 1 ในเทอร์มินัล
  2. รอประมาณ 30 วินาทีให้รัน backfill เสร็จสมบูรณ์
  3. รัน airflow dags list-runs daily_sales_load เพื่อดูรันทั้งหมด

ดูที่คอลัมน์ run_id ในผลลัพธ์ รัน backfill ขึ้นต้นด้วย prefix อะไร?

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

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

ดูคอร์ส

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

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

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