SearchElasticsearch
Описание
Процессор, позволяющий пользователю многократно выполн ять постраничный запрос (с агрегациями), написанный с использованием Elasticsearch JSON DSL. Запросы Search After/Point in Time должны включать действительное поле "sort". Процессор будет получать несколько страниц результатов, пока не закончится либо результаты, либо время жизни пагинации. После этого запрос будет перезапущен, начиная с первой страницы результатов.
Теги
elasticsearch, elasticsearch5, elasticsearch6, elasticsearch7, elasticsearch8, query, scroll, page, search, 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 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 "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. |
| Pagination Type | Используемый метод разбиения на страницы. Не все типы доступны для всех версий Elasticsearch. Ознакомьтесь с документацией Elasticsearch, чтобы узнать, какие типы применимы и рекомендуются для вашего сервиса. |
| Pagination Keep Alive | Pagination "keep_alive" period. Period Elasticsearch will keep the scroll/pit cursor alive in between requests (this is not the time expected for all pages to be returned, but the maximum allowed time for requests between page retrievals). |
Взаимосвязи
- aggregations: Агрегации направляются в эту связь.
- hits: Результаты поиска направляются в эту связь.