Obecnie Cloud Dataflow nie udostępnia źródła danych wejściowych MySQL.
Preferowanym sposobem zaimplementowania obsługi tego jest zaimplementowanie źródła danych wejściowych zdefiniowanego przez użytkownika które mogą obsługiwać zapytania MySQL.
Alternatywnym sposobem byłoby wykonanie zapytania w programie głównym i umieszczenie wyników zapytania w tymczasowej lokalizacji w GCS, przetworzenie wyników za pomocą Dataflow i tymczasowe usunięcie plików.
Mam nadzieję, że to pomoże
