Einen einfachen Dag erstellen
du hast dir die Airflow-Komponenten angesehen und möchtest nun eigene Workflows testen. Zum Start definierst du die Standardparameter und erstellst ein Dag-Objekt für deinen Workflow.
Das Objekt datetime wurde bereits für dich importiert.
Diese Übung ist Teil des Kurses
<Kurs>Einführung in Apache Airflow mit Python</Kurs>Übungsanweisungen
- Importiere das Airflow-Dag-Objekt; beachte, dass die Groß-/Kleinschreibung wichtig ist.
- Definiere den Dag-Decorator und nenne den Dag
example_etl. - Führe die Dag-Funktion am Ende der Codedatei aus.
Interaktive praktische Übung
Versuche dich an dieser Übung, indem du diesen Beispielcode vervollständigst.
# Import the dag object
from ____ import dag
# Define the Dag attributes
____(
____='example_etl',
start_date=datetime(2026, 3, 1),
)
def example_etl():
pass
# Run the Dag
____()