Een eenvoudige Dag maken
Je hebt de Airflow-componenten doorgenomen en wilt je eigen workflows uitproberen. Om te beginnen definieer je de standaardparameters en maak je een Dag-object voor je workflow.
Het datetime-object is alvast voor je geïmporteerd.
Deze oefening maakt deel uit van de cursus
Introductie tot Apache Airflow in Python
Oefeninstructies
- Importeer het Airflow Dag-object; let op hoofdlettergebruik.
- Definieer de Dag-decorator en noem de Dag
example_etl. - Voer de Dag-functie uit aan het einde van het codebestand.
Interactieve oefening met praktijkervaring
Probeer deze oefening door deze voorbeeldcode aan te vullen.
# 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
____()