FetchGCSObject 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-gcp-nar
描述¶
从 Google Cloud Bucket 中提取文件。专为与 ListGCSBucket 配合使用而设计。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
GCP 凭据提供商服务 |
用于获取 Google Cloud Platform 凭据的控制器服务。 |
gcp-project-id |
Google Cloud 项目 ID |
gcp-retry-count |
路由到“failure”关系之前应尝试重试多少次。 |
gcs-bucket |
对象的桶。 |
gcs-generation |
生成要下载的对象。如果未设置，则将下载最新一代版本。 |
gcs-key |
对象名称。 |
gcs-object-range-length |
要从对象下载的字节数，从 Range Start 开始。空值或超出对象末端的值将读取到对象的末尾。 |
gcs-object-range-start |
读取对象的起始字节位置。空值或零值将从对象的开头开始读取。 |
gcs-server-side-encryption-key |
对象已加密的 AES256 键（以 base64 编码）。 |
proxy-configuration-service |
指定代理配置控制器服务来代理网络请求。 |
storage-api-url |
替换默认存储 URL。如 Google 有关专用服务连接的文档所述，配置替代存储 API URL 还可替换请求中的 HTTP 主机标头。 |
关系¶
名称 |
描述 |
|---|---|
failure |
如果 Google Cloud Storage 操作失败，则将 FlowFiles 路由到此关系。 |
success |
Google Cloud Storage 操作成功后，将 FlowFiles 路由到此关系。 |
写入属性¶
名称 |
描述 |
|---|---|
filename |
文件名，尽可能从“Content-Disposition”响应标头中解析出来 |
gcs.bucket |
对象的桶。 |
gcs.key |
对象名称。 |
gcs.size |
对象的大小。 |
gcs.cache.control |
对象的数据缓存控制。 |
gcs.component.count |
构成对象的组件数量。 |
gcs.content.disposition |
对象的数据内容处置。 |
gcs.content.encoding |
对象的内容编码。 |
gcs.content.language |
对象的内容语言。 |
mime.type |
对象的 MIME/内容类型 |
gcs.crc32c |
对象数据的 CRC32C 校验和，以 base64 为编码单位，按大端顺序排列。 |
gcs.create.time |
对象的创建时间（毫秒） |
gcs.update.time |
对象的最后修改时间（毫秒） |
gcs.encryption.algorithm |
用于加密对象的算法。 |
gcs.encryption.sha256 |
用于加密对象的键的 SHA256 哈希值 |
gcs.etag |
对象的 HTTP 1.1 实体标签。 |
gcs.generated.id |
为对象生成的服务 |
gcs.generation |
对象的数据生成。 |
gcs.md5 |
对象数据的 MD5 哈希值，以 base64 编码。 |
gcs.media.link |
对象的媒体下载链接。 |
gcs.metageneration |
对象的元数据版本号。 |
gcs.owner |
对象的所有者（上传者）。 |
gcs.owner.type |
对象上传者的 ACL 实体类型。 |
gcs.acl.owner |
具有对象所有者访问权限的 ACL 实体列表，以逗号分隔。实体将是电子邮件地址、域名或项目 IDs。 |
gcs.acl.writer |
具有对象写入权限的 ACL 实体列表，以逗号分隔。实体将是电子邮件地址、域名或项目 IDs。 |
gcs.acl.reader |
具有对象读取权限的 ACL 实体列表，以逗号分隔。实体将是电子邮件地址、域名或项目 IDs。 |
gcs.uri |
作为字符串的对象 URI。 |
涉及其他组件的用例¶
检索 Google Compute Storage (GCS) 桶中的所有文件 |