ElasticSearch文档批量操作

文档批量操作

批量获取文档数据

批量获取文档数据是通过_mget的API来实现的

在URL中不指定index和type

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
GET _mget
{
  "docs": [
    {
      "_index": "es_db",
      "_type": "_doc",
      "_id": 1
    },
    {
      "_index": "es_db",
      "_type": "_doc",
      "_id": 2
    }
  ]
}

在URL中指定index

1
2
3
4
5
6
7
8
9
10
11
12
13
GET /es_db/_mget
{
  "docs": [
    {
      "_type": "_doc",
      "_id": 1
    },
    {
      "_type": "_doc",
      "_id": 2
    }
  ]
}

在URL中指定index和type

1
2
3
4
5
6
7
8
9
10
11
GET /es_db/_doc/_mget
{
  "docs": [
    {
      "_id": 1
    },
    {
      "_id": 2
    }
  ]
}

批量操作文档数据

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

  • 通过_bulk操作文档，一般至少有两行参数(或偶数行参数)

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

    参数类似于：

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

批量创建文档create

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
POST _bulk
{
  "create": {
    "_index": "article",
    "_type": "_doc",
    "_id": 3
  }
}
{
  "id": 3,
  "title": "文章1",
  "content": "内容1",
  "tags": [
    "tag1",
    "tag2"
  ],
  "create_time": 1554015482530
}
{
  "create": {
    "_index": "article",
    "_type": "_doc",
    "_id": 4
  }
}
{
  "id": 4,
  "title": "文章2",
  "content": "内容2",
  "tags": [
    "tag3",
    "tag4"
  ],
  "create_time": 1554015482530
}

普通创建或全量替换index

  • 如果原文档不存在，则是创建
  • 如果原文档存在，则是替换(全量修改原文档)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
POST _bulk
{
  "index": {
    "_index": "article",
    "_type": "_doc",
    "_id": 3
  }
}
{
  "id": 3,
  "title": "更新后的文章1",
  "content": "更新后的内容1",
  "tags": [
    "tag1",
    "tag2"
  ],
  "create_time": 1554015482530
}
{
  "index": {
    "_index": "article",
    "_type": "_doc",
    "_id": 5
  }
}
{
  "id": 5,
  "title": "文章5",
  "content": "内容5",
  "tags": [
    "tag5",
    "tag14"
  ],
  "create_time": 1554015482530
}

批量修改update

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
POST _bulk
{
  "update": {
    "_index": "article",
    "_type": "_doc",
    "_id": 3
  }
}
{
  "doc": {
    "title": "更新后的文章11",
    "content": "更新后的内容11"
  }
}
{
  "update": {
    "_index": "article",
    "_type": "_doc",
    "_id": 5
  }
}
{
  "doc": {
    "title": "文章51",
    "content": "内容51"
  }
}

批量删除delete

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
POST _bulk
{
  "delete": {
    "_index": "article",
    "_type": "_doc",
    "_id": 3
  }
}
{
  "delete": {
    "_index": "article",
    "_type": "_doc",
    "_id": 4
  }
}s
ElasticSearch
#分布式框架
ElasticSearch文档批量操作
http://example.com/ElasticSearch文档批量操作/
作者
Panyurou
发布于
2022年2月21日
许可协议