elasticsearch - 如何检查 ElasticSearch BulkProcessor 服务是否存在

Question

我正在为 golang 使用 elastic 包。我想使用它的 BulkProcessor 在后台发送大量文档。如 wiki 所示，我可以创建一个处理器。但我不想每次发送文件时都创建它。我想知道连接中是否存在处理器服务并将数据传递给现有处理器而不是创建新处理器。我怎样才能实现它？

Answer 1

注册批量处理器与发送文件分开。批量处理器的生命周期与您的进程一样长，因此要确保您只创建一次，请在进程启动时创建它。然后在您申请的其他地方，您可以随时发送文件。

或者，如果您必须按需进行，您可以使用 sync.Once以确保创建只发生一次。