我们也说过文档是不可变的——它们不能被更改,只能被替换。update API必须遵循相同的规则。表面看来,我们似乎是局部更新了文档的位置,内部却是像我们之前说的一样简单的使用update API处理相同的检索-修改-重建索引流程,我们也减少了其他进程可能导致冲突的修改。

    最简单的update请求表单接受一个局部文档参数doc,它会合并到现有文档中——对象合并在一起,存在的标量字段被覆盖,新字段被添加。举个例子,我们可以使用以下请求为博客添加一个tags字段和一个views字段:

    如果请求成功,我们将看到类似index请求的响应结果:

    1. {
    2. "_index" : "website",
    3. "_id" : "1",
    4. "_type" : "blog",
    5. "_version" : 3
    6. }

    检索文档文档显示被更新的_source字段:

    1. {
    2. "_index": "website",
    3. "_type": "blog",
    4. "_id": "1",
    5. "_version": 3,
    6. "found": true,
    7. "_source": {
    8. "title": "My first blog entry",
    9. "text": "Starting to get the hang of this...",
    10. "views": 0 <1>
    11. }
    12. }
    • <1> 我们新添加的字段已经被添加到_source字段中。

    脚本能够使用 API改变_source字段的内容,它在脚本内部以ctx._source表示。例如,我们可以使用脚本增加博客的views数量:

    我们还可以使用脚本增加一个新标签到tags数组中。在这个例子中,我们定义了一个新标签做为参数而不是硬编码在脚本里。这允许Elasticsearch未来可以重复利用脚本,而不是在想要增加新标签时必须每次编译新脚本:

    1. POST /website/blog/1/_update
    2. {
    3. "script" : "ctx._source.tags+=new_tag",
    4. "params" : {
    5. "new_tag" : "search"
    6. }
    7. }

    获取最后两个有效请求的文档:

    1. {
    2. "_index": "website",
    3. "_type": "blog",
    4. "_id": "1",
    5. "_version": 5,
    6. "found": true,
    7. "_source": {
    8. "title": "My first blog entry",
    9. "tags": ["testing", "search"], <1>
    10. "views": 1 <2>
    11. }
    12. }
    • <1> search标签已经被添加到tags数组。
    • <2> views字段已经被增加。

    通过设置ctx.opdelete我们可以根据内容删除文档:

    在这种情况下,我们可以使用参数定义文档来使其不存在时被创建。

    1. POST /website/pageviews/1/_update
    2. {
    3. "script" : "ctx._source.views+=1",
    4. "upsert": {
    5. "views": 1
    6. }
    7. }

    第一次执行这个请求,upsert值被索引为一个新文档,初始化views字段为1.接下来文档已经存在,所以script被更新代替,增加views数量。

    这这一节的介绍中,我们介绍了如何在检索(retrieve)重建索引(reindex)中保持更小的窗口,如何减少冲突性变更发生的概率,不过这些无法被完全避免,像一个其他进程在update进行重建索引时修改了文档这种情况依旧可能发生。

    为了避免丢失数据,update API在检索(retrieve)阶段检索文档的当前_version,然后在重建索引(reindex)阶段通过index请求提交。如果其他进程在检索(retrieve)重建索引(reindex)阶段修改了文档,_version将不能被匹配,然后更新失败。

    对于多用户的局部更新,文档被修改了并不要紧。例如,两个进程都要增加页面浏览量,增加的顺序我们并不关心——如果冲突发生,我们唯一要做的仅仅是重新尝试更新既可。

    1. POST /website/pageviews/1/_update?retry_on_conflict=5 <1>
    2. {
    3. "script" : "ctx._source.views+=1",
    4. "upsert": {
    5. "views": 0
    6. }
    • <1> 在错误发生前重试更新5次

    这适用于像增加计数这种顺序无关的操作,但是还有一种顺序非常重要的情况。例如index API,使用“保留最后更新(last-write-wins)”update API,但它依旧接受一个version参数以允许你使用乐观并发控制(optimistic concurrency control)来指定你要更细文档的版本。