重命名 Azure 容器时出现 System.InvalidCastException

Question

我正在尝试重命名 azure blob 存储中的容器。我能够成功重命名容器。但我注意到在某些情况下，在某些过程中。我遇到了一些错误。

这是错误信息。

System.InvalidCastException: '无法转换类型的对象 'Microsoft.WindowsAzure.Storage.Blob.CloudBlobDirectory' 键入 'Microsoft.WindowsAzure.Storage.Blob.CloudBlockBlob'。'

下面是我的代码。

string ContainerName = "old-container-name";
    string NewContainerName = "new-container-name";
    CloudStorageAccount storageAccount = CloudStorageAccount.Parse(CloudConfigurationManager.GetSetting("StorageConnectionString"));
    CloudBlobClient blobClient = storageAccount.CreateCloudBlobClient();
    CloudBlobContainer container = blobClient.GetContainerReference(ContainerName);
    CloudBlobContainer destcontainer = blobClient.GetContainerReference(NewContainerName);
    destcontainer.CreateIfNotExists(BlobContainerPublicAccessType.Blob);
    IEnumerable<IListBlobItem> IE = container.ListBlobs(blobListingDetails: BlobListingDetails.Metadata);
    foreach (IListBlobItem item in IE)
    {
        CloudBlockBlob blob = (CloudBlockBlob)item;
        CloudBlockBlob destBlob = destcontainer.GetBlockBlobReference(blob.Name);
        destBlob.StartCopyAsync(new Uri(GetSharedAccessUri(blob.Name, container)));
    }

我在这一行收到错误：

CloudBlockBlob blob = (CloudBlockBlob)item;

你们有解决这个问题的办法吗？有关如何解决此问题的任何提示？

Answer 1

您收到此错误的原因是您列出 Blob 的方式。

IEnumerable<IListBlobItem> IE = container.ListBlobs(blobListingDetails: BlobListingDetails.Metadata);

上面的代码行将列出 blob 和虚拟文件夹。虚拟文件夹由CloudBlobDirectory 表示。由于您尝试将 CloudBlockBlob 类型的对象转换为 CloudBlobDirectory，因此您会遇到此异常。

要列出 blob 容器中的所有 blob，请使用以下 ListBlobs 方法的覆盖：https://docs.microsoft.com/en-us/dotnet/api/microsoft.azure.storage.blob.cloudblobcontainer.listblobs?view=azure-dotnet-legacy。

您需要为useFlatBlobListing 参数传递true。然后它将只返回 blob 而不是虚拟文件夹。

Answer 2

• 在投射前检查item 的类型。
• 你必须await你的Task。
• 总是更喜欢异步 API。不要混合使用非 Async 和 Async API（这确实意味着使用自定义的 ListBlobsAsync 方法，因为没有单一的 ListBlobsAsync 方法）：

async Task CopyBlobsAsync()
{
    const String ContainerName    = "old-container-name";
    const String NewContainerName = "new-container-name";

    CloudStorageAccount storageAccount = CloudStorageAccount.Parse( CloudConfigurationManager.GetSetting("StorageConnectionString") );
    CloudBlobClient     blobClient     = storageAccount.CreateCloudBlobClient();
    CloudBlobContainer  container      = blobClient.GetContainerReference( ContainerName );
    CloudBlobContainer  destcontainer  = blobClient.GetContainerReference( NewContainerName );

    await destcontainer.CreateIfNotExistsAsync( BlobContainerPublicAccessType.Blob );

    List<IListBlobItem> blobs = await ListBlobsAsync( container ).ConfigureAwait(false);
    List<Task>          tasks = new List<Task>();

    foreach( IListBlobItem item in blobs )
    {
        if( item is CloudBlockBlob blob )
        {
            CloudBlockBlob destBlob = destcontainer.GetBlockBlobReference( blob.Name );
            Uri destUri = new Uri( GetSharedAccessUri( blob.Name, container ) );
            Task task = destBlob.StartCopyAsync( destUri  );
            tasks.Add( task );
        }
    }

    await Task.WhenAll( tasks ).ConfigureAwait(false);
}

// From https://ahmet.im/blog/azure-listblobssegmentedasync-listcontainerssegmentedasync-how-to/
async Task<List<IListBlobItem> ListBlobsAsync( CloudBlobContainer container )
{
    BlobContinuationToken continuationToken = null;
    List<IListBlobItem> results = new List<IListBlobItem>();
    do
    {
        var response = await ListBlobsSegmentedAsync( continuationToken );
        continuationToken = response.ContinuationToken;
        results.AddRange( response.Results );
    }
    while( continuationToken != null );
    return results;
}