JsonQueryElasticsearch
Описание
Процессор, позволяющий пользователю выполнять запрос (с агрегациями), написанный с использованием Elasticsearch JSON DSL. Автоматическая пагинация запросов не поддерживается. Если в процессор добавлена входящая связь, он будет использовать содержимое FlowFile для запроса. Следует быть осторожным с размером запроса, так как весь ответ от Elasticsearch будет загружен в память целиком и преобразован в результатирующие FlowFile.
Теги
elasticsearch, elasticsearch5, elasticsearch6, elasticsearch7, elasticsearch8, query, read, get, json
Свойства
| Название | Описание |
|---|---|
| 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". |
| Size | The maximum number of documents to retrieve in the query. If the query is paginated, this "size" applies to each page of the query, not the "size" of the entire result set. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)This Property is only considered if the [Query Definition Style] Property has a value of "BUILD_QUERY". |
| Sort | Sort results by one or more fields, in JSON syntax. Ex: [{"price" : {"order" : "asc", "mode" : "avg"}}, {"post_date" : {"format": "strict_date_optional_time_nanos"}}] Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)This Property is only considered if the [Query Definition Style] Property has a value of "BUILD_QUERY". |
| Aggregations | One or more query aggregations (or "aggs"), in JSON syntax. Ex: {"items": {"terms": {"field": "product", "size": 10}}} Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)This Property is only considered if the [Query Definition Style] Property has a value of "BUILD_QUERY". |
| Fields | Fields of indexed documents to be retrieved, in JSON syntax. Ex: ["user.id", "http.response.*", {"field": "@timestamp", "format": "epoch_millis"}] Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды)This Property is only considered if the [Query Definition Style] Property has a value of "BUILD_QUERY". |
| Script Fields | Fields to created using script evaluation at query runtime, in JSON syntax. Ex: {"test1": {"script": {"lang": "painless", "source": "doc['price'].value * 2"}}, "test2": {"script": {"lang": "painless", "source": "doc['price'].value * params.factor", "params": {"factor": 2.0}}}} Поддерживает язык выражений: 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. |
| Search Results Split | Выводит файл потока, содержащий все результаты поиска, или по одному файлу потока для каждого отдельного результата поиска. |
| Search Results Format | Формат вывода результатов поиска. |
| Aggregation Results Split | Выводит файл потока, содержащий все агрегации, или по одному файлу потока для каждой отдельной агрегации. |
| Aggregation Results Format | Формат результатов агрегации. |
| Output No Hits | Output a "hits" flowfile even if no hits found for query. If true, an empty "hits" flowfile will be output even if "aggregations" are output. |
Взаимосвязи
- hits: Результаты поиска направляются в эту связь.
- original: Все исходные файлы потока, которые не вызывают ошибок, направляются в эту связь.
- failure: All flowfiles that fail for reasons unrelated to server availability go to this relationship.
- aggregations: Агрегации направляются в эту связь.