LoslegenKostenlos starten

Mehrere Endpunkte mit expand verarbeiten

Dein Team zieht Daten aus mehreren API-Endpunkten, die sich im Laufe der Zeit ändern. Für jeden Endpunkt eine eigene Aufgabe hart zu codieren bedeutet, den Dag jedes Mal anzupassen, wenn ein Endpunkt hinzukommt oder entfällt. In dieser Übung machst du aus dieser starren Pipeline eine datengesteuerte: Mit expand() liest Airflow die Liste der Endpunkte zur Laufzeit und startet eine Task-Instanz pro Element, sodass sich die Pipeline automatisch anpasst, wenn sich die Anzahl der Endpunkte ändert.

Diese Übung ist Teil des Kurses

<Kurs>Data-Pipelines mit Airflow aufbauen</Kurs>
Kurs ansehen

Interaktive praktische Übung

Verwandle Theorie mit einer unserer interaktiven Übungen in die Praxis

Übung starten