Понастоящем Cloud Dataflow не предоставя входен източник на MySQL.
Предпочитаният начин за внедряване на поддръжка за това е да се внедри дефиниран от потребителя източник на въвеждане който може да обработва MySQL заявки.
Алтернативен начин би бил да изпълните заявката в основната програма и да поставите резултатите от заявката на временно място в GCS, да обработите резултатите с помощта на Dataflow и да премахнете файловете временно.
Надявам се това да помогне
