CopyAzureBlobStorage_v12 2025.5.31.15¶
捆绑包¶
org.apache.nifi | nifi-azure-nar
描述¶
将 Azure Blob 存储中的 blob 从一个账户/容器复制到另一个账户/容器。该处理器使用 Azure Blob 存储客户端库 v12。
输入要求¶
REQUIRED
支持敏感的动态属性¶
false
属性¶
属性 |
描述 |
|---|---|
源 Blob 名称 |
源 blob 的全名 |
源容器名称 |
将要复制的 Azure 存储容器的名称 |
源存储凭据 |
凭据服务用于获取 Azure Blob 存储凭据以读取源 Blob 信息 |
blob-name |
如果未指定，目标 blob 的全名默认为源 Blob 名称 |
conflict-resolution-strategy |
指定在冲突时是否替换现有 blob 的内容。 |
container-name |
如果未指定，Azure 存储容器目标的名称默认为源容器名称 |
create-container |
指定是否检查容器的存在情况，如果不存在，是否自动创建容器。需要具备列出容器的权限。如果为 false，则不进行此检查，但是如果容器不存在，则 Put 操作将失败。 |
proxy-configuration-service |
指定代理配置控制器服务来代理网络请求。在 SOCKS 的情况下，无法保证处理器会使用所选 SOCKS 版本。 |
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.error.code |
Blob 操作期间报告的错误代码 |
azure.ignored |
当冲突解决策略为“ignore”时，此属性将为 true/false，具体取决于是否忽略了 Blob。 |