FetchFile
Описание
Читает содержимое файла с диска и передает его в содержимое входящего FlowFile. После этого файл при необходимости перемещается в другое место или удаляется, чтобы помочь организовать файловую систему.
Теги
local, files, filesystem, ingest, ingress, get, source, input, fetch
Свойства
| Название | Описание |
|---|---|
| File to Fetch | Полное имя файла, который нужно извлечь из файловой системы Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Completion Strategy | Указы вает, что делать с исходным файлом в файловой системе после его загрузки в NiFi |
| Move Destination Directory | Каталог, в который нужно переместить исходный файл после его загрузки из файловой системы. Это свойство игнорируется, если для стратегии завершения не установлено значение «Переместить файл». Если каталог не существует, он будет создан. Поддерживает язык выражений: true (будет оцениваться с использованием атрибутов файла потока и переменных среды) |
| Move Conflict Strategy | Если для стратегии завершения установлено значение «Переместить файл» и в целевом каталоге уже существует файл с таким же именем, это свойство указывает, как следует разрешать конфликт имен. |
| Log level when file not found | Уровень ведения журнала, используемый в случае, если файл не существует при запуске процессора. |
| Log level when permission denied | Log level to use in case user root does not have sufficient permissions to read the file |
Взаимосвязи
- success: Любой файл потока, успешно извлеченный из файловой системы, будет передан в это отношение.
- not.found: Любой файл FlowFile, который не удалось получить из файловой системы из-за того, что файл не был найден, будет передан в это отношение.
- permission.denied: Любой файл FlowFile, который не удалось получить из файловой системы из-за того, что у пользователя, запустившего NiFi, не было достаточных прав, будет передан в это отношение.
- failure: Any FlowFile that could not be fetched from the file system for any reason other than insufficient permissions or the file not existing will be transferred to this Relationship.