Pour le moment, Cloud Dataflow ne fournit pas de source d'entrée MySQL.
La meilleure façon d'implémenter cette prise en charge consiste à implémenter une source d'entrée définie par l'utilisateur qui peut gérer les requêtes MySQL.
Une autre méthode consisterait à exécuter la requête dans le programme principal et à transférer les résultats de la requête vers un emplacement temporaire dans GCS, à traiter les résultats à l'aide de Dataflow et à supprimer les fichiers temporaires.
J'espère que cela vous aidera