2 个存储帐户之间的 Azure CloudBlob StartCopy 方法 - 404 错误

Posted 2023-03-25

【中文标题】2 个存储帐户之间的 Azure CloudBlob StartCopy 方法 - 404 错误

【英文标题】：Azure CloudBlob StartCopy method between 2 storage accounts - 404 Error

【发布时间】：2021-04-16 22:33:41

【问题描述】：

所以我一直在学习https://docs.microsoft.com/en-us/learn/modules/copy-blobs-from-command-line-and-code/7-move-blobs-using-net-storage-client 教程并尝试将 blob 从一个存储帐户复制到另一个存储帐户（这两个帐户都在我的计算机上本地运行，作为通过 Azurite 的本地开发环境模拟器）。正在尝试了解有关使用 C# 的 Azure SDK 的更多信息。

我可以毫无问题地连接到这两个帐户，并且我的程序到目前为止可以上传/下载 blob 文件并创建容器。但是，似乎当我在 Visual Studio 中执行我的程序时，它会到达包含 StartCopy（或 StartCopyAsync）的行并引发 Web 异常：404 Not Found 错误。在异常中，当我展开 RequestInformation 时，ErrorCode 为“ContainerNotFound”，HttpStatusMessage 为“指定的容器不存在”。不知道为什么我会收到这些消息，因为我可以验证容器是否存在并且只是为了它，我预先使用文件和容器预先填充了源和目标 azure 存储，以查看发生了什么。不幸的是，同样的错误。然后我尝试将容器和 blob 的公共访问级别设置为公共的。不幸的是，这也是不行的。应该发生的是，它应该只是将 blob 文件从源复制到目标，然后就结束了。

起初，我想也许我没有配置正确的东西，但似乎不是这样，或者至少我是这么认为的？然后我尝试通过 Microsoft 将 1 个本地存储帐户模拟器之间的文件复制到实际的在线 Azure 存储（学生）帐户，但效果不佳。我能够在同一个帐户中的 2 个容器之间进行复制，因此这部分不是问题，但尝试在 2 个不同帐户之间进行复制让我“头疼了几个小时”。

代码应该与本文第一个链接中提到的 Microsoft 教程中的代码非常相似。不完全确定为什么我不断收到此 404 错误。暂时关闭我的防火墙，以防万一造成麻烦，但这并没有什么不同。我还尝试了其他人的代码（尽管必须稍微修改它才能在我的情况下工作），但我仍然遇到同样的问题。所以，也许我的设置有问题？

在我的 Azurite 本地服务器的控制台中，我可以看到服务器 2（复制过程的目标服务器）有：

本地源服务器

127.0.0.1 - - [11/Jan/2021:23:28:39 +0000] "PUT /devstoreaccount1/source/NewBlob HTTP/1.1" 201 -
127.0.0.1 - - [11/Jan/2021:23:28:39 +0000] "HEAD /devstoreaccount1/source/NewBlob HTTP/1.1" 200 0

本地目标服务器

127.0.0.1 - - [11/Jan/2021:23:28:39 +0000] "PUT /devstoreaccount1/destination/NewBlob HTTP/1.1" 404 -

代码：

        static async Task Main(string[] args)
        
            string storageKey = "AccountName=devstoreaccount1;AccountKey=<MY_ACCOUNT_KEY_GOES_HERE>;DefaultEndpointsProtocol=http;BlobEndpoint=http://127.0.0.1:10000/devstoreaccount1;QueueEndpoint=http://127.0.0.1:10001/devstoreaccount1;";

            string storageKey2 = "AccountName=devstoreaccount1;AccountKey=<MY_ACCOUNT_KEY_GOES_HERE>;DefaultEndpointsProtocol=http;BlobEndpoint=http://127.0.0.1:10100/devstoreaccount1;QueueEndpoint=http://127.0.0.1:10101/devstoreaccount1;";

            // Retrieve storage account from connection string.
            CloudStorageAccount storageAccount = CloudStorageAccount.Parse(storageKey);
            CloudStorageAccount storageAccount2 = CloudStorageAccount.Parse(storageKey2);

            //create client from storage account
            CloudBlobClient sourceClient = storageAccount.CreateCloudBlobClient();
            CloudBlobClient sourceClient2 = storageAccount2.CreateCloudBlobClient();

            //declare source container and create if doesn't exist
            CloudBlobContainer sourceContainer = sourceClient.GetContainerReference("source");
            await sourceContainer.CreateIfNotExistsAsync();

            //upload local file to azurite 1
            CloudBlockBlob uploadBlob = sourceContainer.GetBlockBlobReference("NewBlob");
            await uploadBlob.UploadFromFileAsync("NewBlob");

            // designate source blob as the new uploaded file
            ICloudBlob sourceBlob = await sourceContainer.GetBlobReferenceFromServerAsync("NewBlob");

            //declare destination container and create it if it doesn't exist
            CloudBlobContainer destBlobContainer = sourceClient2.GetContainerReference("destination");
            await destBlobContainer.CreateIfNotExistsAsync();

            //start copy process of blob between 2 servers
            CloudBlockBlob destBlob = destBlobContainer.GetBlockBlobReference(sourceBlob.Name);
            await destBlob.StartCopyAsync(new Uri(GetSharedAccessUri(sourceBlob.Name, sourceContainer)));

            // Display the status of the blob as it is copied
            ICloudBlob destBlobRef = await destBlobContainer.GetBlobReferenceFromServerAsync(destBlob.Name);
            while (destBlobRef.CopyState.Status == CopyStatus.Pending)
            
                Console.WriteLine($"Blob: destBlobRef.Name, Copied: destBlobRef.CopyState.BytesCopied ?? 0 of  destBlobRef.CopyState.TotalBytes ?? 0");
                await Task.Delay(500);
                destBlobRef = await destBlobContainer.GetBlobReferenceFromServerAsync(destBlobRef.Name);
            
            Console.WriteLine($"Blob: destBlob.Name Complete");

        

        // Create a SAS token for the source blob, to enable it to be read by the StartCopyAsync method
        private static string GetSharedAccessUri(string blobName, CloudBlobContainer container)
        
            DateTime toDateTime = DateTime.Now.AddMinutes(60);

            SharedAccessBlobPolicy policy = new SharedAccessBlobPolicy
            
                Permissions = SharedAccessBlobPermissions.Read,
                SharedAccessStartTime = null,
                SharedAccessExpiryTime = new DateTimeOffset(toDateTime)
            ;

            CloudBlockBlob blob = container.GetBlockBlobReference(blobName);
            string sas = blob.GetSharedAccessSignature(policy);

            return blob.Uri.AbsoluteUri + sas;
        


Thanks in advance!

【问题讨论】：

我在本地和 Azure 云上测试了我这边的代码，除此之外，一切都对我有用。我唯一修改的是更改代码：await uploadBlob.UploadFromFileAsync("NewBlob");等待 uploadBlob.UploadFromFileAsync("");

感谢您的检查。也许我会做的是尝试在另一台计算机上测试它，看看是否会有所作为。

欢迎，如果您有任何其他问题，请告诉我。

嗨@Rocketboy235，怎么样？你的问题解决了吗？

不幸的是仍未解决，所以我可能不得不做一些试验和更多的试验和错误

【参考方案1】：

您上面的代码可以在 Azure Cloud 上完美运行，我还在本地基于 Storage Emulator 测试了您的代码。根据你的代码逻辑查不出根本原因，没关系。

无论如何，您的问题似乎已经在 Azure Cloud 上解决了，我认为这是由于本地存储模拟器的一些错误。