回填歷史資料
延遲到達的資料很常見。你的 daily_sales_load Dag 一直運作良好,但 4 月 20–22 日的訂單資料直到今天才進到 raw_orders,導致 daily_summary 出現 3 個缺口。解法就是進行回填。Dag 已經是啟用狀態,所以你會在你建立的回填執行之外,看到今天的 scheduled 執行。
- 在終端機中執行
airflow backfill create --dag-id daily_sales_load --from-date 2026-04-20 --to-date 2026-04-22 --max-active-runs 1。 - 等待約 30 秒,讓回填執行完成。
- 執行
airflow dags list-runs daily_sales_load以查看所有執行。
查看輸出中的 run_id 欄位。回填執行的前綴字串是什麼?
本練習屬於課程
