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

Question

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

Answer 1

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

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