Backfill de dados históricos
Dados que chegam com atraso fazem parte da realidade. Sua Dag daily_sales_load vinha rodando bem, mas os dados de pedidos de 20 a 22 de abril só chegaram em raw_orders hoje, deixando três lacunas em daily_summary. A correção é fazer um backfill. A Dag já está ativa, então você verá uma execução scheduled de hoje junto com as execuções de backfill que você criar.
- Execute
airflow backfill create --dag-id daily_sales_load --from-date 2026-04-20 --to-date 2026-04-22 --max-active-runs 1no terminal. - Aguarde cerca de 30 segundos para as execuções de backfill terminarem.
- Execute
airflow dags list-runs daily_sales_loadpara ver todas as execuções.
Observe a coluna run_id na saída. Com qual prefixo as execuções de backfill começam?
Este exercicio faz parte do curso
Criando Pipelines de Dados com Airflow
exercicio interativo prático
Transforme teoria em prática com um dos nossos exercicio interativos
Iniciar exercicio