es之7：elastic search partial update

一、什么是partial update？

PUT /index/type/id，创建文档&替换文档，就是一样的语法  

1、查询更新全量方式

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

2、partial update方式

  POST /index/type/id/_update {    "doc": {       "要修改的少数几个field即可，不需要全量的数据"    } }   PUT /test_index/test_type/10 {   "test_field1": "test1",   "test_field2": "test2" }   POST /test_index/test_type/10/_update {   "doc": {     "test_field2": "updated test2"   } } 看起来，好像就比较方便了，每次就传递少数几个发生修改的field即可，不需要将全量的document数据发送过去

二、partial update实现原理

三、partial update相较于应用层进行的全量替换的优点

{

  "doc": {

    "num":32

  }

} 如果更新失败，则获取最新的版本号再次进行更新，最多重试retry_on_conflict指定的次数

{

  "doc": {

    "num":32

  }

}

三、基于groovy脚本执行partial update

es内部有个内置的脚步支持【elaticsearch scripting module】，可以基于groovy脚步实现各种各样的复杂操作，基于groovy脚步，如何执行partial update

        1、内置脚本

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

PUT /test_index/test_type/_update
{    
   "script": "ctx._source.num+=8"
}

 结果：

{
  "_index" : "test_index",
  "_type" : "test_type",
  "_id" : "_update",
  "_version" : 1,
  "result" : "created",
  "_shards" : {
    "total" : 2,
    "successful" : 1,
    "failed" : 0
  },
  "_seq_no" : 0,
  "_primary_term" : 1
}

      2、外部脚本

                （1）添加脚本 test_update_num.groovy

                        POST /test_index/test_type/11/_update

{

  "script": {

    "lang": "groovy",

    "file": "test_update_num"

  }

}

                （ 2）添加脚本：test-add-tags.groovy

{

  "script": {

    "lang": "groovy",

    "file": "test-add-tags",

    "params": {

      "new_tag":"tag_value"

    }

  }

}

                （ 3）添加脚本：test-delete-document.groovy

POST /test_index/test_type/11/_update

{

  "script": {

    "lang": "groovy",

    "file": "test-delete-document",

    "params": {

      "count":17

    }

  }

}

                   （4）upsert操作

POST /test_index/test_type/11/_update

{

   "script" : "ctx._source.num+=1",

   "upsert": {

       "num": 0,

       "tags": []

   }

 

}