使用Java V12 SDK在Azure Blob存储中复制Blob [英] Copy Blob in Azure Blob Storage using Java v12 SDK

问题描述

我的应用程序在Kubernetes集群中，我使用Java v12 SDK与Blob Storage交互。若要针对Blob存储进行授权，我使用的是托管标识。

我的应用程序需要复制一个容器内的blob。我没有找到任何有关如何使用SDK进行复制的recommendations or examples。

我认为以下方法在我使用模拟器时有效

copyBlobClient.copyFromUrl(sourceBlobClient.getBlobUrl());

但是，当在群集中执行此操作时，我收到以下错误

<Error>
   <Code>CannotVerifyCopySource</Code>
   <Message>The specified resource does not exist. RequestId: __ Time: __ </Message>
</Error> 

消息显示"；资源不存在，但blob显然在那里。不过，我的容器具有私有访问权限。

现在，当我将公共访问级别更改为&blob；(仅适用于blob的匿名读取访问)"；时，一切工作正常。但是，我不能接受公共访问。

主要问题-使用Java V12 SDK实现复制blob的正确方式是什么。

在我的情况下可能会遗漏或配置错误的内容？

最后一个是错误消息本身。有一部分内容是&CannotVerifyCopySource"；，它可以帮助您理解Access有问题，但消息部分显然具有误导性。难道不应该更明确地说明错误吗？

推荐答案

如果要使用Azure Java SDK复制带有Azure MSI的blob，请参阅以下详细信息

• 在存储帐户之间复制Blob

如果您使用Azure MSI在存储帐户之间复制Blob。我们应该执行以下操作

1. 将AzureStorage Blob Data Reader分配给源容器中的MSI

2. 将AzureStorage Blob Data Contributor分配给目标容器中的MSI。此外，当我们复制BLOB时，我们需要写入权限才能将内容写入BLOB

3. 为Blob生成SAS令牌。如果源Blob是公共的，则可以直接使用没有SAS令牌的源Blob URL。

例如

 try {
            BlobServiceClient blobServiceClient = new BlobServiceClientBuilder()
                    .endpoint("https://<>.blob.core.windows.net/" )
                    .credential(new DefaultAzureCredentialBuilder().build())
                    .buildClient();
            // get User Delegation Key
            OffsetDateTime delegationKeyStartTime = OffsetDateTime.now();
            OffsetDateTime delegationKeyExpiryTime = OffsetDateTime.now().plusDays(7);
            UserDelegationKey key =blobServiceClient.getUserDelegationKey(delegationKeyStartTime,delegationKeyExpiryTime);

            BlobContainerClient sourceContainerClient = blobServiceClient.getBlobContainerClient("test");
            BlobClient sourceBlob = sourceContainerClient.getBlobClient("test.mp3");
            // generate sas token
            OffsetDateTime expiryTime = OffsetDateTime.now().plusDays(1);
            BlobSasPermission permission = new BlobSasPermission().setReadPermission(true);

            BlobServiceSasSignatureValues myValues = new BlobServiceSasSignatureValues(expiryTime, permission)
                    .setStartTime(OffsetDateTime.now());
            String sas =sourceBlob.generateUserDelegationSas(myValues,key);

            // copy
            BlobServiceClient desServiceClient = new BlobServiceClientBuilder()
                    .endpoint("https://<>.blob.core.windows.net/" )
                    .credential(new DefaultAzureCredentialBuilder().build())
                    .buildClient();
            BlobContainerClient desContainerClient = blobServiceClient.getBlobContainerClient("test");
            String res =desContainerClient.getBlobClient("test.mp3")
                    .copyFromUrl(sourceBlob.getBlobUrl()+"?"+sas);
            System.out.println(res);
        } catch (Exception e) {
            e.printStackTrace();
        }

• 复制到同一帐户

如果您使用Azure MSI复制同一存储帐户中的Blob，我建议您将Storage Blob Data Contributor分配给存储帐户中的MSI。然后我们可以使用copyFromUrl方法执行复制操作。

例如

a.将Storage Blob Data Contributor分配给帐户级的MSI

B.代码

  try {
            BlobServiceClient blobServiceClient = new BlobServiceClientBuilder()
                    .endpoint("https://<>.blob.core.windows.net/" )
                    .credential(new DefaultAzureCredentialBuilder().build())
                    .buildClient();

            BlobContainerClient sourceContainerClient = blobServiceClient.getBlobContainerClient("test");
            BlobClient sourceBlob = sourceContainerClient.getBlobClient("test.mp3");

            BlobContainerClient desContainerClient = blobServiceClient.getBlobContainerClient("output");
            String res =desContainerClient.getBlobClient("test.mp3")
                    .copyFromUrl(sourceBlob.getBlobUrl());
            System.out.println(res);
        } catch (Exception e) {
            e.printStackTrace();
        }

详情请参考here和here

这篇关于使用Java V12 SDK在Azure Blob存储中复制Blob的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！