FetchAzureBlobStorage_v12 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-azure-nar
描述¶
从 Azure Blob 存储中检索指定的 blob 并将其内容写入到 FlowFile 的内容中。该处理器使用 Azure Blob 存储客户端库 v12。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
客户端加密密钥 ID |
指定用于客户端加密的密钥 ID。 |
客户端加密密钥类型 |
指定用于客户端加密的密钥类型。 |
客户端加密本地密钥 |
使用本地客户端加密时，这是原始密钥，以十六进制编码 |
blob-name |
blob 的全名 |
container-name |
Azure 存储容器的名称。对于 PutAzureBlobStorage 处理器，如果容器不存在，则可以创建容器。 |
proxy-configuration-service |
指定代理配置控制器服务来代理网络请求。在 SOCKS 的情况下，无法保证处理器会使用所选 SOCKS 版本。 |
range-length |
要从 blob 下载的字节数（从 Range Start 开始）。对于空值或超出 blob 末尾的值，将读取到 blob 的末尾。 |
range-start |
读取 blob 的起始字节位置。对于空值或零值，将从 blob 的开头开始读取。 |
storage-credentials-service |
用于获取 Azure Blob 存储凭据的控制器服务。 |
关系¶
名称 |
描述 |
|---|---|
failure |
不成功的操作将转移到 failure 关系中。 |
success |
所有成功处理的 FlowFiles 都将路由到此关系 |
写入属性¶
名称 |
描述 |
|---|---|
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 的长度 |
涉及其他组件的用例¶
检索 Azure Blob 存储容器中的所有文件 |