FetchAzureBlobStorage_v12

FetchAzureBlobStorage_v12 Processor

类型全限定名：cn.org.acal.lynxus.processors.azure.storage.FetchAzureBlobStorage_v12

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

描述

从 Azure Blob 存储检索指定的 blob，并将其内容写入 FlowFile 的内容。该处理器使用 Azure Blob 存储客户端库 v12。

多处理器协同场景

检索 Azure Blob Storage 容器中的所有文件

azureblobstoragestateretrievefetchallstream

配置 ListAzureBlobStorage_v12：

"Container Name" 属性应设置为文件所在 Blob Storage 容器的名称。     如果要构建的流程将在其他地方重用，最好通过将其设置为类似 `#{AZURE_CONTAINER}` 的值来参数化此属性。

"Storage Credentials" 属性应指定一个 AzureStorageCredentialsService_v12 实例，以便为访问存储容器提供凭据。

然后将此处理器的 'success' Relationship 连接到 FetchAzureBlobStorage_v12。

配置 FetchAzureBlobStorage_v12：

"Container Name" = "${azure.container}"
"Blob Name" = "${azure.blobname}"

"Storage Credentials" 属性应指定一个 AzureStorageCredentialsService_v12 实例，以便为访问存储容器提供凭据。

属性

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

名称	默认值	可选值	描述
Storage Credentials		控制器服务 API： `AzureStorageCredentialsService_v12` cn.org.acal.lynxus-lynxus-azure-services-api-nar-2.11.8	用于获取 Azure Blob 存储凭据的Controller Service。
Container Name	`${azure.container}`		Azure 存储容器的名称。对于 PutAzureBlobStorage 处理器，如果容器不存在，则可以创建容器。支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Blob Name	`${azure.blobname}`		Blob 的全名支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Range Start			开始从 Blob 读取的字节位置。空值或零值将从 Blob 开头开始读取。支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Range Length			从 Blob 下载字节数，从范围起始位置开始。空值或超出 Blob 末尾的值将读取到 Blob 末尾。支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
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 Type	`NONE`	NONE — 禁用客户端加密（Client-Side Encryption） LOCAL — 使用本地密钥启用客户端加密（Client-Side Encryption）	指定用于客户端加密的密钥类型。
Client-Side Encryption Key ID			指定用于客户端加密的密钥的 ID。支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Client-Side Encryption Local Key			当使用本地客户端加密时，这是原始密钥，以十六进制编码敏感属性：是

关系 (Relationships)

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

写入的 FlowFile 属性

名称	描述
`azure.container`	Azure Blob 存储容器的名称
`azure.blobname`	Azure Blob 存储上的 Blob 名称
`azure.primaryUri`	Blob 的主要位置
`azure.etag`	Blob 的 ETag
`azure.blobtype`	Blob 的类型（BlockBlob、PageBlob 或 AppendBlob）
`mime.type`	内容的 MIME 类型
`lang`	内容的语言代码
`azure.timestamp`	Blob 的时间戳
`azure.length`	Blob 的长度

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

输入要求

该组件要求有传入连接。