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

Acest exercițiu face parte din cursul

Introducere în Apache Airflow în Python

Vezi cursul

Instrucțiuni pentru exercițiu

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.

Exercițiu interactiv practic

Încearcă acest exercițiu completând acest cod de exemplu.

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

Editează și rulează codul