始める無料で始める

過去データのバックフィル

遅れて届くデータは、データパイプラインでよくある問題です。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 によるデータパイプラインの構築

コースを見る

実践的なインタラクティブ演習

理論を実践に変える、インタラクティブな演習のひとつをお試しください

演習を開始する