Eine SLA definieren
Du hast mehrere Airflow-Workflows erfolgreich in Produktion gebracht, aber derzeit keine Möglichkeit festzustellen, ob ein Workflow zu lange läuft. Nach Rücksprache mit deiner Führungskraft und deinem Team entscheidest du dich, auf Ebene des DAGs eine SLA in einem Test-Workflow zu implementieren.
Alle passenden Airflow-Bibliotheken wurden bereits für dich importiert.
Diese Übung ist Teil des Kurses
Einführung in Apache Airflow mit Python
Anleitung zur Übung
- Importiere das Objekt
timedelta. - Definiere eine
slavon 30 Minuten. - Füge die SLA dem DAG hinzu.
Interaktive Übung
Vervollständige den Beispielcode, um diese Übung erfolgreich abzuschließen.
# Import the timedelta object
____
# Create the dictionary entry
default_args = {
'start_date': datetime(2024, 1, 20),
'____': ____
}
# Add to the DAG
test_dag = DAG('test_workflow', default_args=____, schedule_interval=None)