FetchGridFS
Описание
Извлекает один или несколько файлов из GridFS по имени файла или по пользовательскому запросу.
Теги
fetch, gridfs, mongo
Свойства
| Название | Описание |
|---|---|
| Client Service | Клиентская служба MongoDB для подключения к базе данных. |
| Mongo Database Name | Имя используемой базы данных Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Bucket Name | Имя корзины GridFS, в которой будут храниться файлы. Если оставить поле пустым, будет использовано значение по умолчанию 'fs', используемое клиентским драйвером MongoDB. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| File Name | Имя файла в корзине, на который нацелен этот процессор. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Query | Допустимый запрос MongoDB для получения одного или нескольких файлов из GridFS. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Query Output Attribute | Если задано, запрос будет записан в указанный атрибут выходных потоковых файлов. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Operation Mode | This option controls when results are made available to downstream processors. If Stream Query Results is enabled, provenance will not be tracked relative to the input flowfile if an input flowfile is received and starts the query. In Stream Query Results mode errors will be handled by sending a new flowfile with the original content and attributes of the input flowfile to the failure relationship. Streaming should only be used if there is reliable connectivity between MongoDB and NiFi. |
Взаимосвязи
- success: Если операция выполнена успешно, потоковый файл отправляется в эту связь.
- failure: Если при обработке потокового файла возникает ошибка, он отправляется в эту связь.
- original: Исходный входной файл потока отправляется в эту связь, если запрос не вызывает ошибку