cloud composer中没有名为'gcp_sql_operator‘的模块

Question

我无法导入语句，因为-

from airflow.contrib.operators.gcp_sql_operator import CloudSqlQueryOperator

我想将其导入我的DAG文件中，该文件将在版本为1.10.0而不是1.9.0的cloud composer airflow中运行。这里，我尝试将gcs_to_gcs导入为-

from airflow.contrib.operators.gcs_to_gcs import GoogleCloudStorageToGoogleCloudStorageOperator

我可以导入这个，但不能导入gcp_sql_operator。

Answer 1

CloudSqlQueryOperator运算符是在Airflow 1.10.2之后发布的，Composer versions当前不支持该操作符。Composer很快就会提供对1.10.2的支持，在此之前，您可能需要按照here说明手动将gcp_sql_operator.py及其依赖项复制到Composer dags文件夹中。