Creare un Dag semplice
Hai passato un po’ di tempo a rivedere i componenti di Airflow e vuoi mettere alla prova i tuoi workflow. Per iniziare, decidi di definire i parametri predefiniti e creare un oggetto Dag per il tuo workflow.
L’oggetto datetime è già stato importato per te.
Questo esercizio fa parte del corso
Introduzione ad Apache Airflow in Python
Istruzioni dell'esercizio
- Importa l’oggetto Dag di Airflow; nota che fa distinzione tra maiuscole e minuscole.
- Definisci il decorator Dag e assegna al Dag il nome
example_etl. - Esegui la funzione del Dag alla fine del file di codice.
esercizio interattivo pratico
Prova questo esercizio completando questo codice di esempio.
# 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
____()