云作曲家中没有名为“gcp_sql_operator”的模块

Question

我无法将语句导入为-

from airflow.contrib.operators.gcp_sql_operator import CloudSqlQueryOperator

我想将它导入到我的 DAG 文件中，该文件将在版本为 1.10.0 而不是 1.9.0 的云作曲家气流中运行。这里只是为了检查，我尝试将 gcs_to_gcs 导入为-

from airflow.contrib.operators.gcs_to_gcs import GoogleCloudStorageToGoogleCloudStorageOperator

我可以导入它，但不能导入 gcp_sql_operator。

Answer 1

该CloudSqlQueryOperator运算符自 Airflow 1.10.2起发布，目前Composer 版本不支持该运算符。Composer 应该很快就会提供对 1.10.2 的支持，在此之前，您可能需要按照此处的说明手动将gcp_sql_operator.py其及其依赖项复制到 Composerdags文件夹中。