PutAzureBlobStorage_v12

文档中心 › 组件索引 › PutAzureBlobStorage_v12

PutAzureBlobStorage_v12 Processor

类型全限定名:cn.org.acal.lynxus.processors.azure.storage.PutAzureBlobStorage_v12

所属 Bundle:cn.org.acal.lynxus:lynxus-azure-nar:2.11.8

描述

将内容放入 Azure Blob 存储上的 Blob 中。 该处理器使用 Azure Blob 存储客户端库 v12。

标签

azuremicrosoftcloudstorageblob

属性

下表中,加粗的属性为必填项;其余为可选项。表格同时标注默认值、是否支持表达式语言,以及是否为敏感属性(值会被加密)。

名称默认值可选值描述
Storage Credentials控制器服务 API:
AzureStorageCredentialsService_v12
cn.org.acal.lynxus-lynxus-azure-services-api-nar-2.11.8
用于获取 Azure Blob 存储凭据的Controller Service。
Container NameAzure 存储容器的名称。 对于 PutAzureBlobStorage 处理器,如果容器不存在,则可以创建容器。
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
Create Containerfalse
  • true
  • false
指定是否检查容器是否存在,并在不存在时自动创建。需要具有列出容器的权限。如果为 false,则不进行此检查,但如果容器不存在,Put 操作将失败。
Conflict Resolution StrategyFAIL_RESOLUTION
  • fail — 如果 blob 已存在则失败
  • ignore — 如果 blob 已存在则忽略;'azure.error' 属性将被设为值 'BLOB_ALREADY_EXISTS'
  • replace — 如果 blob 已存在,则替换 blob 内容
指定现有 blob 是否在发生冲突时替换其内容。
Blob NameBlob 的全名
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
内容 MD5内容的 MD5 哈希值。设置此属性后,Azure 将根据此校验和验证上传的内容,如果不匹配则拒绝上传。这在传输过程中提供数据完整性验证。该值可以以十六进制格式(32 个字符)或 Base64 格式提供。MD5 校验和必须在调用此处理器之前计算; 使用 CryptographicHashContent 处理器并选择算法 MD5 将结果存储为 FlowFile 属性,然后使用表达式语言引用它(例如 ${content_MD5})。
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
Blob Tag Prefix指定将与传入 FlowFile 的属性进行扫描的前缀,匹配的属性名称和值将分别被视为传出 Azure Blob 的标签名称和标签值。
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
Remove Tag Prefixfalse
  • 是
  • 否
如果设置为 'True',为 'Blob Tag Prefix' 提供的值将从属性中移除,然后被视为标签名称。 例如:如果传入 FlowFile 携带属性 tagAzurecountry、tagAzurePII, 前缀设置为 'tagAzure',则对应的标签名称为 'country' 和 'PII'。
Resource Transfer SourceFLOWFILE_CONTENT
  • FlowFile Content — 传入 FlowFile 的内容提供传输源
  • File Resource Service — 文件资源服务提供传输源
待传输内容的来源
File Resource Service控制器服务 API:
FileResourceService
cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8
文件资源服务提供对要传输的本地资源的访问
Proxy Configuration Service控制器服务 API:
ProxyConfigurationService
cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8
指定代理配置 Controller Service 来代理网络请求。 对于 SOCKS,不保证处理器一定会使用所选的 SOCKS 版本。
Client-Side Encryption Key TypeNONE
  • NONE — 禁用客户端加密(Client-Side Encryption)
  • LOCAL — 使用本地密钥启用客户端加密(Client-Side Encryption)
指定用于客户端加密的密钥类型。
Client-Side Encryption Key ID指定用于客户端加密的密钥的 ID。
支持表达式语言:是(使用 FlowFile 属性与环境/系统变量求值)
Client-Side Encryption Local Key当使用本地客户端加密时,这是原始密钥,以十六进制编码
敏感属性:是

动态属性

动态属性允许用户自定义属性的名称与值。

名称值描述
要添加到 blob 的用户定义元数据字段的名称要添加到 blob 的用户定义元数据字段的值允许将用户定义的元数据作为键/值对添加到 Blob

关系 (Relationships)

名称描述自动终止
failure不成功的操作将转入失败关系。否
success所有成功处理的 FlowFiles 都会路由到此关系否

写入的 FlowFile 属性

名称描述
azure.containerAzure Blob 存储容器的名称
azure.blobnameAzure Blob 存储上的 Blob 名称
azure.primaryUriBlob 的主要位置
azure.etagBlob 的 ETag
azure.blobtypeBlob 的类型(BlockBlob、PageBlob 或 AppendBlob)
mime.type内容的 MIME 类型
lang内容的语言代码
azure.timestampBlob 的时间戳
azure.lengthBlob 的长度
azure.error.codeBlob 操作期间报告的错误代码
azure.ignored当冲突解决策略为 'ignore' 时,此属性将为 true/false,表示 Blob 是否被忽略。
azure.usermetadataBlob 的用户元数据的可读形式(如果已设置)

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

输入要求

该组件要求有传入连接。