В облачном компоновщике нет модуля с именем gcp_sql_operator

Question

Я не могу импортировать выписку как-

from airflow.contrib.operators.gcp_sql_operator import CloudSqlQueryOperator

Я хочу импортировать это в мой файл DAG, который будет работать в облачном компоновщике, версия которого 1.10.0, а не 1.9.0. Вот только для проверки, я попытался импортировать gcs_to_gcs as-

from airflow.contrib.operators.gcs_to_gcs import GoogleCloudStorageToGoogleCloudStorageOperator

Я могу импортировать это, но не gcp_sql_operator.

Answer 1

Оператор CloudSqlQueryOperator освобожден после Airflow 1.10.2 , который в настоящее время не поддерживается в версиях Composer . Поддержка 1.10.2 должна быть доступна в ближайшее время в Composer, перед этим вы можете вручную скопировать gcp_sql_operator.py и его зависимости в папку Composer dags, следуя инструкции здесь .