blocks|key|4298408|text|ElasticSearch中的所有更新都是通过查找记录、删除旧版本并添加新版本来完成的。通过使用Update+API，您可以在将记录一直移动到客户端的过程中节省一点时间。不过，这仍然需要找到记录。|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|4298409|您可能想要的是Update+by+query。|4298410|entityMap|0|LINK|mutability|MUTABLE|url|http://www.elasticsearch.org/guide/reference/api/update.html|1|https://www.elastic.co/guide/en/elasticsearch/reference/6.5/docs-update-by-query.html^0|1C|A|0|0|7|F|1|0^^$0|@$1|2|3|4|5|6|7|P|8|@]|9|@$A|Q|B|R|1|S]]|C|$]]|$1|D|3|E|5|6|7|T|8|@]|9|@$A|U|B|V|1|W]]|C|$]]|$1|F|3|-4|5|6|7|X|8|@]|9|@]|C|$]]]|G|$H|$5|I|J|K|C|$L|M]]|N|$5|I|J|K|C|$L|O]]]]

All updates in ElasticSearch are done by finding the record, deleting the old version and adding the new version. You can save a little bit on moving records all the way to the client by using <a href="http://www.elasticsearch.org/guide/reference/api/update.html" rel="nofollow noreferrer">Update API</a>. It would still require finding the record though. 

What you, probably, want is <a href="https://www.elastic.co/guide/en/elasticsearch/reference/6.5/docs-update-by-query.html" rel="nofollow noreferrer">Update by query</a>.

blocks|key|5715796|text|Elastic+Search有一个Update+API。使用该API，您可以执行以下操作：|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|5715797|curl+-XPOST+'localhost:9200/test/tag/weak/_update'+-d+'{
++++"script"+:+"ctx._source.aliases+%2B=+faint"
}'|code-block|syntax|javascript|5715798|entityMap|0|LINK|mutability|MUTABLE|url|https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-update.html^0|H|A|0|0|0^^$0|@$1|2|3|4|5|6|7|Q|8|@]|9|@$A|R|B|S|1|T]]|C|$]]|$1|D|3|E|5|F|7|U|8|@]|9|@]|C|$G|H]]|$1|I|3|-4|5|6|7|V|8|@]|9|@]|C|$]]]|J|$K|$5|L|M|N|C|$O|P]]]]

Elastic Search has a <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-update.html" rel="nofollow">Update API</a>. With that API you can do the following:

<pre><code>curl -XPOST 'localhost:9200/test/tag/weak/_update' -d '{
 "script" : "ctx._source.aliases += faint"
}'
</code></pre>

blocks|key|4298474|text|此外，如果您添加具有相同id的相同值，它将自动更新较旧的数据。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|4298475|entityMap^0|0^^$0|@$1|2|3|4|5|6|7|D|8|@]|9|@]|A|$]]|$1|B|3|-4|5|6|7|E|8|@]|9|@]|A|$]]]|C|$]]

Also if you add same value with same id, it will automatically update older data.

blocks|key|2186120|text|使用_bulk尝试一下|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|2186121|http://127.0.0.1:9200/myindex/type/_bulk
{
"update":+{
++++"_index":+"myindex",
++++"_type":+"type",
++++"_id":+"myid"
}
}{
"doc":+{
++++"field":+"new+value"
}
}{
"update":+{
++++"_index":+"myindex",
++++"_type":+"type",
++++"_id":+"id"
}
}{
"doc":+{
++++"field":+"new+value"
}
}|code-block|syntax|javascript|2186122|entityMap|0|LINK|mutability|MUTABLE|url|https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-bulk.html^0|2|5|0|0|0^^$0|@$1|2|3|4|5|6|7|Q|8|@]|9|@$A|R|B|S|1|T]]|C|$]]|$1|D|3|E|5|F|7|U|8|@]|9|@]|C|$G|H]]|$1|I|3|-4|5|6|7|V|8|@]|9|@]|C|$]]]|J|$K|$5|L|M|N|C|$O|P]]]]

Try this using <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-bulk.html" rel="noreferrer">_bulk</a>:

<pre><code>http://127.0.0.1:9200/myindex/type/_bulk
{
"update": {
 "_index": "myindex",
 "_type": "type",
 "_id": "myid"
}
}{
"doc": {
 "field": "new value"
}
}{
"update": {
 "_index": "myindex",
 "_type": "type",
 "_id": "id"
}
}{
"doc": {
 "field": "new value"
}
}
</code></pre>

blocks|key|1710834|text|Elasticsearch的批量API也可用于更新请求，至少用于Java客户端。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1710835|List+list+=+new+Arraylist();
list.add("hello");
BulkProcessor+bulk+=+new+BulkProcessor();
UpdateRequest+update+=+new+UpdateRequest("index",+"type",+"id1");
update.script("ctx._source.aliases%2B=+newaliases");++//dynamic+script
update.addScriptParam("newaliases",+list);
bulk.add(update);|code-block|syntax|javascript|1710836|请注意，在较新版本的elasticsearch中禁用了动态脚本。启用该功能或使用预编译的脚本来使用此功能。|1710837|entityMap^0|0|0|0^^$0|@$1|2|3|4|5|6|7|K|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|L|8|@]|9|@]|A|$E|F]]|$1|G|3|H|5|6|7|M|8|@]|9|@]|A|$]]|$1|I|3|-4|5|6|7|N|8|@]|9|@]|A|$]]]|J|$]]

Elasticsearch's bulk APIs can be used for update requests as well, at least for the Java client.

<pre><code>List list = new Arraylist();
list.add("hello");
BulkProcessor bulk = new BulkProcessor();
UpdateRequest update = new UpdateRequest("index", "type", "id1");
update.script("ctx._source.aliases+= newaliases"); //dynamic script
update.addScriptParam("newaliases", list);
bulk.add(update);
</code></pre>

Note that dynamic scripting is disabled in newer versions of elasticsearch. Either enable that or use pre-compiled scripts for using this feature.

blocks|key|5715912|text|您可以使用spring+java+client使用以下代码执行相同的操作。以下是代码中使用的依赖项。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|5715913|import+org.elasticsearch.action.update.UpdateRequest;

import+org.elasticsearch.index.query.QueryBuilder;

import+org.springframework.data.elasticsearch.core.query.UpdateQuery;

import+org.springframework.data.elasticsearch.core.query.UpdateQueryBuilder;

private+UpdateQuery+updateExistingDocument(String+Id)+{
++++//+Add+updatedDateTime,+CreatedDateTime,+CreateBy,+UpdatedBy+field+in+existing+documents+in+Elastic+Search+Engine
++++UpdateRequest+updateRequest+=+new+UpdateRequest().doc("UpdatedDateTime",+new+Date(),+"CreatedDateTime",+new+Date(),+"CreatedBy",+"admin",+"UpdatedBy",+"admin");

++++//+Create+updateQuery
++++UpdateQuery+updateQuery+=+new+UpdateQueryBuilder().withId(Id).withClass(ElasticSearchDocument.class).build();
++++updateQuery.setUpdateRequest(updateRequest);

++++//+Execute+update
+++++elasticsearchTemplate.update(updateQuery);
}|code-block|syntax|javascript|5715914|entityMap^0|0|0^^$0|@$1|2|3|4|5|6|7|I|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|J|8|@]|9|@]|A|$E|F]]|$1|G|3|-4|5|6|7|K|8|@]|9|@]|A|$]]]|H|$]]

You can do the same using spring java client using the following code. Following are the dependencies used in the code.

<pre><code>import org.elasticsearch.action.update.UpdateRequest;

import org.elasticsearch.index.query.QueryBuilder;

import org.springframework.data.elasticsearch.core.query.UpdateQuery;

import org.springframework.data.elasticsearch.core.query.UpdateQueryBuilder;

private UpdateQuery updateExistingDocument(String Id) {
 // Add updatedDateTime, CreatedDateTime, CreateBy, UpdatedBy field in existing documents in Elastic Search Engine
 UpdateRequest updateRequest = new UpdateRequest().doc("UpdatedDateTime", new Date(), "CreatedDateTime", new Date(), "CreatedBy", "admin", "UpdatedBy", "admin");

 // Create updateQuery
 UpdateQuery updateQuery = new UpdateQueryBuilder().withId(Id).withClass(ElasticSearchDocument.class).build();
 updateQuery.setUpdateRequest(updateRequest);

 // Execute update
 elasticsearchTemplate.update(updateQuery);
}
</code></pre>

blocks|key|1713100|text|这对我很有效。|type|unstyled|depth|inlineStyleRanges|entityRanges|data|1713101|input_list.dat：|1713102|{+"index"+:+{+"_index":+"my_index",+"_type":+"my_type",+"_id":+"existing-value"+}+}

{+"Field_to_update":+"New_Value"+}

{+"index"+:+{+"_index":+"my_index",+"_type":+"my_type",+"_id":+"existing_value"+}+}

{+"Field_to_update":+"New_Value"+}|code-block|syntax|javascript|1713103|命令：|1713104|curl+-k+-XPOST+'https://my_host:9200/my_url/_bulk'+--data-binary+"@input_list.dat";+echo|1713105|entityMap^0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|O|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|P|8|@]|9|@]|A|$]]|$1|D|3|E|5|F|7|Q|8|@]|9|@]|A|$G|H]]|$1|I|3|J|5|6|7|R|8|@]|9|@]|A|$]]|$1|K|3|L|5|F|7|S|8|@]|9|@]|A|$G|H]]|$1|M|3|-4|5|6|7|T|8|@]|9|@]|A|$]]]|N|$]]

This works for me.

input_list.dat:

<pre><code>{ "index" : { "_index": "my_index", "_type": "my_type", "_id": "existing-value" } }

{ "Field_to_update": "New_Value" }

{ "index" : { "_index": "my_index", "_type": "my_type", "_id": "existing_value" } }

{ "Field_to_update": "New_Value" }
</code></pre>

Command:

<pre><code>curl -k -XPOST 'https://my_host:9200/my_url/_bulk' --data-binary "@input_list.dat"; echo
</code></pre>

blocks|key|2186240|text|作为期待已久的Reindex+API的一部分，Elasticsearch+2.3.0引入了Update+By+Query+API。|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|2186241|作为示例，您可以更新所有文档以删除某个字段(如果该字段存在)：|2186242|POST+/myindex/mytype/_update_by_query
{
++"script":+{
++++"inline":+"ctx._source.remove(\"remove\")"
++},
++"query":+{
++++"exists":+{
++++++"field":+"remove"
++++}
++}
}|code-block|syntax|javascript|2186243|上面的例子使用了内联脚本，所以一定要在带有script.inline:+on的elasticsearch.yml中启用它。|style|CODE|2186244|entityMap|0|LINK|mutability|MUTABLE|url|https://www.elastic.co/guide/en/elasticsearch/reference/2.3/docs-reindex.html|1|https://www.elastic.co/guide/en/elasticsearch/reference/2.3/docs-update-by-query.html^0|7|B|0|19|J|1|0|0|0|L|H|13|H|0^^$0|@$1|2|3|4|5|6|7|Y|8|@]|9|@$A|Z|B|10|1|11]|$A|12|B|13|1|14]]|C|$]]|$1|D|3|E|5|6|7|15|8|@]|9|@]|C|$]]|$1|F|3|G|5|H|7|16|8|@]|9|@]|C|$I|J]]|$1|K|3|L|5|6|7|17|8|@$A|18|B|19|M|N]|$A|1A|B|1B|M|N]]|9|@]|C|$]]|$1|O|3|-4|5|6|7|1C|8|@]|9|@]|C|$]]]|P|$Q|$5|R|S|T|C|$U|V]]|W|$5|R|S|T|C|$U|X]]]]

Elasticsearch 2.3.0 introduced the <a href="https://www.elastic.co/guide/en/elasticsearch/reference/2.3/docs-update-by-query.html" rel="nofollow">Update By Query API</a> as part of the long awaited <a href="https://www.elastic.co/guide/en/elasticsearch/reference/2.3/docs-reindex.html" rel="nofollow">Reindex API</a>. 

As an example, here is how you could update all documents to delete a certain field if it exists:

<pre><code>POST /myindex/mytype/_update_by_query
{
 "script": {
 "inline": "ctx._source.remove(\"remove\")"
 },
 "query": {
 "exists": {
 "field": "remove"
 }
 }
}
</code></pre>

The above example uses inline scripting, so be sure to enable it in <code>elasticsearch.yml</code> with <code>script.inline: on</code>.

blocks|key|5716016|text|您可以使用ElasticSeach+Bulk+API通过一个API调用来更新多个文档|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|5716017|CURL示例|style|BOLD|5716018|curl+--location+--request+POST+'localhost:9200/whatsapp/_bulk'+\
--header+'Content-Type:+application/json'+\
--data-raw+'{+"update"+:+{"_id"+:+692,+"_index"+:+"whatsapp","_type":"_doc","retry_on_conflict"+:+3}+}
{+"doc"+:+{"thread_status"+:+1}+}
{+"update"+:+{"_id"+:+693,+"_index"+:+"whatsapp","_type":"_doc","retry_on_conflict"+:+3}+}
{+"doc"+:+{"thread_status"+:+1}+}

'|code-block|syntax|javascript|5716019|注意最后一行数据必须以换行符\n结束。这就是为什么你会注意到'在json的结束行。|5716020|entityMap|0|LINK|mutability|MUTABLE|url|https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-bulk.html#bulk-update^0|5|L|0|0|0|6|0|0|0|2|U|1|0^^$0|@$1|2|3|4|5|6|7|W|8|@]|9|@$A|X|B|Y|1|Z]]|C|$]]|$1|D|3|E|5|6|7|10|8|@$A|11|B|12|F|G]]|9|@]|C|$]]|$1|H|3|I|5|J|7|13|8|@]|9|@]|C|$K|L]]|$1|M|3|N|5|6|7|14|8|@$A|15|B|16|F|G]|$A|17|B|18|F|G]]|9|@]|C|$]]|$1|O|3|-4|5|6|7|19|8|@]|9|@]|C|$]]]|P|$Q|$5|R|S|T|C|$U|V]]]]

You can use the <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-bulk.html#bulk-update" rel="nofollow noreferrer">ElasticSeach Bulk API</a> for updating the multiple documents using a single API call 

CURL example

<pre><code>curl --location --request POST 'localhost:9200/whatsapp/_bulk' \
--header 'Content-Type: application/json' \
--data-raw '{ "update" : {"_id" : 692, "_index" : "whatsapp","_type":"_doc","retry_on_conflict" : 3} }
{ "doc" : {"thread_status" : 1} }
{ "update" : {"_id" : 693, "_index" : "whatsapp","_type":"_doc","retry_on_conflict" : 3} }
{ "doc" : {"thread_status" : 1} }

'
</code></pre>

NOTE The final line of data must end with a newline character \n. That' why you will notice ' at the end line of json.

Let's say I have a <code>tag</code> type in an ElasticSearch index, with the following mapping:

<pre><code>{
 "tag": {
 "properties": {
 "tag": {"type": "string", "store": "yes"},
 "aliases": {"type": "string"}
 }
 }
}
</code></pre>

Each entry is a tag, and an array of aliases to that tag. Here is an example item:

<pre><code>{
 "word": "weak",
 "aliases": ["anemic", "anaemic", "faint", "flimsy"]
}
</code></pre>

From time to time, I want to add new tag words with their aliases, and add new aliases to existing tag words.

Adding new tag words with their aliases is easy, it's just a new Document. However, how can I add new aliases to existing tag words in a sane way?

I know I can just search for the tag word, get its document, search to see if the alias already exists in the array of aliases, if not add it, than save. However - this does not sound like a good solution.

Is there a way to do a bulk update?

How do I update multiple items in ElasticSearch?

翻译质量差，导致语言生硬或混乱。

没有提供实际的解决方法或示例。

解答不清晰，无法理解或解决问题。

页面排版不美观，阅读体验差。

文章

问答

视频

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

假设我在ElasticSearch索引中有一个tag类型，映射如下：{    "tag": {        "properties": {            "tag": {"type": "string", "store": "yes"},            "aliases": {"type": "str...

问如何在ElasticSearch中更新多个项目？
EN

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问如何在ElasticSearch中更新多个项目？EN