开始使用免费开始使用

回填历史数据

延迟到达的数据在实际中很常见。您的 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 构建数据流水线

查看课程

动手互动练习

通过我们的互动练习之一,将理论转化为实践

开始练习