GetMongo
Описание
Создает файлы потока из документов в MongoDB, загруженных по пользовате льскому запросу.
Теги
mongodb, read, get
Свойства
| Название | Описание |
|---|---|
| Client Service | Если это свойство настроено, оно будет использовать назначенную клиентскую службу для объединения подключений в пул. |
| Mongo Database Name | Имя используемой базы данных Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Mongo Collection Name | Имя используемой коллекции Поддерживает язык выражений: 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. |
| Pretty Print Results JSON | Выберите, следует ли форматировать JSON из результатов запроса. Выбор значения «Истина» может значительно увеличить требования к дисковому пространству в зависимости от сложности документа JSON |
| Character Set | Указывает набор символов для данных документа. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Query | The selection criteria to do the lookup. If the field is left blank, it will look for input from an incoming connection from another processor to provide the query as a valid JSON document inside of the FlowFile's body. If this field is left blank and a timer is enabled instead of an incoming connection, that will result in a full collection fetch using a "{}" query. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Query Output Attribute | Если задано, запрос будет записан в указанный атрибут в выходных файлах потока. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Projection | Поля, которые будут возвращены из документов в наборе результатов; должны быть допустимым документом BSON Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Sort | Поля для сортировки; должны быть допустимым документом BSON Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Limit | Максимальное количество возвращаемых элементов Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Batch Size | Количество элементов, возвращаемых с сервера за один пакет Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Results Per FlowFile | Количество результатов, которые нужно поместить в FlowFile за один раз. Весь массив будет обрабатываться как массив результатов JSON. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Date Format | Строка формата даты, используемая для форматирования полей даты, возвращаемых из Mongo. Применяется только в том случае, если для формата вывода JSON установлено значение «Стандартный JSON». Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Send Empty Result | Если запрос выполнен успешно, но не вернул результатов, отправьте пустой документ JSON, указывающий на отсутствие результатов. |
Взаимосвязи
- success: Все FlowFiles, в которых есть результаты успешного выполнения запроса, направляются сюда.
- failure: Все входные файлы Flow, которые являются частью неудачного выполнения запроса, попадают сюда.
- original: Все входные файлы Flow, которые являются частью успешного выполнения запроса, попадают сюда.