1. Nauka
    2. /
  2. Kursy
    3. /
  3. Wprowadzenie do Apache Airflow w Pythonie
Connected

ćwiczenie

Przekazywanie danych za pomocą XCom

Aktualizujesz przepływ ETL, aby korzystał z XCom – dzięki temu łatwiej będzie śledzić przepływ informacji. W związku z tym musisz zaktualizować zależności między zadaniami w swoim DAG-u.

Masz już zdefiniowane cztery zadania, które działają następująco:

  • extract() – zwraca order_data
  • transform(order_data) – zwraca przetworzone dane
  • load(summary_data) – nie zwraca informacji XCom
  • send_report() – zadanie niezwiązane z XCom, obsługujące powiadomienia

Instrukcje

100 XP
  • Wstaw zadanie transform między extract() a load(), aby uzupełnić łańcuch.
  • Przypisz wynik do zmiennej o nazwie etl_result.
  • Ustaw zadanie send_report tak, aby uruchamiało się po zmiennej etl_result.