回填历史数据
延迟到达的数据在实际中很常见。您的 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 列。回填运行使用的前缀是什么?
本练习是课程的一部分
