開始使用免費開始

回填歷史資料

延遲到達的資料很常見。你的 daily_sales_load Dag 一直運作良好,但 4 月 20–22 日的訂單資料直到今天才進到 raw_orders,導致 daily_summary 出現 3 個缺口。解法就是進行回填。Dag 已經是啟用狀態,所以你會在你建立的回填執行之外,看到今天的 scheduled 執行。

  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 秒,讓回填執行完成。
  3. 執行 airflow dags list-runs daily_sales_load 以查看所有執行。

查看輸出中的 run_id 欄位。回填執行的前綴字串是什麼?

本練習屬於課程

使用 Airflow 建置資料管線

檢視課程

動手互動練習

將理論付諸實踐,立即體驗我們的互動練習

開始練習