Předávání dat pomocí XCom

Právě aktualizuješ ETL workflow tak, aby používalo XCom pro snazší sledování informací. V rámci toho potřebuješ upravit závislosti mezi tasky ve svém Dagu.

Máš definované čtyři tasky, které fungují takto:

extract() – vrací order_data
transform(order_data) – vrací agregovaná data
load(summary_data) – nevrací žádné XCom informace
send_report() – task bez XComu, který zajišťuje notifikace

Toto cvičení je součástí kurzu

Úvod do Apache Airflow v Pythonu

Zobrazit kurz

Pokyny k cvičení

Vlož task transform mezi extract() a load() a tím řetězec dokonči.
Výsledek přiřaď do proměnné s názvem etl_result.
Nastav, aby send_report běžel až po proměnné etl_result.

Interaktivní cvičení na vyzkoušení si v praxi

Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.

@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()

Upravit a spustit kód