Eine klassische Dag auf TaskFlow umstellen
Dein Team hat beschlossen, für alle neuen Pipelines die TaskFlow-API zu verwenden. Deine Managerin bzw. dein Manager bittet dich, eine bestehende ETL-Pipeline neu zu schreiben, die bisher PythonOperator mit manueller >>-Verdrahtung genutzt hat.
Die ursprüngliche klassische Version findest du als Referenz in dags/classic_etl.py. Eine vorgefertigte TaskFlow-Variante steht bereit und wartet darauf, dass du sie vervollständigst.
Diese Übung ist Teil des Kurses
<Kurs>Data-Pipelines mit Airflow aufbauen</Kurs>Interaktive praktische Übung
Verwandle Theorie mit einer unserer interaktiven Übungen in die Praxis
Übung starten