Как подключить композитор воздушного потока с базой данных MySQL ⇐ MySql

[Anonymous]

Я хочу подключить свой композитор с моей базой данных MySQL . Я создал среду в GCP Composer . В пользовательском интерфейсе Airflow я добавляю новое соединение, подобное этому Admin -> Connection -> Добавить новое соединение и т. Д. . Там я добавляю имя моего идентификатора подключения ,

Код: Выделить всё

Connection Type= mysql

, host , schema , login , пароль , port и in extras У меня есть учетные данные SSL в json формат, как это.

Код: Выделить всё

{
"ssl": {
"ssl_ca": "/home/airflow/gcs/data/my-creds/server-ca.pem",
"ssl_cert": "/home/airflow/gcs/data/my-creds/client-cert.pem",
"ssl_key": "/home/airflow/gcs/data/my-creds/client-key.pem"
}
}

У меня есть добавление учетных данных SSL в папку моего композитора в Data папку. Я хочу уточнить, что я обязан получить доступ к моей базе данных MySQL с учетными данными SSL. После этого я запускаю свой DAG , который включает этот код:

Код: Выделить всё

retrieve_ids_task = SQLExecuteQueryOperator(
task_id="retrieve_ids",
retry_on_failure=False,
conn_id=GCP_SQL_CONNECTION,
sql="""
SELECT ....
)
< /code>
Проблема, с которой я сталкиваюсь, заключается в этом
ERROR - Exception in ...: (2003, "Can't connect to MySQL server on 'hostname:port' (110)")

. Я проверял пути и, кажется, не имею проблемы там. Кто -нибудь может помочь мне с моей проблемой или предложить другим способом?

Подробнее здесь: https://stackoverflow.com/questions/796 ... l-database