以下列方式导入运算符:
from airflow.contrib.operators.gcs_download_operator import GoogleCloudStorageDownloadOperator
然后尝试在DAG中使用它:
download_file = GoogleCloudStorageDownloadOperator(bucket='us-central1-scale-training-d7d12089-bucket',
google_cloud_storage_conn_id='google_cloud_default',
object='params.json',
filename='params.json')
接收到此错误:
未定义“GoogleCloudStorageDownloadOperator”
编辑:我正在使用,所以我假设相关的依赖项已经安装。
发布于 2018-09-10 08:21:57
如果还没有,还需要将GCP依赖项添加到气流中:
pip install apache-airflow[gcp_api]
在docs中有更多关于安装的信息:https://airflow.apache.org/installation.html
https://stackoverflow.com/questions/52260269
复制