1. Learn
    2. /
  2. 课程
    3. /
  3. Python 中的 Apache Airflow 入门
Connected

道练习

使用 XCom 传递数据

您正在将一个 ETL 工作流更新为使用 XCom，以便更容易追踪信息。因此，您需要更新 Dag 中各任务之间的依赖关系。

您已经定义了 4 个任务，可按如下方式使用：

  • extract() - 返回 order_data
  • transform(order_data) - 返回汇总数据
  • load(summary_data) - 不返回任何 XCom 信息
  • send_report() - 一个不使用 XCom 的任务，用于处理通知

说明

100 XP
  • 在 extract() 和 load() 之间插入 transform 任务，完成任务链。
  • 将结果赋值给名为 etl_result 的变量。
  • 设置在 etl_result 之后运行 send_report。