基本语法

bulk操作和以往的普通请求格式有区别。不要格式化json,不然就不在同一行了,这个需要注意。

  1. { action: { metadata }}\n
  2. { request body }\n
  3. { action: { metadata }}\n
  4. { request body }\n
  5. ...
  • { action: { metadata }}代表批量操作的类型,可以是新增、删除或修改
  • \n是每行结尾必须填写的一个规范,每一行包括最后一行都要写,用于es的解析
  • { request body }是请求body,增加和修改操作需要,删除操作则不需要

    批量操作的类型

    action 必须是以下选项之一:

  • create:如果文档不存在,那么就创建它。存在会报错。发生异常报错不会影响其他操作。

  • index:创建一个新文档或者替换一个现有的文档。
  • update:部分更新一个文档。
  • delete:删除一个文档。

metadata 中需要指定要操作的文档的_index 、 _type 和 _id,_index 、 _type也可以在url中指定

实操

  • create新增文档数据,在metadata中指定index以及type ```shell POST /_bulk {“create”: {“_index”: “shop2”, “_type”: “_doc”, “_id”: “2001”}} {“id”: “2001”, “nickname”: “name2001”} {“create”: {“_index”: “shop2”, “_type”: “_doc”, “_id”: “2002”}} {“id”: “2002”, “nickname”: “name2002”} {“create”: {“_index”: “shop2”, “_type”: “_doc”, “_id”: “2003”}} {“id”: “2003”, “nickname”: “name2003”}
  1. - create创建已有id文档,在url中指定indextype
  2. ```shell
  3. POST /shop/_doc/_bulk
  4. {"create": {"_id": "2003"}}
  5. {"id": "2003", "nickname": "name2003"}
  6. {"create": {"_id": "2004"}}
  7. {"id": "2004", "nickname": "name2004"}
  8. {"create": {"_id": "2005"}}
  9. {"id": "2005", "nickname": "name2005"}
  • index创建,已有文档id会被覆盖,不存在的id则新增 ```shell POST /shop/_doc/_bulk {“index”: {“_id”: “2004”}} {“id”: “2004”, “nickname”: “index2004”} {“index”: {“_id”: “2007”}} {“id”: “2007”, “nickname”: “name2007”} {“index”: {“_id”: “2008”}} {“id”: “2008”, “nickname”: “name2008”}
  1. - update跟新部分文档数据
  2. ```shell
  3. POST /shop/_doc/_bulk
  4. {"update": {"_id": "2004"}}
  5. {"doc":{ "id": "3004"}}
  6. {"update": {"_id": "2007"}}
  7. {"doc":{ "nickname": "nameupdate"}}
  • delete批量删除 ```shell POST /shop/_doc/_bulk {“delete”: {“_id”: “2004”}} {“delete”: {“_id”: “2007”}}
  1. - 综合批量各种操作
  2. ```shell
  3. POST /shop/_doc/_bulk
  4. {"create": {"_id": "8001"}}
  5. {"id": "8001", "nickname": "name8001"}
  6. {"update": {"_id": "2001"}}
  7. {"doc":{ "id": "20010"}}
  8. {"delete": {"_id": "2003"}}
  9. {"delete": {"_id": "2005"}}