Elasticsearch（ES）的滚动搜索与批量操作

r囧r小猫 2022-09-12 06:56 376阅读 0赞

**目录**

1. 概述

2. Elasticsearch（ES）的滚动搜索

3. Elasticsearch（ES）的文档批量操作

4. 综述

--------------------

# **1. 概述** #

今天我们来聊一下Elasticsearch（ES）的滚动搜索与批量操作。

# **2. Elasticsearch（ES）的滚动搜索** #

**2.1 概述 **

滚动搜索我们经常能够用到，例如：推荐列表，此类列表通常不需要分页，而是一直上滑刷新。

滚动搜索的原理是根据固定的排序规则先加载一部分数据，当用户再刷新时，从上次加载的最后一条数据的位置再加载同样数量的数据，下一次刷新同理。

**2.2 第一次搜索请求**

第一次搜索的请求比较特殊，与之后的搜索请求的url和参数不同。

参数中的 scroll=1m，是指滚动搜索的下一次搜索，必须在1分钟之内。

size是每次滚动显示的条数。

POST  http://192.168.1.8:9200/index\_user/\_search?scroll=1m

参数：

{
        "query": {
            "match_all": {}
        },
        "sort": [
            {
                "age": "desc"
            }
        ],
        "size": 1
    }

响应：

{
        "_scroll_id": "FGluY2x1ZGVfY29udGV4dF91dWlkDnF1ZXJ5VGhlbkZldGNoBRZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAHAWejhoNTc2clNScU9NWlpHQ3A4VXJGURZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAHEWejhoNTc2clNScU9NWlpHQ3A4VXJGURZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAG8WejhoNTc2clNScU9NWlpHQ3A4VXJGURZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAG0WejhoNTc2clNScU9NWlpHQ3A4VXJGURZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAG4WejhoNTc2clNScU9NWlpHQ3A4VXJGUQ==","took": 7,
        "timed_out": false,
        "_shards": {
            "total": 5,
            "successful": 5,
            "skipped": 0,
            "failed": 0
        },
        "hits": {
            "total": {
                "value": 3,
                "relation": "eq"
            },
            "max_score": null,
            "hits": [
                {
                    "_index": "index_user",
                    "_type": "_doc",
                    "_id": "2",
                    "_score": null,
                    "_source": {
                        "user_id": "2",
                        "name": "夏维尔",
                        "login_name": "xwe",
                        "age": 28,
                        "birthday": "1992-06-06",
                        "desc": "我是一名高级开发经理，每天坐地铁上班，在北京住，从不堵车",
                        "head_url": "https://www.zhuifengren.cn/img/xwe.jpg"
                    },
                    "sort": [
                        28
                    ]
                }
            ]
        }
    }

** 2.3 之后的搜索**

参数中 scroll\_id 是第一次搜索返回的。

POST  http://192.168.1.8:9200/\_search/scroll

参数：

{
        "scroll_id": "FGluY2x1ZGVfY29udGV4dF91dWlkDnF1ZXJ5VGhlbkZldGNoBRZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAHAWejhoNTc2clNScU9NWlpHQ3A4VXJGURZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAHEWejhoNTc2clNScU9NWlpHQ3A4VXJGURZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAG8WejhoNTc2clNScU9NWlpHQ3A4VXJGURZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAG0WejhoNTc2clNScU9NWlpHQ3A4VXJGURZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAG4WejhoNTc2clNScU9NWlpHQ3A4VXJGUQ==",
        "scroll":"1m"
    }

响应：

{
        "_scroll_id": "FGluY2x1ZGVfY29udGV4dF91dWlkDnF1ZXJ5VGhlbkZldGNoBRYxMDBJOHhrUFJwdUdkUHJpbE52VjlBAAAAAAAAAG8WejhoNTc2clNScU9NWlpHQ3A4VXJGURYxMDBJOHhrUFJwdUdkUHJpbE52VjlBAAAAAAAAAHEWejhoNTc2clNScU9NWlpHQ3A4VXJGURYxMDBJOHhrUFJwdUdkUHJpbE52VjlBAAAAAAAAAHIWejhoNTc2clNScU9NWlpHQ3A4VXJGURYxMDBJOHhrUFJwdUdkUHJpbE52VjlBAAAAAAAAAHAWejhoNTc2clNScU9NWlpHQ3A4VXJGURYxMDBJOHhrUFJwdUdkUHJpbE52VjlBAAAAAAAAAG4WejhoNTc2clNScU9NWlpHQ3A4VXJGUQ==",
        "took": 12,
        "timed_out": false,
        "_shards": {
            "total": 5,
            "successful": 5,
            "skipped": 0,
            "failed": 0
        },
        "hits": {
            "total": {
                "value": 6,
                "relation": "eq"
            },
            "max_score": null,
            "hits": [
                {
                    "_index": "index_user",
                    "_type": "_doc",
                    "_id": "1",
                    "_score": null,
                    "_source": {
                        "user_id": "1",
                        "name": "僵尸猎手",
                        "login_name": "jsls",
                        "age": 25,
                        "birthday": "1990-03-01",
                        "desc": "我是一名房产经纪人，现在转行了，目前是一名运输工人",
                        "head_url": "https://www.zhuifengren.cn/img/jsls.jpg"
                    },
                    "sort": [
                        25
                    ]
                }
            ]
        }
    }

# **3. Elasticsearch（ES）的文档批量操作** #

**3.1 批量依据ID查询文档**

POST  http://192.168.1.8:9200/index\_user/\_doc/\_mget

参数：

{
        "ids":["1", "3"]
    }

**3.2 批量新增文档1**

注意：参数的最后一行，需要以回车（'\\n'）结尾。

其中一条报错，不会影响其他数据正常执行。

如果新增数据的id已存在会报错。

POST  http://192.168.1.8:9200/\_bulk

参数：

{"create":{"_index":"index_user", "_type":"_doc", "_id": "5"}}
    {"user_id":"5", "name":"姓名5"}
    {"create":{"_index":"index_user", "_type":"_doc", "_id": "6"}}
    {"user_id":"6", "name":"姓名6"}
    {"create":{"_index":"index_user", "_type":"_doc", "_id": "7"}}
    {"user_id":"6", "name":"姓名7"}

**3.3 批量新增文档2**

批量新增文档的第二种写法。

POST  http://192.168.1.8:9200/index\_user/\_doc/\_bulk

参数：

{"create":{"_id": "5"}}
    {"user_id":"5", "name":"姓名5"}
    {"create":{"_id": "6"}}
    {"user_id":"6", "name":"姓名6"}
    {"create":{"_id": "7"}}
    {"user_id":"6", "name":"姓名7"}

**3.4 批量新增或更新文档**

当id不存在，会新增文档，id已存在，会更新文档。

POST  http://192.168.1.8:9200/index\_user/\_doc/\_bulk

参数：

{"index":{"_id": "5"}}
    {"user_id":"5", "name":"姓名5_1"}
    {"index":{"_id": "6"}}
    {"user_id":"6", "name":"姓名6_1"}
    {"index":{"_id": "8"}}
    {"user_id":"8", "name":"姓名8_1"}

**3.5 批量局部更新文档**

当id不存在，会报错。

POST   http://192.168.1.8:9200/index\_user/\_doc/\_bulk

参数：

{"update":{"_id": "5"}}
    {"doc": {"user_id":"5", "name":"姓名5_2"}}
    {"update":{"_id": "6"}}
    {"doc": {"user_id":"6", "name":"姓名6_2"}}
    {"update":{"_id": "9"}}
    {"doc": {"user_id":"9", "name":"姓名9_1"}}

**3.6 批量删除文档**

POST  http://192.168.1.8:9200/index\_user/\_doc/\_bulk

参数：

{"delete":{"_id": "5"}}
    {"delete":{"_id": "6"}}

**3.7 其他说明**

批量新增、更新、删除的操作，可以在一次请求完成。

每次批量新增、更新、删除的请求，请求体不宜过大，控制在1000条之内。

# **4. 综述** #

今天简单聊了一下 Elasticsearch（ES）的滚动搜索与批量操作，希望可以对大家的工作有所帮助。

欢迎帮忙点赞、评论、加关注 ：）

关注追风人聊Java，每天更新Java干货。