通过数据流管道写入云 SQL 非常慢

Question

我设法通过JDBCIO连接到云sql

DataSourceConfiguration.create("com.mysql.jdbc.Driver"，"jdbc：mysql：//google/？cloudSqlInstance=：：&socketFactory=com.google.cloud.sql.mysql.SocketFactory&user=&password="(

这有效，但是，对于 2 条记录，批量写入需要 5-1000 分钟，这很糟糕。 我尝试了不同的网络，看看这是否相关，结果是一致的。

有人有什么想法吗？

Answer 1

在哪里初始化此连接？如果您在 DoFn 内部执行此操作，则在每个捆绑包上构建和拆除套接字时会产生延迟。

看看 DoFn.Setup 它提供了一种简洁的方式来初始化将在捆绑调用中持久保存的资源。