ES中partial update实现、groovy脚本进行pa

1、什么是partial update？

• 如果使用 PUT /index/type/id 这样的方式进行创建文档和替换文档，就是一样的语法。
• 一般对应到应用程序中，每次的执行流程基本是这样的：

（1）应用程序先发起一个get请求，获取到document，展示到前台界面，供用户查看和修改
（2）用户在前台界面修改数据，发送到后台
（3）后台代码，会将用户修改的数据在内存中进行执行，然后封装好修改后的全量数据
（4）然后发送PUT请求，到es中，进行全量替换
（5）es将老的document标记为deleted，然后重新创建一个新的document

partial update则是使用POST方式进行修改

post /index/type/id/_update 
{
   "doc": {
      "要修改的少数几个field即可，不需要全量的数据"
   }
}

看起来，好像就比较方便了，每次就传递少数几个发生修改的field即可，不需要将全量的document数据发送过去

2、图解partial update实现原理以及其优点

图解partial update实现原理以及其优点

3. 实战演练

#全量替换
PUT /test_index/test_type/10
{
  "test_field1": "test1",
  "test_field2": "test2"
}
#partial update
POST /test_index/test_type/10/_update
{
  "doc": {
    "test_field2":"updated test2"
  }
}

4. 基于groovy脚本执行partial update

es中其实是有个内置的脚本支持的，可以基于groovy脚本实现各种各样的复杂操作，这里介绍基于groovy脚本，如何执行partial update

• 首先创建出一条数据

PUT /test_index/test_type/11
{
  "num":0,
  "tags":[]
}

（1）内置脚本

POST /test_index/test_type/11/_update
{
  "script": "ctx._source.num+=1"
}
#查询
GET /test_index/test_type/11
#返回
{
  "_index": "test_index",
  "_type": "test_type",
  "_id": "11",
  "_version": 2,
  "found": true,
  "_source": {
    "num": 1,
    "tags": []
  }
}

（2）外置脚本

在es安装目录下的config文件下的scripts文件新建一个脚本文件： test-add-tags.groovy

#在test-add-tags.groovy文件中添加以下内容
ctx._source.tags+=new_tag

• 然后在kibana控制台中进行测试

#运行脚本文件
POST /test_index/test_type/11/_update
{
  "script": {
    "lang": "groovy", 
    "file": "test-add-tags",
    "params": {
      "new_tag":"tag1"
    }
  }
}
#查询
GET /test_index/test_type/11
#返回
{
  "_index": "test_index",
  "_type": "test_type",
  "_id": "11",
  "_version": 3,
  "found": true,
  "_source": {
    "num": 1,
    "tags": [
      "tag1"
    ]
  }
}

（3）用脚本删除文档

新建一个 test-delete-document.groovy 脚本文件，并添加以下内容

ctx.op = ctx._source.num == count ? 'delete' : 'none'

• 然后在kibana控制台中进行测试

#运行脚本文件
POST /test_index/test_type/11/_update
{
  "script": {
    "lang": "groovy",
    "file": "test-delete-document",
    "params": {
      "count":1
    }
  }
}
#查询
GET /test_index/test_type/11
#返回
{
  "_index": "test_index",
  "_type": "test_type",
  "_id": "11",
  "found": false
}

（4）upsert操作

如果在执行修改的情况下该document已经不存在了，就执行upsert中的初始化操作；如果指定的document存在，就执行doc或者script指定的partial update操作

POST /test_index/test_type/11/_update
{
  "script": "ctx._source.num+=1",
  "upsert": {
    "num":0,
    "tags":[]
  }
}
#查询
GET /test_index/test_type/11
#返回
{
  "_index": "test_index",
  "_type": "test_type",
  "_id": "11",
  "_version": 1,
  "found": true,
  "_source": {
    "num": 0,
    "tags": []
  }
}