Definieren einer SLA
Du hast mehrere Airflow-Workflows erfolgreich in die Produktion implementiert, aber du hast derzeit keine Methode, um festzustellen, ob ein Workflow zu lange braucht, um zu laufen. Nachdem du dich mit deinem Manager und deinem Team beraten hast, beschließt du, eine SLA auf der Ebene DAG in einen Test-Workflow zu implementieren.
Alle passenden Airflow-Bibliotheken sind für dich importiert worden.
Diese Übung ist Teil des Kurses
Einführung in Apache Airflow in Python
Anleitung zur Übung
- Importiere das Timedelta-Objekt.
- Lege eine
slavon 30 Minuten fest. - Füge die SLA zur DAG hinzu.
Interaktive Übung zum Anfassen
Probieren Sie diese Übung aus, indem Sie diesen Beispielcode ausführen.
# 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)