使用 XCom 传递数据
您正在将一个 ETL 工作流更新为使用 XCom，以便更容易追踪信息。因此，您需要更新 Dag 中各任务之间的依赖关系。
您已经定义了 4 个任务，可按如下方式使用：
extract()- 返回order_datatransform(order_data)- 返回汇总数据load(summary_data)- 不返回任何 XCom 信息send_report()- 一个不使用 XCom 的任务，用于处理通知
本练习是课程的一部分
Python 中的 Apache Airflow 入门
练习说明
- 在
extract()和load()之间插入transform任务，完成任务链。 - 将结果赋值给名为
etl_result的变量。 - 设置在
etl_result之后运行send_report。
交互式实操练习
通过完成这段示例代码来试试这个练习。
@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()