Een klassieke Dag omzetten naar TaskFlow
Jullie team heeft besloten om de TaskFlow API te gebruiken voor alle nieuwe pipelines. Je manager vraagt je om een bestaande ETL-pipeline, die PythonOperator met handmatige >>-koppeling gebruikte, opnieuw te schrijven.
De oorspronkelijke klassieke versie staat als referentie in dags/classic_etl.py. Een voorgedefinieerde TaskFlow-versie staat klaar voor je om af te maken.
Deze oefening maakt deel uit van de cursus
Data-pijplijnen bouwen met Airflow
Interactieve oefening met praktijkervaring
Zet theorie om in actie met een van onze interactieve oefeningen
Begin oefening