FetchSFTP 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-standard-nar
描述¶
从远程 SFTP 服务器获取文件的内容，并使用远程文件的内容覆盖传入 FlowFile 的内容。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
允许的密码 |
允许用于 SFTP 连接的密码列表（以逗号分隔）。留空则允许所有。可用选项包括：3des-cbc、3des-ctr、aes128-cbc、aes128-ctr、aes128-gcm@openssh.com、aes192-cbc、aes192-ctr、aes256-cbc、aes256-ctr、aes256-gcm@openssh.com、arcfour、arcfour128、arcfour256、blowfish-cbc、blowfish-ctr、cast128-cbc、cast128-ctr、chacha20-poly1305@openssh.com、idea-cbc、idea-ctr、serpent128-cbc、serpent128-ctr、serpent192-cbc、serpent192-ctr、serpent256-cbc、serpent256-ctr、twofish-cbc、twofish128-cbc、twofish128-ctr、twofish192-cbc、twofish192-ctr、twofish256-cbc、twofish256-ctr |
完成策略 |
指定将服务器的原始文件拉入 NiFi 后如何处理该文件。如果完成策略失败，将记录警告但仍将传输数据。 |
连接超时 |
创建连接时在超时之前要等待的时间 |
创建目录 |
当“完成策略”为“移动文件”时使用。指定如果远程目录不存在，是否要创建该目录。 |
数据超时 |
在本地和远程系统之间传输文件时，此值规定了系统间无数据传输的最长允许间隔时间 |
禁用目录列表 |
控制当“完成策略”为“移动文件”且“创建目录”启用时如何创建“移动目标目录”。如果设为“true”，则在创建缺失目录前不执行目录列表操作。默认情况下，此处理器会执行目录列表命令以检查目标目录是否存在，然后再创建缺失目录。但是，在某些情况下，您可能需要禁用目录列表，如下所示。在目录上进行某些权限设置（例如 chmod 100）时，目录列表可能会失败。此外，如果任何其他 SFTP 客户端在该处理器执行了列表操作之后以及该处理器的目录创建请求完成之前创建了该目录，则会返回错误，因为该目录已经存在。 |
主机密钥文件 |
如果提供，则给定文件将用作主机密钥；否则，如果应用“严格主机密钥检查”属性（设为 true），则使用 ~/.ssh 目录中的“known_hosts”和“known_hosts2”文件，否则将不使用任何主机密钥文件 |
主机名 |
要从中获取数据的主机的完全限定主机名或 IP 地址 |
允许的密钥算法 |
允许用于 SFTP 连接的密钥算法列表（以逗号分隔）。留空则允许所有。可用选项包括：ecdsa-sha2-nistp256、ecdsa-sha2-nistp256-cert-v01@openssh.com、ecdsa-sha2-nistp384、ecdsa-sha2-nistp384-cert-v01@openssh.com、ecdsa-sha2-nistp521、ecdsa-sha2-nistp521-cert-v01@openssh.com、rsa-sha2-256、rsa-sha2-512、ssh-dss、ssh-dss-cert-v01@openssh.com、ssh-ed25519、ssh-ed25519-cert-v01@openssh.com、ssh-rsa、ssh-rsa-cert-v01@openssh.com |
允许的密钥交换算法 |
允许用于 SFTP 连接的密钥交换算法列表（以逗号分隔）。留空则允许所有。可用选项包括：curve25519-sha256、curve25519-sha256@libssh.org、diffie-hellman-group-exchange-sha1、diffie-hellman-group-exchange-sha256、diffie-hellman-group1-sha1、diffie-hellman-group14-sha1、diffie-hellman-group14-sha256、diffie-hellman-group14-sha256@ssh.com、diffie-hellman-group15-sha256、diffie-hellman-group15-sha256@ssh.com、diffie-hellman-group15-sha384@ssh.com、diffie-hellman-group15-sha512、diffie-hellman-group16-sha256、diffie-hellman-group16-sha384@ssh.com、diffie-hellman-group16-sha512、diffie-hellman-group16-sha512@ssh.com、diffie-hellman-group17-sha512、diffie-hellman-group18-sha512、diffie-hellman-group18-sha512@ssh.com、ecdh-sha2-nistp256、ecdh-sha2-nistp384、ecdh-sha2-nistp521、ext-info-c |
允许的消息身份验证代码 |
允许用于 SFTP 连接的消息身份验证代码列表（以逗号分隔）。留空则允许所有。可用选项包括：hmac-md5、hmac-md5-96、hmac-md5-96-etm@openssh.com、hmac-md5-etm@openssh.com、hmac-ripemd160、hmac-ripemd160-96、hmac-ripemd160-etm@openssh.com、hmac-ripemd160@openssh.com、hmac-sha1、hmac-sha1-96、hmac-sha1-96@openssh.com、hmac-sha1-etm@openssh.com、hmac-sha2-256、hmac-sha2-256-etm@openssh.com、hmac-sha2-512、hmac-sha2-512-etm@openssh.com |
移动目标目录 |
将原始文件引入到 NiFi 后要将原始文件移至其中的远程服务器上的目录。除非将“完成策略”设置为“移动文件”，否则将忽略此属性。如果禁用了“创建目录”，则指定的目录必须已经存在于远程系统上，否则重命名将失败。 |
密码 |
用户账户的密码 |
端口 |
远程主机上用于从中获取数据的连接端口 |
私钥密码 |
私钥的密码 |
私钥路径 |
私钥文件的完全限定路径 |
远程文件 |
远程系统上的完全限定文件名 |
发送保持在线超时 |
每 5 秒发送一条保持在线消息，最多 5 次，总超时时间为 25 秒。 |
严格的主机密钥检查 |
表示是否应严格执行主机密钥 |
使用压缩 |
表示传输文件时是否应使用 ZLIB 压缩 |
用户名 |
用户名 |
fetchfiletransfer-notfound-loglevel |
触发处理器且文件不存在时使用的日志级别 |
proxy-configuration-service |
指定代理配置控制器服务来代理网络请求。 |
关系¶
名称 |
描述 |
|---|---|
comms.failure |
由于通信故障而无法从远程服务器提取的任何 FlowFile 都将传输到此关系。 |
not.found |
收到远程服务器“Not Found”消息的任何 FlowFile 将被传输到此关系。 |
permission.denied |
任何因权限不足而无法从远程服务器提取的 FlowFile 都将转移到此关系中。 |
success |
所有收到的 FlowFiles 都将路由至“success” |
写入属性¶
名称 |
描述 |
|---|---|
sftp.remote.host |
从中提取文件的主机名或 IP 地址 |
sftp.remote.port |
用于与远程 SFTP 服务器通信的端口 |
sftp.remote.filename |
提取的远程文件的名称 |
filename |
文件名更新为指向远程文件的文件名 |
path |
如果远程文件包含目录名，则该目录名将使用“path”属性添加到 FlowFile |
fetch.failure.reason |
路由到任何 failure 关系时，所应用的 failure 关系的名称 |
涉及其他组件的用例¶
检索 SFTP 服务器目录中的所有文件 |