问题描述
我无法将语句导入为-
from airflow.contrib.operators.gcp_sql_operator import CloudSqlQueryOperator
我想将其导入到我的DAG文件中，该文件将在版本为1.10.0而不是1.9.0的cloud composer airflow中运行.这里只是检查一下，我试图将gcs_to_gcs导入为-
I want to import this in my DAG file which will be run in cloud composer airflow whose version is 1.10.0 and not 1.9.0.Here just to check, I tried to import gcs_to_gcs as-
from airflow.contrib.operators.gcs_to_gcs import GoogleCloudStorageToGoogleCloudStorageOperator
我可以导入此文件，但不能导入gcp_sql_operator.
I am able to import this but not gcp_sql_operator.
推荐答案
自Airflow 1.10.2 ，目前作曲家版本.对1.10.2的支持应该很快会在Composer中提供，然后您可能要按照gcp_sql_operator.py及其依赖项复制到Composer dags文件夹中. com/composer/docs/how-to/using/installing-python-dependencies#install-local"rel =" noreferrer>此处.
The CloudSqlQueryOperator operator is released since Airflow 1.10.2, which is currently not supported in Composer versions. The support for 1.10.2 should be available soon in Composer, before that you may want to manually copy gcp_sql_operator.py and its dependencies to the Composer dags folder following the instruction here.
这篇关于Cloud Composer中没有名为'gcp_sql_operator'的模块的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！