Elasticsearch Document Update API详解、原理与示例

这篇具有很好参考价值的文章主要介绍了Elasticsearch Document Update API详解、原理与示例。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

  • private int retryOnConflict = 0:更新冲突时重试次数。

  • private RefreshPolicy refreshPolicy = RefreshPolicy.NONE:刷新策略。NONE:代表不重试;

  • private ActiveShardCount waitForActiveShards = ActiveShardCount.DEFAULT:执行操作之前需要等待激活的副本数,已在《Elasticsearch Document Get API详解、原理与示例》中详细介绍。

  • private IndexRequest upsertRequest:使用该 字段进行更新操作,如果原索引不存在,则更新,类似于saveOrUpdate操作,该操作需要与脚步执行,详细将在后续章节中描述,

  • private boolean scriptedUpsert = false;是否是用脚步执行更新操作。

  • private boolean docAsUpsert = false; 是否使用saveOrUpdate模式,即是否使用IndexRequest upsertRequest进行更新操作。(docAsUpser=true+ doc组合,将使用saveOrUpdate模式)。

  • private boolean detectNoop = true;是否检查空操作,下文会进行详细介绍。

  • private IndexRequest doc;默认使用该请求进行更新操作。

从上述我们基本可以得知更新基本有3种方式,script、upsert、doc(普通更新)。

2、深入分析Elasticsearch Update API(更新API)

2.1 Script脚步更新

Elasticsearch可以通过脚本(painless)进行更新,其具体语法见:https://www.elastic.co/guide/en/elasticsearch/painless/current/index.html ,,本节不会深入去学习其语法,后续会看单独的章节对其进行详细讲解。

2.2 部分字段更新(普通更新方式)

更新API支持传递一个部分文档(_source字段中包含类型的部门字段),它将被合并到现有的文档中(简单的递归合并,对象的内部合并,替换核心的“键/值”和数组)。如果需要完全替代现有的文档,请使用(Index API)。以下部分更新为现有文档添加了一个新字段:(下文会给出基于java的API调用)。

POST test/_doc/1/_update

{

“doc” : {

“name” : “new_name”

}

}

如果指定了doc和script,则script属性优先,关于更新API一个比较好的实践是使用脚步更新(painless),后续会重点章节详细介绍。

2.3 检测空更新(检测本请求是否值得更新)

该功能特性的意思是当提交的请求,发现与原文档的数据并未发送变化,是否执行update操作,默认检测。如果开启检测,detectNoop=true,如果检测到数据并未发生变化,则返回结果为noop(空操作),如果detectNoop=false,每次操作都会执行,版本号将自增。

2.4 保存或更新(Upserts)

如果文档还不存在,upsert元素的内容将作为新文档插入。Elasticsearch支持scripted_upsert和doc_as_upsert两种模式,以scripted_upsert优先。通过UpdateRequest#scriptedUpsert和UpdateRequest#docAsUpsert控制。

2.5 核心参数一览表

更新API主要核心参数一览表

| 参数名 | 说明 |

| — | — |

| retry_on_conflict | Elasticsearch基于版本进行乐观锁控制,当版本冲突后,允许的重试次数,超过重试次数retry_on_conflict后抛出异常。 |

| routing | 路由策略。 |

| timeout | 等待分片的超时时间。 |

| wait_for_active_shards | 在执行命令之前需要等待副本的数量。 |

| refresh | 刷新机制。 |

| _source | 允许在响应中控制更新后的源是否和如何返回。默认情况下,更新的源代码不会返回。有关源字段过滤,请参考《Elasticsearch Document Get API详解、原理与示例》中详细介绍。 |

| version | 版本字段,基于乐观锁控制。 |

注意:更新API不支持除内部以外的版本控制,外部(版本类型外部和外部的)或强制(版本类型的force)版本控制不受更新API的支持,因为它会导致弹性搜索版本号与外部系统不同步。

3、Update API使用示例

本节将暂时不会展示使用脚步进行更新的Demo,此部分会在后续文章中单独的章节来介绍ElasticSearch painless Script。

3.1 常规更新(更新部分字段)

public static void testUpdate_partial() {

RestHighLevelClient client = EsClient.getClient();

try {

UpdateRequest request = new UpdateRequest(“twitter”, “_doc”, “10”);

IndexRequest indexRequest = new IndexRequest(“twitter”, “_doc”, “10”);

Map<String, String> source = new HashMap<>();

source.put(“user”, “dingw2”);

indexRequest.source(source);

request.doc(indexRequest);

UpdateResponse result = client.update(request, RequestOptions.DEFAULT);

System.out.println(result);

testGet();

} catch (Throwable e) {

e.printStackTrace();

} finally {

EsClient.close(client);

}

}

最终结果:调用get API能反映出user字段已经更新为dingw2,及更新成功。

3.2 开启detectNoop(detectNoop=true),并且并不改变数据

public static void testUpdate_noop() {

RestHighLevelClient client = EsClient.getClient();

try {

UpdateRequest request = new UpdateRequest(“twitter”, “_doc”, “10”);

request.detectNoop(true);

request.doc(buildIndexRequest());

UpdateResponse result = client.update(request, RequestOptions.DEFAULT);

System.out.println(result);

} catch (Throwable e) {

e.printStackTrace();

} finally {

EsClient.close(client);

}

}

返回结果:

{

“_shards”: {

“total”: 0,

“successful”: 0,

“failed”: 0

},

“_index”: “twitter”,

“_type”: “_doc”,

“_id”: “10”,

“_version”: 6,

“result”: “noop”

}

其特征为result为noop,并且_shards各个字段都返回0,表示没有在任何分片上执行该动作,并且数据的版本_version并不会发送变化。

3.3 不开启detectNoop(detectNoop=false),并且并不改变数据

public static void testUpdate_no_noop() {

RestHighLevelClient client = EsClient.getClient();

try {

UpdateRequest request = new UpdateRequest(“twitter”, “_doc”, “10”);

request.detectNoop(false);

request.doc(buildIndexRequest());

UpdateResponse result = client.update(request, RequestOptions.DEFAULT);

System.out.println(result);

} catch (Throwable e) {

e.printStackTrace();

} finally {

EsClient.close(client);

}

}

返回结果:

{

“_shards”: {

“total”: 2,

“successful”: 1,

“failed”: 0

},

“_index”: “twitter”,

“_type”: “_doc”,

“_id”: “10”,

“_version”: 7,

“result”: “updated”

}

自我介绍一下,小编13年上海交大毕业,曾经在小公司待过,也去过华为、OPPO等大厂,18年进入阿里一直到现在。

深知大多数Java工程师,想要提升技能,往往是自己摸索成长或者是报班学习,但对于培训机构动则几千的学费,着实压力不小。自己不成体系的自学效果低效又漫长,而且极易碰到天花板技术停滞不前!

因此收集整理了一份《2024年Java开发全套学习资料》,初衷也很简单,就是希望能够帮助到想自学提升又不知道该从何学起的朋友,同时减轻大家的负担。Elasticsearch Document Update API详解、原理与示例,程序员,elasticsearch,jenkins,大数据

Elasticsearch Document Update API详解、原理与示例,程序员,elasticsearch,jenkins,大数据

Elasticsearch Document Update API详解、原理与示例,程序员,elasticsearch,jenkins,大数据

既有适合小白学习的零基础资料,也有适合3年以上经验的小伙伴深入学习提升的进阶课程,基本涵盖了95%以上Java开发知识点,真正体系化!

由于文件比较大,这里只是将部分目录截图出来,每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频,并且会持续更新!

如果你觉得这些内容对你有帮助,可以扫码获取!!(备注Java获取)

Elasticsearch Document Update API详解、原理与示例,程序员,elasticsearch,jenkins,大数据

最后

毕竟工作也这么久了 ,除了途虎一轮,也七七八八面试了不少大厂,像阿里、饿了么、美团、滴滴这些面试过程就不一一写在这篇文章上了。我会整理一份详细的面试过程及大家想知道的一些问题细节

美团面试经验

Elasticsearch Document Update API详解、原理与示例,程序员,elasticsearch,jenkins,大数据
字节面试经验
Elasticsearch Document Update API详解、原理与示例,程序员,elasticsearch,jenkins,大数据
菜鸟面试经验
Elasticsearch Document Update API详解、原理与示例,程序员,elasticsearch,jenkins,大数据
蚂蚁金服面试经验
Elasticsearch Document Update API详解、原理与示例,程序员,elasticsearch,jenkins,大数据
唯品会面试经验
Elasticsearch Document Update API详解、原理与示例,程序员,elasticsearch,jenkins,大数据

因篇幅有限,图文无法详细发出
《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取!
2934261)]
字节面试经验
[外链图片转存中…(img-LN6T5yuY-1713082934261)]
菜鸟面试经验
[外链图片转存中…(img-RO0Bh5vS-1713082934261)]
蚂蚁金服面试经验
[外链图片转存中…(img-PhyVhvGM-1713082934261)]
唯品会面试经验
[外链图片转存中…(img-I7EhRlbA-1713082934261)]

因篇幅有限,图文无法详细发出
《互联网大厂面试真题解析、进阶开发核心学习笔记、全套讲解视频、实战项目源码讲义》点击传送门即可获取!文章来源地址https://www.toymoban.com/news/detail-855468.html

到了这里,关于Elasticsearch Document Update API详解、原理与示例的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 4、Elasticsearch7.6.1 Java api操作ES(CRUD、两种分页方式、高亮显示)和Elasticsearch SQL详细示例

    1、介绍lucene的功能以及建立索引、搜索单词、搜索词语和搜索句子四个示例实现 2、Elasticsearch7.6.1基本介绍、2种部署方式及验证、head插件安装、分词器安装及验证 3、Elasticsearch7.6.1信息搜索示例(索引操作、数据操作-添加、删除、导入等、数据搜索及分页) 4、Elasticsearch7

    2024年02月16日
    浏览(79)
  • Elasticsearch中Document Routing特性

    Document Routing在Elasticsearch中是一种高级特性,它允许用户在索引文档时指定一个路由值。通过这种方式,可以确保具有相同路由值的所有文档都存储在同一个分片中。这对于提高查询效率特别有用,因为它允许查询只针对包含相关文档的特定分片,而不是整个索引。下面是如

    2024年02月20日
    浏览(38)
  • 【Elasticsearch】 03-索引创建/更新/删除详解及示例

    Elasticsearch 是一个开源的分布式搜索和分析引擎,提供了强大的全文搜索、实时数据分析和数据可视化功能。本文将详细介绍 Elasticsearch 的新增语法,包括索引的创建、数据的插入、更新和删除等操作,并提供丰富的示例代码,帮助您更好地理解和使用 Elasticsearch。 在开始之

    2024年02月04日
    浏览(42)
  • 义乌购关键字搜索API接口技术详解与代码示例

    义乌购搜索API接口技术详解与代码示例 在电子商务蓬勃发展的今天,义乌购作为国内知名的批发市场平台,为广大商家和消费者提供了丰富的商品资源。为了方便开发者快速接入义乌购平台,实现商品信息的搜索与获取,义乌购开放了搜索API接口。本文将详细介

    2024年03月17日
    浏览(58)
  • 【Spark原理系列】Accumulator累加器原理用法示例源码详解

    源自专栏《SparkML:Spark ML系列专栏目录》 Accumulator是Spark中的一种分布式变量,用于在并行计算中进行累加操作。它是由MapReduce模型中的“全局计数器”概念演化而来的。 Accumulator提供了一个可写的分布式变量,可以在并行计算中进行累加操作。在Spark中,当一个任务对Accum

    2024年03月14日
    浏览(62)
  • ElasticSearch文档(document)在index上的增删改查

    在 Elasticsearch 中,Document(文档)是存储在索引中的最小数据单元。它是一条具有结构化数据的记录,以 JSON(JavaScript Object Notation)格式表示。 每个文档都有一个唯一的标识符,称为 _id。如果你没有为文档提供自定义的 _id 值,Elasticsearch 将为其生成一个唯一的标识符。 文档

    2024年02月16日
    浏览(114)
  • 16、Flink 的table api与sql之连接外部系统: 读写外部系统的连接器和格式以及Elasticsearch示例(2)

    一、Flink 专栏 Flink 专栏系统介绍某一知识点,并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。 2、Flink基础系列 本部分介绍Flink 的基础部分,比如术语、架构、编程模型、编程指南、基本的datastream api用法、四大基石等内容。 3、

    2024年02月11日
    浏览(52)
  • 【Spark Graphx 系列】mask原理场景示例详解

    源自专栏《Gremlin AQL ArangoDB Neo4j Graphx 图算法 图数据库中文教程导航》 源自专栏[《SparkML:Spark ML系列专栏目录》 在Spark GraphX中, mask 方法用于将当前图限制为仅包含另一个图中也存在的顶点和边,同时保留当前图的属性。下面是 mask 方法的原理解释: 基本原理 : mask 方法基

    2024年03月22日
    浏览(46)
  • python中的 collections 模块(用法、详解、底层原理,示例等)

    1.1 defaultdict 功能 可以设置一个默认值作为字典中新key的默认值。该默认值可以是任何对象, 包括函数、列表、元组、集合等。默认值不需要像dict那样事先定义,因为它在需要的时候会自动创建 使用defaultdict,可以简化代码并提高代码的可读性,而且可以防止KeyError异常的出

    2024年04月29日
    浏览(39)
  • elasticsearch 8.7.0的Java API详解教程(一)

    最近作者做一个es的搜索,之前采用的是7.12.1,本来接口都已经基本上写好了,后面es要升级到8.7.0,一升级就连接不上es8.7.0了,后面才发现原来es8是默认采用了HTTPS协议,需要配置认证证书,这个问题搞了好久好久,最后终于搞成功了,在此写一篇博客记录一下。 如何获取这

    2024年02月12日
    浏览(40)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包