Daten mit XCom übergeben

Du aktualisierst gerade einen ETL-Workflow, um ein XCom zu nutzen und Informationen leichter nachzuverfolgen. Dazu musst du die Abhängigkeiten zwischen den Tasks in deinem Dag aktualisieren.

Du hast bereits vier Tasks definiert, die wie folgt verwendet werden können:

extract() – gibt order_data zurück
transform(order_data) – gibt zusammengefasste Daten zurück
load(summary_data) – gibt keine XCom-Informationen zurück
send_report() – ein Task ohne XCom, der Benachrichtigungen verarbeitet

Diese Übung ist Teil des Kurses

<Kurs>Einführung in Apache Airflow mit Python</Kurs>

Kurs ansehen

Übungsanweisungen

Füge den transform-Task zwischen extract() und load() ein, um die Kette zu vervollständigen.
Weise das Ergebnis einer Variablen namens etl_result zu.
Setze send_report so, dass es nach der Variable etl_result ausgeführt wird.

Interaktive praktische Übung

Versuche dich an dieser Übung, indem du diesen Beispielcode vervollständigst.

@dag(start_date=datetime(2026,4,1))
def etl_example():
    # Chain extract, transform, and load, assigning the result
    ____ = load(____(extract()))
    # Run send_report after the ETL tasks
    etl_result ____ ____()
    
etl_example()

Code bearbeiten und ausführen