检查 Azure 存储中是否存在 blob

Question

我有一个非常简单的问题（我希望如此！） - 我只想查明某个 blob（具有我定义的名称）是否存在于特定容器中。如果它确实存在，我会下载它，如果不存在，我会做其他事情。

我在管间做了一些搜索，显然曾经有一个名为DoesExist或类似的函数...但是与许多Azure API一样，这个函数似乎不再存在（或者如果存在，也有一个非常巧妙地伪装的名字）。

Answer 1

新的 API 具有 .Exists() 函数调用。只需确保您使用 GetBlockBlobReference，它不会执行对服务器的调用。它使该功能变得简单：

public static bool BlobExistsOnCloud(CloudBlobClient client, 
    string containerName, string key)
{
     return client.GetContainerReference(containerName)
                  .GetBlockBlobReference(key)
                  .Exists();  
}

Answer 2

注意：这个答案现在已经过时了。请参阅 Richard 的答案，了解检查是否存在的简单方法

不，您并没有错过一些简单的东西...我们在新的 StorageClient 库中隐藏此方法方面做得很好。 :)

我刚刚写了一篇博客文章来回答您的问题： http://blog.smarx.com/posts/testing-existence-of-a-windows-azure-blob。

简短的答案是：使用 CloudBlob.FetchAttributes()，它对 blob 执行 HEAD 请求。

Answer 3

看起来很蹩脚，您需要捕获异常来测试 blob 是否存在。

public static bool Exists(this CloudBlob blob)
{
    try
    {
        blob.FetchAttributes();
        return true;
    }
    catch (StorageClientException e)
    {
        if (e.ErrorCode == StorageErrorCode.ResourceNotFound)
        {
            return false;
        }
        else
        {
            throw;
        }
    }
}

Answer 4

如果 blob 是公共的，您当然可以从无数知道如何执行此操作的语言/环境/平台中发送一个 HTTP HEAD 请求，然后检查响应。

核心 Azure API 是基于 RESTful XML 的 HTTP 接口。 StorageClient 库是它们周围许多可能的包装器之一。这是 Sriram Krishnan 用 Python 完成的另一个操作：

http: //www.sriramkrishnan.com/blog/2008/11/python-wrapper-for-windows-azure.html

它还展示了如何在 HTTP 级别进行身份验证。

我在 C# 中为自己做了类似的事情，因为我更喜欢通过 HTTP/REST 的视角而不是通过 StorageClient 库的视角来看待 Azure。很长一段时间我什至都懒得去实现 ExistsBlob 方法。我的所有 blob 都是公共的，执行 HTTP HEAD 很简单。

Answer 5

如果您不喜欢其他解决方案，这里有一个不同的解决方案：

我使用的是 Azure.Storage.Blobs NuGet 包 12.4.1 版本。

我得到一个 >Azure.Pageable 对象，它是容器中所有 Blob 的列表。然后，我使用 BlobItem 来检查容器内每个 Blob 的 Name 属性是否等于 Name 属性。强>LINQ。 （当然，如果一切都有效）

using Azure.Storage.Blobs;
using Azure.Storage.Blobs.Models;
using System.Linq;
using System.Text.RegularExpressions;

public class AzureBlobStorage
{
    private BlobServiceClient _blobServiceClient;

    public AzureBlobStorage(string connectionString)
    {
        this.ConnectionString = connectionString;
        _blobServiceClient = new BlobServiceClient(this.ConnectionString);
    }

    public bool IsContainerNameValid(string name)
    {
        return Regex.IsMatch(name, "^[a-z0-9](?!.*--)[a-z0-9-]{1,61}[a-z0-9]$", RegexOptions.Singleline | RegexOptions.CultureInvariant);
    }

    public bool ContainerExists(string name)
    {
        return (IsContainerNameValid(name) ? _blobServiceClient.GetBlobContainerClient(name).Exists() : false);
    }

    public Azure.Pageable<BlobItem> GetBlobs(string containerName, string prefix = null)
    {
        try
        {
            return (ContainerExists(containerName) ? 
                _blobServiceClient.GetBlobContainerClient(containerName).GetBlobs(BlobTraits.All, BlobStates.All, prefix, default(System.Threading.CancellationToken)) 
                : null);
        }
        catch
        {
            throw;
        }
    }

    public bool BlobExists(string containerName, string blobName)
    {
        try
        {
            return (from b in GetBlobs(containerName)
                     where b.Name == blobName
                     select b).FirstOrDefault() != null;
        }
        catch
        {
            throw;
        }
    }
}

希望这对将来的人有帮助。

Answer 6

新的 Windows Azure 存储库已包含 Exist() 方法。
它位于 Microsoft.WindowsAzure.Storage.dll 中。

以 NuGet 包形式提供
创建者：微软
ID：WindowsAzure.Storage
版本：2.0.5.1

另请参阅 msdn< /a>

Answer 7

我就是这样做的。为有需要的人展示完整代码。

        // Parse the connection string and return a reference to the storage account.
        CloudStorageAccount storageAccount = CloudStorageAccount.Parse(CloudConfigurationManager.GetSetting("AzureBlobConnectionString"));

        CloudBlobClient blobClient = storageAccount.CreateCloudBlobClient();

        // Retrieve reference to a previously created container.
        CloudBlobContainer container = blobClient.GetContainerReference("ContainerName");

        // Retrieve reference to a blob named "test.csv"
        CloudBlockBlob blockBlob = container.GetBlockBlobReference("test.csv");

        if (blockBlob.Exists())
        {
          //Do your logic here.
        }

Answer 8

如果您的 blob 是公共的并且您只需要元数据：

        HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
        request.Method = "HEAD";
        string code = "";
        try
        {
            HttpWebResponse response = (HttpWebResponse)request.GetResponse();
            code = response.StatusCode.ToString();
        }
        catch 
        {
        }

        return code; // if "OK" blob exists

Answer 9

使用 Azure Blob 存储库 v12，您可以使用 BlobBaseClient.Exists()/BlobBaseClient.ExistsAsync()

回答了另一个类似问题：https://stackoverflow.com/a/63293998/4865541

Answer 10

相同的Java版本（使用新的v12 SDK）

这使用共享密钥凭证授权（帐户访问密钥）

public void downloadBlobIfExists(String accountName, String accountKey, String containerName, String blobName) {
    // create a storage client using creds
    StorageSharedKeyCredential credential = new StorageSharedKeyCredential(accountName, accountKey);
    String endpoint = String.format(Locale.ROOT, "https://%s.blob.core.windows.net", accountName);
    BlobServiceClient storageClient = new BlobServiceClientBuilder().credential(credential).endpoint(endpoint).buildClient();

    BlobContainerClient container = storageClient.getBlobContainerClient(containerName);
    BlobClient blob = container.getBlobClient(blobName);
    if (blob.exists()) {
        // download blob
    } else {
        // do something else
    }
}

Answer 11

如果您不喜欢使用异常方法，那么 judell 建议的基本 C# 版本如下。但请注意，您确实也应该处理其他可能的响应。

HttpWebRequest myReq = (HttpWebRequest)WebRequest.Create(url);
myReq.Method = "HEAD";
HttpWebResponse myResp = (HttpWebResponse)myReq.GetResponse();
if (myResp.StatusCode == HttpStatusCode.OK)
{
    return true;
}
else
{
    return false;
}

Answer 12

使用更新的 SDK，一旦您拥有 CloudBlobReference，您就可以对您的引用调用 Exists()。

请参阅 http://msdn.microsoft。 com/en-us/library/microsoft.windowsazure.storage.blob.cloudblockblob.exists.aspx

Answer 13

尽管这里的大多数答案在技术上都是正确的，但大多数代码示例都在进行同步/阻塞调用。除非您受到非常旧的平台或代码库的约束，否则 HTTP 调用应始终异步完成，并且 SDK 在这种情况下完全支持它。只需使用 ExistsAsync() 而不是 Exists()。

bool exists = await client.GetContainerReference(containerName)
    .GetBlockBlobReference(key)
    .ExistsAsync();