Passando dados com XCom

Você está no processo de atualizar um workflow de ETL para usar um XCom e acompanhar informações com mais facilidade. Para isso, é preciso atualizar as dependências entre as tarefas no seu Dag.

Você já tem quatro tarefas definidas que podem ser usadas da seguinte forma:

extract() - Retorna order_data
transform(order_data) - Retorna dados resumidos
load(summary_data) - Não retorna informações de XCom
send_report() - Uma tarefa que não usa XCom e cuida das notificações

Este exercício faz parte do curso

Introdução ao Apache Airflow em Python

Ver curso

Instruções do exercício

Insira a tarefa transform entre extract() e load() para completar a cadeia.
Atribua o resultado a uma variável chamada etl_result.
Defina send_report para executar após a variável etl_result.

Exercício interativo prático

Experimente este exercício completando este código de exemplo.

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

Editar e executar o código