Daten aus einer TaskFlow-Funktion zurückgeben
Dein Team speichert die Pipeline-Konfiguration in einer separaten Task, damit sie in nachgelagerten Schritten wiederverwendet werden kann. Dieses Zentralisieren von Konfiguration ist in der Produktion üblich: Eine Task definiert die Einstellungen, und alle anderen Tasks lesen dieselben Werte, statt sie hart zu codieren. Die Task get_config gibt bereits das Config-Dictionary zurück, und run_pipeline ist bereit, es zu verwenden.
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