1. Učit se
    2. /
  2. Kurzy
    3. /
  3. Úvod do Apache Airflow v Pythonu
Connected

Cvičení

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

Pokyny

100 XP
  • 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.