Skapa en enkel DAG
Du har ägnat en stund åt att bekanta dig med Airflows komponenter och vill nu testa dina egna arbetsflöden. Som ett första steg bestämmer du dig för att definiera standardparametrarna och skapa ett DAG-objekt för ditt arbetsflöde.
Objektet datetime har redan importerats åt dig.
Den här övningen är en del av kursen
Introduktion till Apache Airflow i Python
Övningsinstruktioner
- Importera Airflows DAG-objekt – notera att det är skiftlägeskänsligt.
- Definiera DAG-dekoratorn och ge DAG:en namnet
example_etl. - Anropa DAG-funktionen i slutet av kodfilen.
Interaktiv övning med praktiskt arbete
Testa den här övningen genom att slutföra den här exempelkoden.
# 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
____()