Rattraper des données historiques (backfill)
Les données qui arrivent en retard, ça arrive. Votre Dag daily_sales_load fonctionne bien, mais les données de commandes des 20 au 22 avril ne sont arrivées dans raw_orders qu'aujourd'hui, laissant trois trous dans daily_summary. La solution est un backfill (rattrapage). Le Dag est déjà actif, vous verrez donc 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 ?
Cet exercice fait partie du cours
<cours>Créer des pipelines de données avec Airflow</cours>Exercice interactif pratique
Transformez la théorie en action avec l’un de nos exercices interactifs
Commencer l’exercice