Update API
editUpdate API
editUpdates a document using the specified script.
Request
editPOST /<index>/_update/<_id>
Prerequisites
edit-
If the Elasticsearch security features are enabled, you must have the
index
orwrite
index privilege for the target index or index alias.
Description
editEnables you to script document updates. The script can update, delete, or skip
modifying the document. The update API also supports passing a partial document,
which is merged into the existing document. To fully replace an existing
document, use the index
API.
This operation:
- Gets the document (collocated with the shard) from the index.
- Runs the specified script.
- Indexes the result.
The document must still be reindexed, but using update
removes some network
roundtrips and reduces chances of version conflicts between the GET and the
index operation.
The _source
field must be enabled to use update
. In addition to _source
,
you can access the following variables through the ctx
map: _index
,
_type
, _id
, _version
, _routing
, and _now
(the current timestamp).
Path parameters
edit-
<index>
- (Required, string) Name of the target index. By default, the index is created automatically if it doesn’t exist. For more information, see Automatically create data streams and indices.
-
<_id>
- (Required, string) Unique identifier for the document to be updated.
Query parameters
edit-
if_seq_no
- (Optional, integer) Only perform the operation if the document has this sequence number. See Optimistic concurrency control.
-
if_primary_term
- (Optional, integer) Only perform the operation if the document has this primary term. See Optimistic concurrency control.
-
lang
-
(Optional, string) The script language. Default:
painless
. -
require_alias
-
(Optional, Boolean) If
true
, the destination must be an index alias. Defaults tofalse
. -
refresh
-
(Optional, enum) If
true
, Elasticsearch refreshes the affected shards to make this operation visible to search, ifwait_for
then wait for a refresh to make this operation visible to search, iffalse
do nothing with refreshes. Valid values:true
,false
,wait_for
. Default:false
. -
retry_on_conflict
- (Optional, integer) Specify how many times should the operation be retried when a conflict occurs. Default: 0.
-
routing
- (Optional, string) Custom value used to route operations to a specific shard.
-
_source
-
(Optional, list) Set to
true
to enable source retrieval (default:false
). You can also specify a comma-separated list of the fields you want to retrieve. -
_source_excludes
- (Optional, list) Specify the source fields you want to exclude.
-
_source_includes
- (Optional, list) Specify the source fields you want to retrieve.
-
timeout
-
(Optional, time units) Period to wait for the following operations:
Defaults to
1m
(one minute). This guarantees Elasticsearch waits for at least the timeout before failing. The actual wait time could be longer, particularly when multiple waits occur. -
wait_for_active_shards
-
(Optional, string) The number of shard copies that must be active before proceeding with the operation. Set to
all
or any positive integer up to the total number of shards in the index (number_of_replicas+1
). Default: 1, the primary shard.See Active shards.
Examples
editFirst, let’s index a simple doc:
PUT test/_doc/1 { "counter" : 1, "tags" : ["red"] }
To increment the counter, you can submit an update request with the following script:
POST test/_update/1 { "script" : { "source": "ctx._source.counter += params.count", "lang": "painless", "params" : { "count" : 4 } } }
Similarly, you could use and update script to add a tag to the list of tags (this is just a list, so the tag is added even it exists):
POST test/_update/1 { "script": { "source": "ctx._source.tags.add(params.tag)", "lang": "painless", "params": { "tag": "blue" } } }
You could also remove a tag from the list of tags. The Painless
function to remove
a tag takes the array index of the element
you want to remove. To avoid a possible runtime error, you first need to
make sure the tag exists. If the list contains duplicates of the tag, this
script just removes one occurrence.
POST test/_update/1 { "script": { "source": "if (ctx._source.tags.contains(params.tag)) { ctx._source.tags.remove(ctx._source.tags.indexOf(params.tag)) }", "lang": "painless", "params": { "tag": "blue" } } }
You can also add and remove fields from a document. For example, this script
adds the field new_field
:
POST test/_update/1 { "script" : "ctx._source.new_field = 'value_of_new_field'" }
Conversely, this script removes the field new_field
:
POST test/_update/1 { "script" : "ctx._source.remove('new_field')" }
The following script removes a subfield from an object field:
POST test/_update/1 { "script": "ctx._source['my-object'].remove('my-subfield')" }
Instead of updating the document, you can also change the operation that is
executed from within the script. For example, this request deletes the doc if
the tags
field contains green
, otherwise it does nothing (noop
):
POST test/_update/1 { "script": { "source": "if (ctx._source.tags.contains(params.tag)) { ctx.op = 'delete' } else { ctx.op = 'none' }", "lang": "painless", "params": { "tag": "green" } } }
Update part of a document
editThe following partial update adds a new field to the existing document:
POST test/_update/1 { "doc": { "name": "new_name" } }
If both doc
and script
are specified, then doc
is ignored. If you
specify a scripted update, include the fields you want to update in the script.
Detect noop updates
editBy default updates that don’t change anything detect that they don’t change
anything and return "result": "noop"
:
POST test/_update/1 { "doc": { "name": "new_name" } }
If the value of name
is already new_name
, the update
request is ignored and the result
element in the response returns noop
:
{ "_shards": { "total": 0, "successful": 0, "failed": 0 }, "_index": "test", "_type": "_doc", "_id": "1", "_version": 2, "_primary_term": 1, "_seq_no": 1, "result": "noop" }
You can disable this behavior by setting "detect_noop": false
:
POST test/_update/1 { "doc": { "name": "new_name" }, "detect_noop": false }
Upsert
editIf the document does not already exist, the contents of the upsert
element
are inserted as a new document. If the document exists, the
script
is executed:
POST test/_update/1 { "script": { "source": "ctx._source.counter += params.count", "lang": "painless", "params": { "count": 4 } }, "upsert": { "counter": 1 } }
Scripted upsert
editTo run the script whether or not the document exists, set scripted_upsert
to
true
:
POST test/_update/1 { "scripted_upsert": true, "script": { "source": """ if ( ctx.op == 'create' ) { ctx._source.counter = params.count } else { ctx._source.counter += params.count } """, "params": { "count": 4 } }, "upsert": {} }
Doc as upsert
editInstead of sending a partial doc
plus an upsert
doc, you can set
doc_as_upsert
to true
to use the contents of doc
as the upsert
value:
POST test/_update/1 { "doc": { "name": "new_name" }, "doc_as_upsert": true }
Using ingest pipelines with doc_as_upsert
is not supported.