jjzjj

BulkProcessor

全部标签

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

我正在为golang使用elastic包。我想使用它的BulkProcessor在后台发送大量文档。如wiki所示,我可以创建一个处理器。但我不想每次发送文件时都创建它。我想知道连接中是否存在处理器服务并将数据传递给现有处理器而不是创建新处理器。我怎样才能实现它? 最佳答案 注册批量处理器与发送文件分开。批量处理器的生命周期与您的进程一样长,因此要确保您只创建一次,请在进程启动时创建它。然后在您申请的其他地方,您可以随时发送文件。或者,如果您必须按需进行,您可以使用sync.Once以确保创建只发生一次。

ElasticSearch 7.x 版本使用 BulkProcessor 实现批量添加数据

ElasticSearch1、ElasticSearch学习随笔之基础介绍2、ElasticSearch学习随笔之简单操作3、ElasticSearch学习随笔之javaapi操作4、ElasticSearch学习随笔之SpringBootStarter操作5、ElasticSearch学习随笔之嵌套操作6、ElasticSearch学习随笔之分词算法7、ElasticSearch学习随笔之高级检索8、ELK技术栈介绍9、Logstash部署与使用10、ElasticSearch7.x版本使用BulkProcessor实现批量添加数据11、ElasticSearch8.x弃用了HighLeve