我设法通过JDBCIO连接到云sql
DataSourceConfiguration.create("com.mysql.jdbc.Driver","jdbc:mysql://google/?cloudSqlInstance=::&socketFactory=com.google.cloud.sql.mysql.SocketFactory&user=&password=")
这是可行的,但是,批量写入1000条记录需要2-5分钟,这是很糟糕的。我尝试了不同的网络,看看这是否相关,结果是一致的。
有谁有什么想法吗?
发布于 2018-09-21 23:12:20
您在何处初始化此连接?如果你在你的DoFn中做这件事,它将会产生延迟,因为套接字是在每个包上构建和拆除的。
看一看DoFn.Setup,它提供了一种干净的方式来初始化资源,这些资源将在包调用中持久存在。
https://stackoverflow.com/questions/52444974
复制相似问题