我们也说过文档是不可变的——它们不能被更改,只能被替换。update
API必须遵循相同的规则。表面看来,我们似乎是局部更新了文档的位置,内部却是像我们之前说的一样简单的使用update
API处理相同的检索-修改-重建索引流程,我们也减少了其他进程可能导致冲突的修改。
最简单的update
请求表单接受一个局部文档参数doc
,它会合并到现有文档中——对象合并在一起,存在的标量字段被覆盖,新字段被添加。举个例子,我们可以使用以下请求为博客添加一个tags
字段和一个views
字段:
如果请求成功,我们将看到类似index
请求的响应结果:
{
"_index" : "website",
"_id" : "1",
"_type" : "blog",
"_version" : 3
}
检索文档文档显示被更新的_source
字段:
{
"_index": "website",
"_type": "blog",
"_id": "1",
"_version": 3,
"found": true,
"_source": {
"title": "My first blog entry",
"text": "Starting to get the hang of this...",
"views": 0 <1>
}
}
- <1> 我们新添加的字段已经被添加到
_source
字段中。
脚本能够使用 API改变_source
字段的内容,它在脚本内部以ctx._source
表示。例如,我们可以使用脚本增加博客的views
数量:
我们还可以使用脚本增加一个新标签到tags
数组中。在这个例子中,我们定义了一个新标签做为参数而不是硬编码在脚本里。这允许Elasticsearch未来可以重复利用脚本,而不是在想要增加新标签时必须每次编译新脚本:
POST /website/blog/1/_update
{
"script" : "ctx._source.tags+=new_tag",
"params" : {
"new_tag" : "search"
}
}
获取最后两个有效请求的文档:
{
"_index": "website",
"_type": "blog",
"_id": "1",
"_version": 5,
"found": true,
"_source": {
"title": "My first blog entry",
"tags": ["testing", "search"], <1>
"views": 1 <2>
}
}
- <1>
search
标签已经被添加到tags
数组。 - <2>
views
字段已经被增加。
通过设置ctx.op
为delete
我们可以根据内容删除文档:
在这种情况下,我们可以使用参数定义文档来使其不存在时被创建。
POST /website/pageviews/1/_update
{
"script" : "ctx._source.views+=1",
"upsert": {
"views": 1
}
}
第一次执行这个请求,upsert
值被索引为一个新文档,初始化views
字段为1
.接下来文档已经存在,所以script
被更新代替,增加views
数量。
这这一节的介绍中,我们介绍了如何在检索(retrieve)和重建索引(reindex)中保持更小的窗口,如何减少冲突性变更发生的概率,不过这些无法被完全避免,像一个其他进程在update
进行重建索引时修改了文档这种情况依旧可能发生。
为了避免丢失数据,update
API在检索(retrieve)阶段检索文档的当前_version
,然后在重建索引(reindex)阶段通过index
请求提交。如果其他进程在检索(retrieve)和重建索引(reindex)阶段修改了文档,_version
将不能被匹配,然后更新失败。
对于多用户的局部更新,文档被修改了并不要紧。例如,两个进程都要增加页面浏览量,增加的顺序我们并不关心——如果冲突发生,我们唯一要做的仅仅是重新尝试更新既可。
POST /website/pageviews/1/_update?retry_on_conflict=5 <1>
{
"script" : "ctx._source.views+=1",
"upsert": {
"views": 0
}
- <1> 在错误发生前重试更新5次
这适用于像增加计数这种顺序无关的操作,但是还有一种顺序非常重要的情况。例如index
API,使用“保留最后更新(last-write-wins)”的update
API,但它依旧接受一个version
参数以允许你使用乐观并发控制(optimistic concurrency control)来指定你要更细文档的版本。