Airflow/Python 等非常新,但似乎无法弄清楚我需要做什么来解决这个问题..
Airflow 在 Puckel/Docker 上运行
完整的错误是:
Broken DAG : [/usr/local/airflow/dags/xxxx.py] No module named 'airflow.contrib.operators.gsc_to_gcs'
Run Code Online (Sandbox Code Playgroud)
在 python 代码中,我写了:
from airflow.contrib.operators.gcs_to_gcs import GoogleCloudStorageToGoogleCloudStorageOperator
Run Code Online (Sandbox Code Playgroud)
我猜我需要安装该gcs_to_gcs模块,但我不确定如何执行此操作。
任何具体说明将不胜感激:-)