UpdateByQueryElasticsearch
Описание
Обновление документов в индексе Elasticsearch с использованием запроса. Запрос может быть загружен из содержимого FlowFile или из параметра Query. Загруженный запрос может содержать любой JSON, принимаемый API _update_by_query Elasticsearch, например объект "query" для идентификации документов, подлежащих обновлению, а также скрипт "script" для определения выполняемых обновлений.
Теги
elastic, elasticsearch, elasticsearch5, elasticsearch6, elasticsearch7, elasticsearch8, update, query
Свойства
| Название | Описание |
|---|---|
| Query Definition Style | How the JSON Query will be defined for use by the processor. |
| Query | A query in JSON syntax, not Lucene syntax. Ex: {"query":{"match":{"somefield":"somevalue"}}}. If this parameter is not set, the query will be read from the flowfile content. If the query (property and flowfile content) is empty, a default empty JSON Object will be used, which will result in a "match_all" query in Elasticsearch. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)This Property is only considered if the [Query Definition Style] Property has a value of "FULL_QUERY". |
| Query Clause | A "query" clause in JSON syntax, not Lucene syntax. Ex: {"match":{"somefield":"somevalue"}}. If the query is empty, a default JSON Object will be used, which will result in a "match_all" query in Elasticsearch. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)This Property is only considered if the [Query Definition Style] Property has a value of "BUILD_QUERY". |
| Script | A "script" to execute during the operation, in JSON syntax. Ex: {"source": "ctx._source.count++", "lang": "painless"} Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)This Property is only considered if the [Query Definition Style] Property has a value of "BUILD_QUERY". |
| Query Attribute | If set, the executed query will be set on each result flowfile in the specified attribute. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Index | The name of the index to use. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Type | The type of this document (used by Elasticsearch for indexing and searching). Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Max JSON Field String Length | The maximum allowed length of a string value when parsing a JSON document or attribute. |
| Client Service | An Elasticsearch client service to use for running queries. |
Взаимосвязи
- success: If the "by query" operation succeeds, and a flowfile was read, it will be sent to this relationship.
- failure: If the "by query" operation fails, and a flowfile was read, it will be sent to this relationship.
- retry: All flowfiles that fail due to server/cluster availability go to this relationship.