我试图在MWAA中使用类EcsCreateClusterOperator,但是我得到了以下错误:
Broken DAG: [/usr/local/airflow/dags/etl_basic_ecs/etl_ecs_basic_dag.py] Traceback (most recent call last):
File "<frozen importlib._bootstrap>", line 219, in _call_with_frames_removed
File "/usr/local/airflow/dags/etl_basic_ecs/etl_ecs_basic_dag.py", line 5, in <module>
from airflow.providers.amazon.aws.operators.ecs import (
ImportError: cannot import name 'EcsCreateClusterOperator' from 'airflow.providers.amazon.aws.operators.ecs' (/usr/local/lib/python3.7/site-packages/airflow/providers/amazon/aws/operators/ecs.py)这个库在我安装的本地环境中非常好地工作:
pip install apache-airflow-providers-amazon==5.0.0 在部署到MWAA之前,我还将这个库(Version5.0.0)添加到我的requirements.txt文件中,在UI中似乎安装了提供程序:
更新日志显示下载了库:
下面是这个类的文档:api/airflow/providers/amazon/aws/operators/ecs/index.html这个类是最近引入的(版本5.0.0)。
默认情况下,MWAA (Airflow 2.2.2)有一个更老版本(2.4)的Amazon提供商,看起来气流实际上是在加载旧版本的库。
任何帮助都将不胜感激,谢谢。
发布于 2022-09-11 15:20:14
https://stackoverflow.com/questions/73614477
复制相似问题