Planen Sie eine DAG über Python
Du hast schon einiges über die Erstellung von DAGgelernt, aber jetzt möchtest du eine bestimmte DAG an einem bestimmten Wochentag zu einer bestimmten Zeit einplanen. Du möchtest, dass der Code diese Informationen enthält, falls ein Kollege die DAG auf einem anderen Server neu installieren muss.
Das Airflow DAG Objekt und die entsprechenden datetime Methoden wurden für dich importiert.
Diese Übung ist Teil des Kurses
Einführung in Apache Airflow in Python
Anleitung zur Übung
- Lege das Startdatum der DAG auf den 1. November 2023 fest.
- Stelle die
retry_delayauf 20 Minuten ein. Du wirst in Kapitel 3 mehr über das Timedelta-Objekt erfahren. Für den Moment musst du nur wissen, dass sie einen Integer-Wert erwartet. - Verwende die cron-Syntax, um einen Zeitplan für jeden Mittwoch um 12:30 Uhr zu konfigurieren.
Interaktive Übung
Versuche dich an dieser Übung, indem du diesen Beispielcode vervollständigst.
# Update the scheduling arguments as defined
default_args = {
'owner': 'Engineering',
'start_date': datetime(____, ____, ____),
'email': ['[email protected]'],
'email_on_failure': False,
'email_on_retry': False,
'retries': 3,
'retry_delay': timedelta(minutes=____)
}
dag = DAG('update_dataflows', default_args=default_args, schedule_interval='____')