使用Java API检查并插入Elasticsearch

Arpit乔希

我如何以最有效的方式使用Java api在Elasticsearch中的索引中插入数据。首先,我需要使用一个让字段log_id来检查条目是否存在,如果存在,我将更新该条目,否则我将插入一个elasticsearch的新条目。elasticsearch中是否有任何方法可以做到这两种。

回溯

您可以批量处理(如果要批量插入和更新),下面是一个简单的示例:

检查是否log_id已经存在:

如果现有的create Update json字符串\n应该存在,

{ "update" : {"_id" : "1", "_type" : "type1", "_index" : "index1"} }\n{ "doc" : {"field2" : "value2"} }

否则创建一个如下所示的Insert Json \n

{ "index" : { "_index" : "test", "_type" : "type1", "_id" : "1" } }\n{ "field1" : "value1" }

将它们列入清单并执行BULK API

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章