FetchFile

文档中心 › 组件索引 › FetchFile

FetchFile Processor

类型全限定名:cn.org.acal.lynxus.processors.standard.FetchFile

所属 Bundle:cn.org.acal.lynxus:lynxus-standard-nar:2.11.8

描述

从磁盘读取文件的内容并将其流式传输到传入 FlowFile 的内容中。 完成此操作后,可以选择将文件移动到其他地方或删除,以帮助保持文件系统的组织。

标签

localfilesfilesystemingestingressgetsourceinputfetch

多处理器协同场景

将目录中的所有文件导入 Lynxus

localfilesfilesystemingestingressgetsourceinputfetch

配置 ListFile:

配置 "Input Directory" 属性以指向你想从中导入文件的目录。
将 "Input Directory Location" 属性设置为 "Local"
可选地,将 "Minimum File Age" 设置为一个较小的值(例如 "1 min"),以避免导入仍在写入的文件。

将 'success' Relationship 连接到 FetchFile 处理器。

配置 FetchFile:

将 "File to Fetch" 属性设置为 `${absolute.path}/${filename}`
将 "Completion Strategy" 属性设置为 `None`

将目录中的特定文件导入 Lynxus,按文件名过滤

localfilesfilesystemingestingressgetsourceinputfetchfilter

配置 ListFile:

配置 "Input Directory" 属性以指向你想从中导入文件的目录。
将 "Input Directory Location" 属性设置为 "Local"
将 "File Filter" 属性设置为一个匹配你想导入文件的文件名(不含路径)的正则表达式。 例如,要导入所有 .jpg 文件,将值设置为 `.*\.jpg`
可选地,将 "Minimum File Age" 设置为一个较小的值(例如 "1 min"),以避免导入仍在写入的文件。

将 'success' Relationship 连接到 FetchFile 处理器。

配置 FetchFile:

将 "File to Fetch" 属性设置为 `${absolute.path}/${filename}`
将 "Completion Strategy" 属性设置为 `None`

属性

下表中,加粗的属性为必填项;其余为可选项。表格同时标注默认值、是否支持表达式语言,以及是否为敏感属性(值会被加密)。

名称默认值可选值描述
File to Fetch${absolute.path}/${filename}要从文件系统获取的文件的完全限定文件名
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
Completion StrategyNone
  • 无 — 保留文件原样
  • 移动文件 — 将文件移动到 <移动目标目录> 属性指定的目录
  • 删除文件 — 从文件系统中删除原始文件
指定将文件系统上的原始文件拉入 Lynxus 后如何处理
Move Destination Directory从文件系统获取原始文件后要将其移动到的目录。除非完成策略设置为 "Move File",否则忽略此属性。如果目录不存在,将创建该目录。
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
Move Conflict StrategyRename
  • 重命名 — 现有的目标文件应保持不变。新摄取的文件应移动到目标目录但重命名为随机文件名
  • 替换文件 — 新摄取的文件应替换目标目录中的现有文件
  • 保留现有 — 目标目录中的现有文件应保持不变,新摄取的文件应被删除
  • 失败 — 现有的目标文件应保持完整,传入的 FlowFile 应路由至失败
如果完成策略设置为 Move File 且目标目录中已存在同名文件,此属性指定应如何解决该命名冲突。
File not Found Log LevelERROR
  • TRACE
  • DEBUG
  • INFO
  • WARN
  • ERROR
  • FATAL
  • NONE
触发处理器时文件不存在时使用的日志级别
Permission Denied Log LevelERROR
  • TRACE
  • DEBUG
  • INFO
  • WARN
  • ERROR
  • FATAL
  • NONE
当前应用程序用户没有足够的权限读取文件时要使用的日志级别

关系 (Relationships)

名称描述自动终止
failure由于权限不足或文件不存在以外的任何原因无法从文件系统获取的任何 FlowFile 都将被转移到此关系。否
not.found任何因找不到文件而无法从文件系统获取的 FlowFile 将被传输到此关系。否
permission.denied由于运行 Lynxus 的用户没有足够的权限而无法从文件系统获取的任何 FlowFile 将被转移到此关系。否
success从文件系统成功获取的任何 FlowFile 将被传输到此关系。否

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

输入要求

该组件要求有传入连接。

另请参阅