Google Cloud数据流：如何每个工作人员（单个）仅初始化一次Hikari连接池？

Question

Hibernate Utils与Hikari配置一起创建了会话工厂。当前，我们在ParDo的@Setup方法中进行操作，但是它打开了太多的连接。因此，有没有很好的示例初始化每个工作程序的连接池？

Answer 1

如果您在@Setup中使用DoFn方法创建数据库连接，请记住，Apache Beam将为每个工作程序实例线程创建连接池。这可能会导致大量数据库连接，具体取决于启动的工作程序数量。

您可以在ParDo中使用Singleton类来创建您的连接池并控制每个工作程序的连接数。您可以在这里查看示例实现

http://mail-archives.apache.org/mod_mbox/beam-issues/201905.mbox/[e-mail]%3E