Как я могу добавить имя базы данных в соединениях воздушного потока, когда у меня есть экземпляр базы данных - PullRequest
0 голосов
/ 08 июля 2019

Я использую airflow для выполнения некоторых процедур и сохранения данных в экземпляре Google Cloud SQL, который содержит несколько баз данных.Поэтому я добавил соединение в поток воздуха, и я не могу найти, где я должен поместить имя базы данных.Из-за этой проблемы я не могу создать движок sqlalchemy в своем коде Python для сохранения результатов.

Я сделал что-то очень странное, что работает: get_uri и заменил имя "None" реальным именембазы данных, а затем позвоните create_engine.Однако я не думаю, что это хорошее решение.

Может кто-нибудь сказать мне, где я должен поместить имя базы данных (в соединении или в коде), чтобы она работала правильно.Спасибо за вашу помощь.

1 Ответ

0 голосов
/ 11 июля 2019

AFAIK, имя базы данных входит в поле schema.


Между тем, выбор conn_type="MySql" не должен создавать никаких проблем, покавозвращаемое значение get_uri(..) функция действительна

...