Einen DAG per Python planen

Du hast schon einiges über das Erstellen von DAGs gelernt. Jetzt möchtest du einen bestimmten DAG an einem bestimmten Wochentag zu einer festen Uhrzeit einplanen. Diese Informationen sollen im Code stehen, 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 für dich importiert.

Diese Übung ist Teil des Kurses

Einführung in Apache Airflow mit Python

Kurs anzeigen

Anleitung zur Übung

Setze das Startdatum des DAG auf den 1. November 2023.
Konfiguriere retry_delay auf 20 Minuten. Du lernst mehr über das timedelta-Objekt in Kapitel 3. Für den Moment musst du nur wissen, dass es einen Integerwert erwartet.
Verwende die Cron-Syntax, um jeden Mittwoch um 12:30 Uhr zu planen.

Interaktive Übung

Vervollständige den Beispielcode, um diese Übung erfolgreich abzuschließen.

# 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='____')

Code bearbeiten und ausführen