過去データのバックフィル
遅れて届くデータは、データパイプラインでよくある問題です。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 列を確認してください。バックフィル実行のプレフィックスはどれですか?
この演習はコースの一部です
