Einen Dag per Python planen
Du hast schon einiges darüber gelernt, wie man Dags erstellt. Jetzt möchtest du jedoch einen bestimmten Dag an einem bestimmten Wochentag zu einer festgelegten Uhrzeit planen. Der Code soll diese Informationen enthalten, falls eine Kollegin oder ein Kollege den Dag auf einem anderen Server neu installieren muss.
Das Airflow-dag-Objekt und die passenden datetime-Methoden wurden bereits für dich importiert.
Diese Übung ist Teil des Kurses
<Kurs>Einführung in Apache Airflow mit Python</Kurs>Übungsanweisungen
- Setze das Startdatum des Dag auf den 1. November 2025.
- Verwende die Cron-Syntax, um einen Zeitplan für jeden Mittwoch um 12:30 Uhr zu konfigurieren.
Interaktive praktische Übung
Versuche dich an dieser Übung, indem du diesen Beispielcode vervollständigst.
@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()