Как в Apache Airflow я могу получить результаты оператора «SELECT» в базе данных Google Cloud SQL?

Question

Мне нужно получить данные из базы данных Google Cloud SQL в одном из моих Dags.

Я пытался использовать CloudSqlQueryOperator (https://airflow.readthedocs.io/en/latest/howto/connection/gcp_sql.html), но мои запросы SELECT не работают. Есть ли способ извлечь данные из запроса на выборку в Google Cloud SQL из Airflow?

Answer 1

Оператор запроса не «не возвращает никаких данных из базы данных, поэтому передавать запросы DQL бесполезно».

Вы можете или не хотите использовать оператор экспорта вместо этого, в зависимости от