FetchFTP 2025.5.31.15¶

捆绑包¶

org.apache.nifi | nifi-standard-nar

描述¶

从远程 FTP 服务器获取文件的内容，并使用远程文件的内容覆盖传入 FlowFile 的内容。

标签¶

fetch、files、ftp、get、ingest、input、remote、retrieve、source

输入要求¶

REQUIRED

支持敏感的动态属性¶

false

属性¶

属性	描述
完成策略	指定将服务器的原始文件拉入 NiFi 后如何处理该文件。如果完成策略失败，将记录警告但仍将传输数据。
连接模式	FTP 连接模式
连接超时	创建连接时在超时之前要等待的时间
创建目录	当“完成策略”为“移动文件”时使用。指定如果远程目录不存在，是否要创建该目录。
数据超时	在本地和远程系统之间传输文件时，此值规定了系统间无数据传输的最长允许间隔时间
主机名	要从中获取数据的主机的完全限定主机名或 IP 地址
内部缓冲区大小	为缓冲数据流设置内部缓冲区大小
移动目标目录	将原始文件引入到 NiFi 后要将原始文件移至其中的远程服务器上的目录。除非将“完成策略”设置为“移动文件”，否则将忽略此属性。如果禁用了“创建目录”，则指定的目录必须已经存在于远程系统上，否则重命名将失败。
密码	用户账户的密码
端口	远程主机上用于从中获取数据的连接端口
远程文件	远程系统上的完全限定文件名
传输模式	FTP 传输模式
使用压缩	表示传输文件时是否应使用 ZLIB 压缩
用户名	用户名
fetchfiletransfer-notfound-loglevel	触发处理器时文件不存在时使用的日志级别
ftp-use-utf8	告知客户端在处理文件和文件名时使用 UTF-8 编码。如果设置为 true，则服务器还必须支持 UTF-8 编码。
proxy-configuration-service	指定代理配置控制器服务来代理网络请求。

关系¶

名称	描述
comms.failure	由于通信故障而无法从远程服务器提取的任何 FlowFile 都将传输到此关系。
not.found	收到远程服务器“Not Found”消息的任何 FlowFile 将被传输到此关系。
permission.denied	任何因权限不足而无法从远程服务器提取的 FlowFile 都将转移到此关系中。
success	所有收到的 FlowFiles 都将路由至“success”

写入属性¶

名称	描述
ftp.remote.host	从中提取文件的主机名或 IP 地址
ftp.remote.port	用于与远程 FTP 服务器通信的端口
ftp.remote.filename	提取的远程文件的名称
filename	文件名更新为指向远程文件的文件名
path	如果远程文件包含目录名，则该目录名将使用“path”属性添加到 FlowFile
fetch.failure.reason	路由到任何 failure 关系时，所应用的 failure 关系的名称

涉及其他组件的用例¶

检索 FTP 服务器目录中的所有文件

另请参阅¶