FetchS3Object 2025.5.31.15¶

捆绑包¶

org.apache.nifi | nifi-aws-nar

描述¶

检索 S3 对象的内容并将其写入到 FlowFile 的内容中

标签¶

AWS、Amazon、Fetch、Get、S3

输入要求¶

REQUIRED

支持敏感的动态属性¶

false

属性¶

属性	描述
AWS 凭据提供商服务	用于获取 AWS 凭据提供商的控制器服务
桶	要与之交互的 S3 桶
通信超时	超时之前为与 AWS 建立连接或从 AWS 接收数据而等待的时间。
端点替换 URL	要使用的端点 URL 而不是 AWS 默认端点，包括架构、主机、端口和路径。AWS 库会根据 AWS 区域选择端点 URL，但此属性会替换所选端点 URL，允许与其他与 S3 兼容的端点一起使用。
对象键	要使用的 S3 对象键。这类似于传统文件系统的文件名。
区域	要连接的 AWS 区域。
SSL Context Service	指定可选的 SSL Context Service，如果提供该服务，将用于创建连接
签名器替换	默认情况下，AWS S3 库使用签名版本 4，但此属性允许您指定版本 2 签名器以支持较早的 S3 兼容服务，甚至可以插入自己的自定义签名器实现。
版本	要下载的对象的版本
custom-signer-class-name	自定义签名器类的完全限定类名。签名器必须实现 com.amazonaws.auth.Signer 接口。
custom-signer-module-location	以逗号分隔的文件和/或目录路径列表，这些文件和/或目录包含自定义签名器的 JAR 文件及其依赖关系（如果有）。
encryption-service	指定用于配置请求的加密服务控制器。PutS3Object：为了向后兼容，当设置“服务器端加密”时，将忽略此值。FetchS3Object：仅在服务器端客户密钥、客户端 KMS 和客户端客户密钥加密的情况下才需要进行配置。
proxy-configuration-service	指定代理配置控制器服务来代理网络请求。
range-length	要从对象下载的字节数，从 Range Start 开始。空值或超出对象末端的值将读取到对象的末尾。
range-start	读取对象的起始字节位置。空值或零值将从对象的开头开始读取。
requester-pays	如果为 true，则表示请求者同意支付与从 S3 桶检索对象相关的任何费用。这会将“x-amz-request-payer”标头设置为“requester”。

关系¶

名称	描述
failure	如果处理器无法处理给定的 FlowFile，则会将其路由到此关系。
success	FlowFiles 成功处理后，将路由到此关系。

写入属性¶

名称	描述
s3.url	可用于访问 S3 对象的 URL
s3.bucket	S3 桶的名称
path	文件的路径
absolute.path	文件的路径
filename	文件的名称
hash.value	文件的 MD5 总和
hash.algorithm	MD5
mime.type	如果 S3 提供内容类型/MIME 类型，则此属性将保存该文件
s3.etag	可以用来查看文件是否已更改的 ETag
s3.exception	处理器执行期间引发的异常的类名
s3.additionalDetails	S3 提供的失败操作的详细信息
s3.statusCode	失败操作的 HTTP 错误代码（如果有）
s3.errorCode	失败操作的 S3 昵称
s3.errorMessage	失败操作的 S3 异常消息
s3.expirationTime	如果文件有过期日期，则将设置此属性，包含自时间纪元（采用 UTC 时间）以来的毫秒数
s3.expirationTimeRuleId	表明此对象过期时间的规则的 ID
s3.sseAlgorithm	对象的服务器端加密算法
s3.version	S3 对象的版本
s3.encryptionStrategy	用于存储 S3 对象的加密策略的名称（如果已加密）

用例¶

从 S3 提取特定文件

涉及其他组件的用例¶

检索 S3 桶中的所有文件

仅从 S3 检索符合某些指定条件的文件

在新文件到达 S3 桶时对其进行检索

另请参阅¶