Rellenar datos históricos (backfill)
Los datos que llegan con retraso son algo habitual. Tu Dag daily_sales_load ha estado funcionando bien, pero los datos de pedidos del 20 al 22 de abril solo han llegado hoy a raw_orders, dejando tres huecos en daily_summary. La solución es un backfill. El Dag ya está activo, así que verás una ejecución scheduled para hoy junto con las ejecuciones de backfill que crees.
- Ejecuta
airflow backfill create --dag-id daily_sales_load --from-date 2026-04-20 --to-date 2026-04-22 --max-active-runs 1en la terminal. - Espera unos 30 segundos a que terminen las ejecuciones de backfill.
- Ejecuta
airflow dags list-runs daily_sales_loadpara ver todas las ejecuciones.
Fíjate en la columna run_id del resultado. ¿Con qué prefijo empiezan las ejecuciones de backfill?
Este ejercicio forma parte del curso
Creación de canalizaciones de datos con Airflow
ejercicio interactivo práctico
Convierte la teoría en práctica con uno de nuestros ejercicios interactivos
Empezar ejercicio