airflow - MWAA Apache Airflow DAG 导入 EcsOperator 时出错

Question

我正在尝试将 Airfow DAG 部署到 MWAA。

我的requirements.txt:

apache-airflow[amazon] == 3.2.0

我像这样导入EcsOperator:

from airflow.contrib.operators.ecs_operator import EcsOperator

但是，我收到此错误:

Broken DAG: [/usr/local/airflow/dags/mydag.py] Traceback (most recent call last):
  File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
  File "/usr/local/airflow/dags/mydag.py", line 4, in <module>
    from airflow.contrib.operators.ecs_operator import EcsOperator
ImportError: cannot import name 'EcsOperator' from 'airflow.contrib.operators.ecs_operator' (/usr/local/lib/python3.7/site-packages/airflow/contrib/operators/ecs_operator.py)

我在这里做错了什么？

Answer 1

What am I doing wrong here?

您可能引用了 Airflow 文档的不同版本(1.10.12？)。

airflow.contrib.operators.ecs_operator (1.10.12)

3.2.0 的文档是 here 。您可以像这样导入 EcsOperator:

from airflow.providers.amazon.aws.operators.ecs import EcsOperator

airflow.providers.amazon.aws.operators.ecs (3.2.0)