ES _bulk 批量操作用法

es版本：7.6

es 的 bulk 操作，是用来批量发送请求，或者理解为批量操作的。

支持4种操作

bulk 支持多种操作，如下create、index、update、delete。

create 如果文档不存在就创建，但如果文档存在就返回错误
index 如果文档不存在就创建，如果文档存在就更新
update 更新一个文档，如果文档不存在就返回错误
delete 删除一个文档，如果要删除的文档id不存在，就返回错误

语法结构

语法结构上，一个操作分为两部分，一部分指定操作类型和索引，另一部分是请求体； $\color{#ea4335}{要求每个部分的json必须为一行}$ 。
针对不同的操作类型，第二行的请求体是不一样的
（1）index 和 create 第二行是source数据体
（2）delete 没有第二行
（3）update 第二行可以是partial doc，upsert或者是script

示例

POST /_bulk
{"create":{"_index":"索引名", "_id":"文档"}} // 动作
{"field1":"value1"} //请求体

批量执行两个动作

POST /_bulk
{"create":{"_index":"zm_blog5"}}
{"name":"小刘","desc":{"simple":"山西人","complete":"山西人，定居太原","other":"程序员"}}
{"create":{"_index":"zm_blog5"}}
{"name":"小刘","desc":{"simple":"山西人","complete":"山西人，定居太原","other":"程序员"}}

POST zm_blog5/_bulk
{"create":{}}
{"name":"小刘","desc":{"simple":"山西人","complete":"山西人，定居太原","other":"程序员"}}
{"create":{}}
{"name":"小刘","desc":{"simple":"山西人","complete":"山西人，定居太原","other":"程序员"}}

执行返回结果

执行结果是分开的，比如发送2个操作，两个操作结果分别返回，可能其中一个失败另一个成功

比如执行：

POST /_bulk
{"create":{"_index":"zm_blog5"}}
{"name":"小刘","desc":{"simple":"山西人","complete":"山西人，定居太原","other":"程序员"}}
{"create":{"_index":"zm_blog5"}}
{"name":"小刘","desc":{"simple":"山西人","complete":"山西人，定居太原","other":"程序员"}}

返回结果：
每个返回结果中有 http status，以及其他详细信息。

{
  "took" : 8,
  "errors" : false,
  "items" : [
    {
      "create" : {
        "_index" : "zm_blog5",
        "_type" : "_doc",
        "_id" : "wKNBpYQBCuglFCwN_ObP",
        "_version" : 1,
        "result" : "created",
        "_shards" : {
          "total" : 1,
          "successful" : 1,
          "failed" : 0
        },
        "_seq_no" : 1,
        "_primary_term" : 1,
        "status" : 201  
      }
    },
    {
      "create" : {
        "_index" : "zm_blog5",
        "_type" : "_doc",
        "_id" : "waNBpYQBCuglFCwN_ObP",
        "_version" : 1,
        "result" : "created",
        "_shards" : {
          "total" : 1,
          "successful" : 1,
          "failed" : 0
        },
        "_seq_no" : 2,
        "_primary_term" : 1,
        "status" : 201
      }
    }
  ]
}

最后编辑于：2022.11.24 00:28:55