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
Anleitung zur Übung
- Füge mit der Funktion
timedelta()eineslavon 90 Minuten auf DAG hinzu. - Aktualisiere das Objekt
FileSensor, um mit dem Parameterpoke_intervalalle 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 Argumentprovide_contextakzeptiert.
Interaktive Übung zum Anfassen
Setzen Sie die Theorie mit einer unserer interaktiven Übungen in die Tat um
Beginnen Sie mit dem Training