Plan een Dag via Python
Je hebt al best wat geleerd over het maken van Dags, maar nu wil je een specifieke Dag plannen op een bepaalde dag van de week op een bepaald tijdstip. Je wilt dat de code deze informatie bevat voor het geval een collega de Dag op een andere server moet herinstalleren.
Het Airflow-dag-object en de juiste datetime-methoden zijn alvast voor je geïmporteerd.
Deze oefening maakt deel uit van de cursus
Introductie tot Apache Airflow in Python
Oefeninstructies
- Stel de startdatum van de Dag in op 1 november 2025.
- Gebruik de cron-syntaxis om een schema te configureren van elke woensdag om 12:30 uur.
Praktische interactieve oefening
Probeer deze oefening eens door deze voorbeeldcode in te vullen.
@dag(
dag_id='update_dataflows',
# Set to November 1, 2025
start_date=datetime(____),
# Every Wednesday at 12:30pm
schedule='____'
)
def update_dataflows():
@task
def pull_source_data():
pass
update_dataflows()