Parametrizando SQL e extraindo para arquivos
Strings de SQL inline ficam difíceis de manter rapidamente e não podem ser revisadas pela sua equipe de dados. A equipe extraiu a agregação para include/sql/aggregate_sales.sql, assim ela fica junto do restante do projeto. Torne a consulta ciente de datas para que cada execução processe um único dia e, em seguida, aponte o pipeline para o arquivo. Use /home/repl/workspace/include/sql como o caminho da pasta de SQL.
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