PutS3Object 2025.10.2.19¶
捆绑包¶
org.apache.nifi | nifi-aws-nar
描述¶
将 FlowFile 的内容作为 S3 对象写入 Amazon S3 桶中。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
AWS 凭据提供商服务 |
用于获取 AWS 凭据提供商的控制器服务 |
桶 |
要与之交互的 S3 桶 |
Cache Control |
设置缓存控制 HTTP 标头，指示关联对象的缓存指令。多个指令以逗号分隔。 |
Canned ACL |
对象的 Amazon 预定义 ACL，具体为以下其一：BucketOwnerFullControl、BucketOwnerRead、LogDeliveryWrite、AuthenticatedRead、PublicReadWrite、PublicRead、Private；如果指定了其他 ACL/权限/所有者属性，则此属性将被忽略 |
通信超时 |
超时之前为与 AWS 建立连接或从 AWS 接收数据而等待的时间。 |
Content Disposition |
Sets the Content-Disposition HTTP header indicating if the content is intended to be displayed inline or should be downloaded. Possible values are 'inline' or 'attachment'. If this property is not specified, object 's content-disposition will be set to filename. When' attachment 'is selected,'; filename='plus object key are automatically appended to form final value' attachment; filename="filename.jpg"'. |
内容类型 |
Sets the Content-Type HTTP header indicating the type of content stored in the associated object. The value of this header is a standard MIME type. AWS S3 Java client will attempt to determine the correct content type if one hasn't been set yet. Users are responsible for ensuring a suitable content type is set when uploading streams. If no content type is provided and cannot be determined by the filename, the default content type "application/octet-stream" will be used. |
Custom Signer Class Name |
Fully qualified class name of the custom signer class. The signer must implement com.amazonaws.auth. Signer interface. |
Custom Signer Module Location |
以逗号分隔的文件和/或目录路径列表，这些文件和/或目录包含自定义签名器的 JAR 文件及其依赖关系（如果有）。 |
Encryption Service |
指定用于配置请求的加密服务控制器。PutS3Object：为了向后兼容，当设置“服务器端加密”时，将忽略此值。FetchS3Object：仅在服务器端客户密钥、客户端 KMS 和客户端客户密钥加密的情况下才需要进行配置。 |
端点替换 URL |
要使用的端点 URL 而不是 AWS 默认端点，包括架构、主机、端口和路径。AWS 库会根据 AWS 区域选择端点 URL，但此属性会替换所选端点 URL，允许与其他与 S3 兼容的端点一起使用。 |
Expiration Time Rule |
|
文件资源服务 |
文件资源服务提供对要传输的本地资源的访问权限 |
FullControl 用户列表 |
以逗号分隔的 Amazon 用户 ID 或电子邮件地址列表，用于指定谁应该拥有对象的完全控制权 |
Multipart Part Size |
指定使用 PutS3Multipart Upload API 时使用的分段大小。在上传过程中，FlowFile 将被分成这样大小的块，但是最后发送的分段可能会更小，因为它没有填充。有效范围为 50MB 到 5GB。 |
Multipart Threshold |
Specifies the file size threshold for switch from the PutS3Object API to the PutS3MultipartUpload API. Flow files bigger than this limit will be sent using the stateful multipart process. The valid range is 50MB to 5GB. |
Multipart Upload AgeOff Interval |
Specifies the interval at which existing multipart uploads in AWS S3 will be evaluated for ageoff. When processor is triggered it will initiate the ageoff evaluation if this interval has been exceeded. |
Multipart Upload Max Age Threshold |
Specifies the maximum age for existing multipart uploads in AWS S3. When the ageoff process occurs, any upload older than this threshold will be aborted. |
对象键 |
要使用的 S3 对象键。这类似于传统文件系统的文件名。 |
Object Tags Prefix |
Specifies the prefix which would be scanned against the incoming FlowFile 's attributes and the matching attribute's name and value would be considered as the outgoing S3 object 's Tag name and Tag value respectively. For Ex: If the incoming FlowFile carries the attributes tagS3country, tagS3PII, the tag prefix to be specified would be' tagS3' |
所有者 |
供对象所有者使用的 Amazon ID |
读取 ACL 用户列表 |
以逗号分隔的 Amazon 用户 ID 或电子邮件地址列表，用于指定谁应有权读取对象的访问控制列表 |
读取权限用户列表 |
以逗号分隔的 Amazon 用户 ID 或电子邮件地址列表，用于指定谁应该拥有对象的读取权限 |
区域 |
要连接的 AWS 区域。 |
Remove Tag Prefix |
如果设置为“True”，则为“Object Tags Prefix”提供的值将从属性中移除，然后将其视为标签名称。例如：如果传入的 FlowFile 带有 tagS3country、tagS3PII 属性，并且前缀设置为“tagS3”，则相应的标签值将为“国家”和“PII” |
资源传输来源 |
要传输的内容的来源 |
SSL Context Service |
指定可选的 SSL Context Service，如果提供该服务，将用于创建连接 |
Server Side Encryption |
指定用于服务器端加密的算法。 |
签名器替换 |
默认情况下，AWS S3 库使用签名版本 4，但此属性允许您指定版本 2 签名器以支持较早的 S3 兼容服务，甚至可以插入自己的自定义签名器实现。 |
Storage Class |
|
Temporary Directory Multipart State |
对于分段上传，处理器将在该目录中本地保存跟踪上传 ID 和已上传分段的状态，这两个部分都必须提供才能完成上传。 |
Use Chunked Encoding |
启用/禁用上传请求的分块编码。仅当您的端点不支持分块上传时，才将其设置为 false。 |
Use Path Style Access |
通过将此属性设置为 true，可以强制执行路径式访问。如果端点不支持虚拟托管式请求，仅支持路径式请求，则将其设置为 true。 |
写入 ACL 用户列表 |
以逗号分隔的 Amazon 用户 ID 或电子邮件地址列表，用于指定谁应有权更改对象的访问控制列表 |
写入权限用户列表 |
以逗号分隔的 Amazon 用户 ID 或电子邮件地址列表，用于指定谁应该拥有对象的写入权限 |
proxy-configuration-service |
指定代理配置控制器服务来代理网络请求。 |
关系¶
名称 |
描述 |
|---|---|
failure |
如果处理器无法处理给定的 FlowFile，则会将其路由到此关系。 |
success |
FlowFiles 成功处理后，将路由到此关系。 |
写入属性¶
名称 |
描述 |
|---|---|
s3.url |
可用于访问 S3 对象的 URL |
s3.bucket |
将对象放入 S3 的 S3 桶 |
s3.key |
将对象放入 S3 时的 S3 密钥 |
s3.contenttype |
放入 S3 的 S3 对象的 S3 内容类型 |
s3.version |
放入 S3 的 S3 对象的版本 |
s3.exception |
处理器执行期间引发的异常的类名 |
s3.additionalDetails |
S3 提供的失败操作的详细信息 |
s3.statusCode |
失败操作的 HTTP 错误代码（如果有） |
s3.errorCode |
失败操作的 S3 昵称 |
s3.errorMessage |
失败操作的 S3 异常消息 |
s3.etag |
S3 对象的 ETag |
s3.contentdisposition |
放入 S3 的 S3 对象的内容处置 |
s3.cachecontrol |
S3 对象的缓存控制标头 |
s3.uploadId |
用于将对象上传到 S3 的 uploadId |
s3.expiration |
S3 对象的过期日期（如果已设置）的人类可读形式 |
s3.sseAlgorithm |
对象的服务器端加密算法 |
s3.usermetadata |
S3 对象的用户元数据的人类可读形式（如果已设置） |
s3.encryptionStrategy |
加密策略的名称（如果已设置） |