RunMongoAggregation
Описание
Процессор, выполняющий агрегированный запрос при получении файла потока.
Теги
mongo, aggregation, aggregate
Свойства
| Название | Описание |
|---|---|
| Client Service | Если это свойство настроено, оно будет использовать назначенную клиентскую службу для объединения подключений в пул. |
| Mongo Database Name | Имя используемой базы данных Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Mongo Collection Name | Имя используемой коллекции Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Character Set | Указывает набор символов для данных документа. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Query | Задаваемый запрос на выполнение агрегации. Поддерживае т язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Allow Disk Use | Установите значение true, чтобы разрешить запись данных во временные файлы и предотвратить превышение максимального лимита использования памяти во время выполнения конвейера агрегации при работе с большими наборами данных. |
| JSON Type | By default, MongoDB's Java driver returns "extended JSON". Some of the features of this variant of JSON may cause problems for other JSON parsers that expect only standard JSON types and conventions. This configuration setting controls whether to use extended JSON or provide a clean view that conforms to standard JSON. |
| Query Output Attribute | Если задано, запрос будет записан в указанный атрибут в выходных файлах потока. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Batch Size | Количество элементов, возвращаемых с сервера за один пакет. |
| Results Per FlowFile | Сколько результатов нужно поместить в файл потока за один раз. Весь массив будет обрабатываться как массив JSON результатов. |
| Date Format | Строка формата даты, используемая для формати рования полей даты, возвращаемых из Mongo. Применяется только в том случае, если для формата вывода JSON установлено значение «Стандартный JSON». Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
Взаимосвязи
- results: Набор результатов агрегации будет отправлен в эту связь.
- failure: Входной файл потока отправляется в эту связь, если запрос не выполнен.
- original: Входной файл потока отправляется в эту связь, если запрос выполнен успешно.