一年春又来
0%

ES 批量操作 bulk

发表于 更新于 分类于

基本语法

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

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

批量操作的类型

action 必须是以下选项之一:

  • create：如果文档不存在，那么就创建它。存在会报错。发生异常报错不会影响其他操作。
  • index：创建一个新文档或者替换一个现有的文档。
  • update：部分更新一个文档。
  • delete：删除一个文档。

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

实操

create

  • create新增文档数据，在metadata中指定index以及type

    1
    2
    3
    4
    5
    6
    7
    8
    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"}
    1234567

  • create创建已有id文档，在url中指定index和type

    1
    2
    3
    4
    5
    6
    7
    8
    POST    /shop/_doc/_bulk
    {"create": {"_id": "2003"}}
    {"id": "2003", "nickname": "name2003"}
    {"create": {"_id": "2004"}}
    {"id": "2004", "nickname": "name2004"}
    {"create": {"_id": "2005"}}
    {"id": "2005", "nickname": "name2005"}
    1234567

  • index创建，已有文档id会被覆盖，不存在的id则新增

    1
    2
    3
    4
    5
    6
    7
    8
    9
    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"}

    12345678

update

  • update跟新部分文档数据

    1
    2
    3
    4
    5
    POST    /shop/_doc/_bulk
    {"update": {"_id": "2004"}}
    {"doc":{ "id": "3004"}}
    {"update": {"_id": "2007"}}
    {"doc":{ "nickname": "nameupdate"}}

delete

  • delete批量删除

    1
    2
    3
    POST    /shop/_doc/_bulk
    {"delete": {"_id": "2004"}}
    {"delete": {"_id": "2007"}}

复合操作

  • 综合批量各种操作

    1
    2
    3
    4
    5
    6
    7
    POST    /shop/_doc/_bulk
    {"create": {"_id": "8001"}}
    {"id": "8001", "nickname": "name8001"}
    {"update": {"_id": "2001"}}
    {"doc":{ "id": "20010"}}
    {"delete": {"_id": "2003"}}
    {"delete": {"_id": "2005"}}

参考资源

官文：https://www.elastic.co/guide/cn/elasticsearch/guide/current/bulk.html