Al momento, Cloud Dataflow non fornisce l'origine di input MySQL.
Il modo migliore per implementare il supporto per questo è implementare una origine di input definita dall'utente in grado di gestire le query MySQL.
Un modo alternativo sarebbe eseguire la query nel programma principale e collocare i risultati della query in una posizione temporanea in GCS, elaborare i risultati utilizzando Dataflow e rimuovere i file in modo temporaneo.
Spero che questo aiuti