FetchFile Processor
描述
从磁盘读取文件的内容并将其流式传输到传入 FlowFile 的内容中。 完成此操作后,可以选择将文件移动到其他地方或删除,以帮助保持文件系统的组织。
标签
多处理器协同场景
将目录中的所有文件导入 Lynxus
配置 "Input Directory" 属性以指向你想从中导入文件的目录。
将 "Input Directory Location" 属性设置为 "Local"
可选地,将 "Minimum File Age" 设置为一个较小的值(例如 "1 min"),以避免导入仍在写入的文件。
将 'success' Relationship 连接到 FetchFile 处理器。
将 "File to Fetch" 属性设置为 `${absolute.path}/${filename}`
将 "Completion Strategy" 属性设置为 `None`
将目录中的特定文件导入 Lynxus,按文件名过滤
配置 "Input Directory" 属性以指向你想从中导入文件的目录。
将 "Input Directory Location" 属性设置为 "Local"
将 "File Filter" 属性设置为一个匹配你想导入文件的文件名(不含路径)的正则表达式。 例如,要导入所有 .jpg 文件,将值设置为 `.*\.jpg`
可选地,将 "Minimum File Age" 设置为一个较小的值(例如 "1 min"),以避免导入仍在写入的文件。
将 'success' Relationship 连接到 FetchFile 处理器。
将 "File to Fetch" 属性设置为 `${absolute.path}/${filename}`
将 "Completion Strategy" 属性设置为 `None`
属性
| 名称 | 默认值 | 可选值 | 描述 |
|---|---|---|---|
| File to Fetch | ${absolute.path}/${filename} | 要从文件系统获取的文件的完全限定文件名 支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值) | |
| Completion Strategy | None |
| 指定将文件系统上的原始文件拉入 Lynxus 后如何处理 |
| Move Destination Directory | | 从文件系统获取原始文件后要将其移动到的目录。除非完成策略设置为 "Move File",否则忽略此属性。如果目录不存在,将创建该目录。 支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值) | |
| Move Conflict Strategy | Rename |
| 如果完成策略设置为 Move File 且目标目录中已存在同名文件,此属性指定应如何解决该命名冲突。 |
| File not Found Log Level | ERROR |
| 触发处理器时文件不存在时使用的日志级别 |
| Permission Denied Log Level | ERROR |
| 当前应用程序用户没有足够的权限读取文件时要使用的日志级别 |
关系 (Relationships)
| 名称 | 描述 | 自动终止 |
|---|---|---|
failure | 由于权限不足或文件不存在以外的任何原因无法从文件系统获取的任何 FlowFile 都将被转移到此关系。 | 否 |
not.found | 任何因找不到文件而无法从文件系统获取的 FlowFile 将被传输到此关系。 | 否 |
permission.denied | 由于运行 Lynxus 的用户没有足够的权限而无法从文件系统获取的任何 FlowFile 将被转移到此关系。 | 否 |
success | 从文件系统成功获取的任何 FlowFile 将被传输到此关系。 | 否 |
状态管理
该组件不存储状态。
受限 (Restricted)
该组件不受限。
输入要求
该组件要求有传入连接。