Een SLA definiëren
Je hebt met succes meerdere Airflow-workflows in productie gebracht, maar je hebt nu geen manier om te bepalen of een workflow te lang draait. Na overleg met je manager en je team besluit je een SLA op DAG-niveau te implementeren op een testworkflow.
Alle benodigde Airflow-bibliotheken zijn al voor je geïmporteerd.
Deze oefening maakt deel uit van de cursus
Introductie tot Apache Airflow in Python
Oefeninstructies
- Importeer het
timedelta-object. - Definieer een
slavan 30 minuten. - Voeg de SLA toe aan de DAG.
Praktische interactieve oefening
Probeer deze oefening eens door deze voorbeeldcode in te vullen.
# 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)