1. Learn
    2. /
  2. Cursuri
    3. /
  3. Introducere în Apache Airflow în Python
Connected

exercițiu

Transmiterea datelor cu XCom

Ești în procesul de actualizare a unui flux ETL pentru a utiliza un XCom, cu scopul de a urmări mai ușor informațiile. Prin urmare, trebuie să actualizezi dependențele dintre taskurile din DAG-ul tău.

Ai deja patru taskuri definite, care pot fi folosite astfel:

  • extract() – Returnează order_data
  • transform(order_data) – Returnează date sumarizate
  • load(summary_data) – Nu returnează informații XCom
  • send_report() – Un task non-XCom care gestionează notificările

Instrucțiuni

100 XP
  • Inserează taskul transform între extract() și load() pentru a completa lanțul.
  • Atribuie rezultatul unei variabile numite etl_result.
  • Setează send_report să ruleze după variabila etl_result.