ComeçarComece de graça

Criando um BashOperator com template

Você criou com sucesso um BashOperator que limpa um arquivo de dados executando um script chamado cleandata.sh. Isso funciona, mas infelizmente exige que o script seja executado apenas para o dia atual. Algumas das suas fontes de dados às vezes ficam atrasadas alguns dias e precisam ser executadas manualmente.

Você modificou o script cleandata.sh para aceitar um argumento — a data no formato YYYYMMDD. Seus testes funcionaram na linha de comando, mas agora você precisa implementar isso no seu DAG do Airflow. Por enquanto, use o termo {{ ds_nodash }} no seu template — você verá exatamente o que isso significa mais adiante.

Este exercício faz parte do curso

Introdução ao Apache Airflow em Python

Ver curso

Exercício interativo prático

Transforme a teoria em ação com um de nossos exercícios interativos

Começar o exercício