Search code examples
pythonmysqlgoogle-cloud-dataflowgoogle-cloud-sqlapache-beam-io

google cloud dataflow mysql io connector using python

what is the efficient way to insert streaming records into MySQL from google-dataflow using python.Is there any IO connector as in case of bigquery?I see that or bigquery has beam.io.WriteToBigQuery. how can we use similar io connector in cloud-MySQL

Solution

  • You can you JDBCIO to read and write data from/to a JDBC database compliant database.

    You can find the details here testWrite