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

道练习

使用 @task.bash 定义 BashOperator

Bash 任务允许您指定任意 shell 命令或脚本，并将其加入 Airflow 工作流。这是在您的环境中落地 Airflow 的一个很好的起点。

因此，您一直在交付给数据分析团队同事之前，手动运行一些脚本清洗数据（使用名为 cleanup.sh 的脚本）。随着分配给您的此类任务越来越多，您发现手动运行已难以跟上，更不用说处理错误或重试了。您希望将这个简单脚本实现为一个 Airflow operator。

Airflow 的 dag 和 task 对象已经导入。

说明

100 XP
  • 使用 @task.bash 装饰器定义该任务。
  • 使用方法名 cleanup_task。
  • 让该任务返回 cleanup.sh。