DevShelf

Appearance

文档批量操作 ​

批量操作可以减少网络连接所产生的开销，提升性能

  • 支持在一次api调用中，对不同的索引进行操作
  • 可以在URI中指定index，也可以在请求的Payload中进行
  • 操作中单条操作失败，并不会影响其他操作
  • 返回结果包括了每一条操作执行的结果

批量写入 ​

批量对文档进行写操作是通过_bulk的API来实现的

  • 请求方式：POST

  • 请求地址：_bulk

  • 请求参数：通过_bulk操作文档，一般至少有两行参数（或偶数行参数）

    • 第一行参数为指定操作的类型及操作的对象（index，type和id）
    • 第二行参数才是操作的数据

    参数类似于：

    json
     {"actionName":{"_index":"indexName", "_type":"typeName","_id":"id"}}
 {"field1":"value1", "field2":"value2"} 
 {"actionName":{"_index":"indexName", "_type":"typeName","_id":"id"}}
 {"field1":"value1", "field2":"value2"}

    提示

    actionName：表示操作类型，主要有create，index，delete和update

批量创建文档crate ​

json
 POST _bulk
 {"create":{"_index":"es_db","_type":"_doc","_id":1001}}
 {"id":1001,"age":18,"name":"zhangsan"}
 {"create":{"_index":"es_db","_type":"_doc","_id":1002}}
 {"id":1002,"age":18,"name":"lisi"}
 // 注意：已存在的文档会产生冲突

注意

已存在的文档会产生冲突

普通创建或全量替换index ​

json
POST _bulk
{"index":{"_index":"es_db","type":"_doc","_id":1001}}
{"id":1001,"age":18,"name":"zhangsan"}
{"index":{"_index":"es_db","type":"_doc","_id":1002}}
{"id":1002,"age":18,"name":"lisi"}

注意

如果原文档不存在，则是创建

如果原文档存在，则是替换（全量修改原文档）

批量删除delete ​

json
POST _bulk
{"delete":{"_index":"es_db", "_type":"_doc", "_id":1001}} 
{"delete":{"_index":"es_db", "_type":"_doc", "_id":1002}}

批量修改update ​

json
POST _bulk 
{"update":{"_index":"es_db", "_type":"_doc", "_id":1001}}
{"doc":{"age":30}}
{"update":{"_index":"es_db", "_type":"_doc", "_id":1002}}
{"doc":{"name":"wangwu"}}

组合应用 ​

json
POST _bulk 
{"delete":{"_index":"es_db", "_type":"_doc", "_id":1001}} 
{"create":{"_index":"es_db", "_type":"_doc", "_id":1001}} 
{"id":1001,"age":18,"name":"zhangsan"}
{"update":{"_index":"es_db", "_type":"_doc", "_id":1002}} 
{"doc":{"age":30}}

批量读取 ​

es的批量查询可以使用mget和msearch两种。其中mget是需要我们知道它的id，可以指定不同的index，也可以指定返回值source。msearch可以通过字段查询来进行一个批量的查找。

_mget ​

json
// 可以通过ID批量获取不同index和type的数据
GET _mget
{ "docs":[
  {
    "_index":"es_db",
    "_id":1
  },
  {
    "_index":"es_db2",
    "_id":2
  }
  ]
}

// 可以通过ID批量获取es_db的数据
GET /es_db/_mget
{
  "docs":[
    {
      "_id":1
    },
    {
      "_id":2
    }
    ]
}

// 简化后
GET /es_db/_mget
{
  "ids":["1","2"]
}

_msearch ​

在_msearch中，请求格式和bulk类似。查询一条数据需要两个对象，第一个设置index和type，第二个设置查询语句。查询语句和search相同。如果知识查询一个index，我们可以在url中带上index，这样，如果查该index可以直接用空对象表示。

json
GET /es_db/_msearch
{}
{"query":{"match_all":{}},"from":0,"size":2}
{"index":"es_db"}
{"query":{"match_all":{}}}