什么是partial update?
PUT /index/type/id,创建文档&替换文档,就是一样的语法
一般对应到应用程序中,每次的执行流程基本是这样的:
(1)应用程序先发起一个get请求,获取到document,展示到前台界面,供用户查看和修改
(2)用户在前台界面修改数据,发送到后台
(3)后台代码,会将用户修改的数据在内存中进行执行,然后封装好修改后的全量数据
(4)然后发送PUT请求,到es中,进行全量替换
(5)es将老的document标记为deleted,然后重新创建一个新的document
partial update
post /index/type/id/_update { "doc": { "要修改的少数几个field即可,不需要全量的数据" } }
看起来,好像就比较方便了,每次就传递少数几个发生修改的field即可,不需要将全量的document数据发送过去
图解partial update实现原理以及其优点
partial update,看起来很方便的操作,实际内部的原理是什么样子的,然后它的优点是什么
上机动手实战演练partial update
PUT /test_index/test_type/10 { "test_field1": "test1", "test_field2": "test2" }
POST /test_index/test_type/10/_update { "doc": { "test_field2": "updated test2" } }
基于groovy脚本 , partial update
es,其实是有个内置的脚本支持的,可以基于groovy脚本实现各种各样的复杂操作
基于groovy脚本,如何执行partial update
es scripting module,我们会在高手进阶篇去讲解,这里就只是初步讲解一下
PUT /test_index/test_type/11 { "num": 0, "tags": [] }
(1)内置脚本
POST /test_index/test_type/11/_update { "script" : "ctx._source.num+=1" }
{ "_index": "test_index", "_type": "test_type", "_id": "11", "_version": 2, "found": true, "_source": { "num": 1, "tags": [] } }
(2)外部脚本
ctx._source.tags+=new_tag
POST /test_index/test_type/11/_update { "script": { "lang": "groovy", "file": "test-add-tags", "params": { "new_tag": "tag1" } } }
(3)用脚本删除文档
ctx.op = ctx._source.num == count ? 'delete' : 'none'
POST /test_index/test_type/11/_update { "script": { "lang": "groovy", "file": "test-delete-document", "params": { "count": 1 } } }
(4)upsert操作
POST /test_index/test_type/11/_update { "doc": { "num": 1 } }
{ "error": { "root_cause": [ { "type": "document_missing_exception", "reason": "[test_type][11]: document missing", "index_uuid": "6m0G7yx7R1KECWWGnfH1sw", "shard": "4", "index": "test_index" } ], "type": "document_missing_exception", "reason": "[test_type][11]: document missing", "index_uuid": "6m0G7yx7R1KECWWGnfH1sw", "shard": "4", "index": "test_index" }, "status": 404 }
如果指定的document不存在,就执行upsert中的初始化操作;如果指定的document存在,就执行doc或者script指定的partial update操作
POST /test_index/test_type/11/_update { "script" : "ctx._source.num+=1", "upsert": { "num": 0, "tags": [] } }