GetMongoRecord
Описание
Версия GetMongo, основанная на записях, которая использует Record Writers для записи набора результатов MongoDB.
Теги
mongo, mongodb, get, fetch, record, json
Свойства
| Название | Описание |
|---|---|
| Client Service | Если это свойство настроено, оно будет использовать назначенную клиентскую службу для объединения подключений в пул. |
| Record Writer | Фабрика записи, используемая для записи наборов результатов. |
| Mongo Database Name | Имя используемой базы данных Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Mongo Collection Name | Имя используемой коллекции Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Schema Name | Имя схемы в настроенном реестре схем, используемое для результатов запроса. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Query Output Attribute | Если задано, запрос будет записан в указанный атрибут в выходных файлах потока. Поддерживает язык выражений: 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 (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Projection | Поля, которые будут возвращены из документов в наборе ре зультатов; должны быть допустимым документом BSON Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Sort | Поля для сортировки; должны быть допустимым документом BSON Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Limit | Максимальное количество возвращаемых элементов Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Batch Size | Количество элементов, возвращаемых с сервера за один пакет Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
Взаимосвязи
- success: Все FlowFiles, в которых есть результаты успешного выполнения запроса, направляются сюда.
- failure: Все входные файлы Flow, которые являются частью неудачного выполнения запроса, попадают сюда.
- original: Все входные файлы Flow, которые являются частью успешного выполнения запроса, попадают сюда.