Rattraper des données historiques (backfill)
Les données en retard, ça arrive. Votre Dag daily_sales_load fonctionne bien, mais les données de commandes des 20 au 22 avril n'ont atterri dans raw_orders qu'aujourd'hui, créant trois trous dans daily_summary. La solution est un backfill. Le Dag est déjà actif, donc vous verrez une exécution scheduled pour aujourd'hui en plus des exécutions de backfill que vous allez créer.
- Exécutez
airflow backfill create --dag-id daily_sales_load --from-date 2026-04-20 --to-date 2026-04-22 --max-active-runs 1dans le terminal. - Attendez environ 30 secondes que les exécutions de backfill se terminent.
- Exécutez
airflow dags list-runs daily_sales_loadpour voir toutes les exécutions.
Regardez la colonne run_id dans le résultat. Par quel préfixe commencent les exécutions de backfill?
Cette activité fait partie du cours
Créer des pipelines de données avec Airflow
Exercice interactif pratique
Passez de la théorie à l’action grâce à l’un de nos exercices interactifs
Commencer l’exercice