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

道练习

更多 @tasks

为继续实现您的工作流，您需要再添加一步，用于解析并保存已下载文件的更改。Dag process_sales 已定义，并且已添加了 pull_file 任务。本题中，Python 函数也已为您定义好：parse_file(inputfile, outputfile)。

请注意，在实现 Airflow 任务时，您不一定总能理解给定的每个具体步骤。只要您能理解如何将这些步骤封装进 Airflow 的结构中，您就能够实现所需的工作流。

说明

100 XP
  • 使用 parse_file 方法创建一个 Airflow 任务。
  • 使用必要的参数调用该任务。