Passare dati con XCom

Stai aggiornando un workflow ETL per usare un XCom e tenere traccia delle informazioni in modo più semplice. Per questo, devi aggiornare le dipendenze tra i task nel tuo Dag.

Hai già quattro task definiti, utilizzabili come segue:

extract() - Restituisce order_data
transform(order_data) - Restituisce dati riepilogati
load(summary_data) - Non restituisce informazioni XCom
send_report() - Un task non XCom che gestisce le notifiche

Questo esercizio fa parte del corso

Introduzione ad Apache Airflow in Python

Visualizza il corso

Istruzioni dell'esercizio

Inserisci il task transform tra extract() e load() per completare la catena.
Assegna il risultato a una variabile chiamata etl_result.
Imposta send_report per essere eseguito dopo la variabile etl_result.

Esercizio pratico interattivo

Prova a risolvere questo esercizio completando il codice di esempio.

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

Modifica ed esegui il codice