Erstellen einer Produktionspipeline #2

In Fortsetzung deines letzten Workflows möchtest du einige zusätzliche Funktionen hinzufügen, insbesondere einige SLAs in den Code einfügen und die Sensorkomponenten ändern.

Schau im Quellcode von DAG nach, ob noch etwas hinzugefügt werden muss. Das Wörterbuch default_args wurde bereits für dich definiert, muss aber möglicherweise noch angepasst werden.

Diese Übung ist Teil des Kurses

Einführung in Apache Airflow in Python

Kurs anzeigen

Anleitung zur Übung

Füge mit der Funktion timedelta() eine sla von 90 Minuten auf DAG hinzu.
Aktualisiere das Objekt FileSensor, um mit dem Parameter poke_interval alle 45 Sekunden nach Dateien zu suchen.
Ändere die python_task, um Airflow-Variablen an den Callable zu senden. Beachte, dass der Callable so konfiguriert ist, dass er die Variablen mit dem Argument provide_context akzeptiert.

Interaktive Übung

In dieser interaktiven Übung kannst du die Theorie in die Praxis umsetzen.

Übung starten