Criando uma Dag simples
Você passou um tempo revisando os componentes do Airflow e quer testar seus próprios fluxos de trabalho. Para começar, você decidiu definir os parâmetros padrão e criar um objeto Dag para o seu fluxo.
O objeto datetime já foi importado para você.
Este exercicio faz parte do curso
Introdução ao Apache Airflow em Python
Instruções do exercicio
- Importe o objeto Dag do Airflow; observe que diferencia maiúsculas de minúsculas.
- Defina o decorator Dag e nomeie a Dag como
example_etl. - Execute a função da Dag no final do arquivo de código.
exercicio interativo prático
Tente este exercicio completando este código de exemplo.
# Import the dag object
from ____ import dag
# Define the Dag attributes
____(
____='example_etl',
start_date=datetime(2026, 3, 1),
)
def example_etl():
pass
# Run the Dag
____()