Пересмотр подписи общего доступа Windows Azure

var sas = blobContainer.GetSharedAccessSignature(new SharedAccessBlobPolicy()
    {
        Permissions = permission,
        SharedAccessStartTime = DateTime.UtcNow.AddMinutes(-5),//SAS Start time is back by 5 minutes to take clock skewness into consideration
        SharedAccessExpiryTime = DateTime.UtcNow.AddMinutes(15),
    });

/// <summary>
/// Creates a SAS URI for the blob container.
/// </summary>
/// <param name="blobContainer"></param>
/// <param name="permission"></param>
/// <returns></returns>
static string GetSaSForBlobContainer(CloudBlobContainer blobContainer, SharedAccessBlobPermissions permission)
{
    var sas = blobContainer.GetSharedAccessSignature(new SharedAccessBlobPolicy()
        {
            Permissions = permission,
            SharedAccessStartTime = DateTime.UtcNow.AddMinutes(-5),//SAS Start time is back by 5 minutes to take clock skewness into consideration
            SharedAccessExpiryTime = DateTime.UtcNow.AddMinutes(15),
        });
    return string.Format(CultureInfo.InvariantCulture, "{0}{1}", blobContainer.Uri, sas);
}

/// <summary>
/// Creates a SAS URI for the blob.
/// </summary>
/// <param name="blob"></param>
/// <param name="permission"></param>
/// <returns></returns>
static string GetSaSForBlob(CloudBlockBlob blob, SharedAccessBlobPermissions permission)
{
    var sas = blob.GetSharedAccessSignature(new SharedAccessBlobPolicy()
    {
        Permissions = permission,
        SharedAccessStartTime = DateTime.UtcNow.AddMinutes(-5),
        SharedAccessExpiryTime = DateTime.UtcNow.AddMinutes(15),
    });
    return string.Format(CultureInfo.InvariantCulture, "{0}{1}", blob.Uri, sas);
}

Использование клиентской библиотеки хранилища

/// <summary>
/// List blobs in a blob container using storage client library.
/// </summary>
/// <param name="blobContainerSasUri"></param>
static void ListBlobsWithStorageClientLibrary(string blobContainerSasUri)
{
    CloudBlobContainer blobContainer = new CloudBlobContainer(new Uri(blobContainerSasUri));
    var blobs = blobContainer.ListBlobs(null, true);
    foreach (var blob in blobs)
    {
        Console.WriteLine(blob.Uri);
    }
}

Использование REST API

/// <summary>
/// List blobs in a blob container using REST API.
/// </summary>
/// <param name="blobContainerSasUri"></param>
static void ListBlobsWithRestAPI(string blobContainerSasUri)
{
    string requestUri = string.Format(CultureInfo.InvariantCulture, "{0}&comp=list", blobContainerSasUri);
    HttpWebRequest request = (HttpWebRequest) WebRequest.Create(requestUri);
    request.Method = "GET";
    using (HttpWebResponse resp = (HttpWebResponse) request.GetResponse())
    {
        using (Stream s = resp.GetResponseStream())
        {
            using (StreamReader reader = new StreamReader(s, true))
            {
                string blobsData = reader.ReadToEnd();
                Console.WriteLine(blobsData);
            }
        }
    }
}

Вы должны добавить « & comp = list » в URI для перечисления контейнеров BLOB-объектов. Также вывод XML.

Я мог бы просто взять URI (в переменной requestUri выше) и вставить его в адресное окно браузера и увидеть список больших двоичных объектов в контейнере больших двоичных объектов. Смотрите скриншот ниже для примера.

Загрузить BLOB-объекты

Вот код для загрузки BLOB-объекта в контейнер BLOB-объектов. Для загрузки большого двоичного объекта вы можете создать SAS с разрешением « Запись » для контейнера больших двоичных объектов или большого двоичного объекта. Капля не должна присутствовать в контейнере капли. Если блоб отсутствует, он будет создан, в противном случае он будет перезаписан.

Использование клиентской библиотеки хранилища

/// <summary>
/// Uploads a blob in a blob container where SAS permission is defined on a blob container using storage client library.
/// </summary>
/// <param name="blobContainerSasUri"></param>
static void UploadBlobWithStorageClientLibrarySasPermissionOnBlobContainer(string blobContainerSasUri)
{
    CloudBlobContainer blobContainer = new CloudBlobContainer(new Uri(blobContainerSasUri));
    CloudBlockBlob blob = blobContainer.GetBlockBlobReference("sample.txt");
    string sampleContent = "This is sample text.";
    using (MemoryStream ms = new MemoryStream(Encoding.UTF8.GetBytes(sampleContent)))
    {
        blob.UploadFromStream(ms);
    }
}

/// <summary>
/// Uploads a blob in a blob container where SAS permission is defined on a blob using storage client library.
/// </summary>
/// <param name="blobSasUri"></param>
static void UploadBlobWithStorageClientLibrarySasPermissionOnBlob(string blobSasUri)
{
    CloudBlockBlob blob = new CloudBlockBlob(new Uri(blobSasUri));
    string sampleContent = "This is sample text.";
    using (MemoryStream ms = new MemoryStream(Encoding.UTF8.GetBytes(sampleContent)))
    {
        blob.UploadFromStream(ms);
    }
}

Использование REST API

/// <summary>
/// Uploads a blob in a blob container where SAS permission is defined on a blob container using REST API.
/// </summary>
/// <param name="blobContainerSasUri"></param>
static void UploadBlobWithRestAPISasPermissionOnBlobContainer(string blobContainerSasUri)
{
    string blobName = "sample.txt";
    string sampleContent = "This is sample text.";
    int contentLength = Encoding.UTF8.GetByteCount(sampleContent);
    string queryString = (new Uri(blobContainerSasUri)).Query;
    string blobContainerUri = blobContainerSasUri.Substring(0, blobContainerSasUri.Length - queryString.Length);
    string requestUri = string.Format(CultureInfo.InvariantCulture, "{0}/{1}{2}", blobContainerUri, blobName, queryString);
    HttpWebRequest request = (HttpWebRequest)WebRequest.Create(requestUri);
    request.Method = "PUT";
    request.Headers.Add("x-ms-blob-type", "BlockBlob");
    request.ContentLength = contentLength;
    using (Stream requestStream = request.GetRequestStream())
    {
        requestStream.Write(Encoding.UTF8.GetBytes(sampleContent), 0, contentLength);
    }
    using (HttpWebResponse resp = (HttpWebResponse)request.GetResponse())
    {
         
    }
}

При работе с REST API необходимо указать заголовок запроса « x-ms-blob-type ». Для блочных BLOB-объектов его значение должно быть « BlockBlob », а для блочных страниц — « PageBlob ».

Загрузить Blobs в блоках

Вот код, если вы хотите загрузить блоб, разбив его на блоки. Для загрузки большого двоичного объекта вы можете создать SAS с разрешением « Запись » для контейнера больших двоичных объектов или большого двоичного объекта. Капля не должна присутствовать в контейнере капли. Если блоб отсутствует, он будет создан, в противном случае он будет перезаписан.

Использование клиентской библиотеки хранилища

/// <summary>
/// Uploads a blob by splitting into blocks in a blob container where SAS permission is defined on a blob container using storage client library.
/// </summary>
/// <param name="blobContainerSasUri"></param>
static void UploadBlobInBlocksWithStorageClientLibrarySasPermissionOnBlobContainer(string blobContainerSasUri)
{
    CloudBlobContainer blobContainer = new CloudBlobContainer(new Uri(blobContainerSasUri));
    CloudBlockBlob blob = blobContainer.GetBlockBlobReference(Guid.NewGuid().ToString() + ".txt");
    List<string> blockIds = new List<string>();
    for (int i = 0; i < 10; i++)
    {
        string sampleContent = string.Format(CultureInfo.InvariantCulture, "Line {0}: This is sample text.\r\n", i);
        string blockId = i.ToString("d4");
        blockIds.Add(blockId);
        using (MemoryStream ms = new MemoryStream(Encoding.UTF8.GetBytes(sampleContent)))
        {
            blob.PutBlock(blockId, ms, null);
        }
    }
    blob.PutBlockList(blockIds);
}

/// <summary>
/// Uploads a blob by splitting into blocks in a blob container where SAS permission is defined on a blob using storage client library.
/// </summary>
/// <param name="blobSasUri"></param>
static void UploadBlobInBlocksWithStorageClientLibrarySasPermissionOnBlob(string blobSasUri)
{
    CloudBlockBlob blob = new CloudBlockBlob(blobSasUri);
    List<string> blockIds = new List<string>();
    for (int i = 0; i < 10; i++)
    {
        string sampleContent = string.Format(CultureInfo.InvariantCulture, "Line {0}: This is sample text.\r\n", i);
        string blockId = i.ToString("d4");
        blockIds.Add(blockId);
        using (MemoryStream ms = new MemoryStream(Encoding.UTF8.GetBytes(sampleContent)))
        {
            blob.PutBlock(blockId, ms, null);
        }
    }
    blob.PutBlockList(blockIds);
}

Использование REST API

/// <summary>
/// Uploads a blob by splitting into blocks in a blob container where SAS permission is defined on a blob container using REST API.
/// </summary>
/// <param name="blobContainerSasUri"></param>
static void UploadBlobInBlocksWithRestAPISasPermissionOnBlobContainer(string blobContainerSasUri)
{
    string blobName = Guid.NewGuid().ToString() + ".txt";
    string queryString = (new Uri(blobContainerSasUri)).Query;
    string blobContainerUri = blobContainerSasUri.Substring(0, blobContainerSasUri.Length - queryString.Length);
    List<string> blockIds = new List<string>();
    for (int i = 0; i < 10; i++)
    {
        string sampleContent = string.Format(CultureInfo.InvariantCulture, "Line {0}: This is sample text.\r\n", i);
        string blockId = i.ToString("d4");
        blockIds.Add(blockId);
        int contentLength = Encoding.UTF8.GetByteCount(sampleContent);
        string requestUri = string.Format(CultureInfo.InvariantCulture, "{0}/{1}{2}&comp=block&blockid={3}", blobContainerUri, blobName, queryString, Convert.ToBase64String(Encoding.UTF8.GetBytes(blockId)));
        HttpWebRequest request = (HttpWebRequest)WebRequest.Create(requestUri);
        request.Method = "PUT";
        request.ContentLength = contentLength;
        using (Stream requestStream = request.GetRequestStream())
        {
            requestStream.Write(Encoding.UTF8.GetBytes(sampleContent), 0, contentLength);
        }
        using (HttpWebResponse resp = (HttpWebResponse)request.GetResponse())
        {
 
        }
    }
    string commitBlockListRequestBodyFormat = @"<?xml version=""1.0"" encoding=""utf-8"" ?><BlockList>{0}</BlockList>";
 
    string blockListReuestBodyFormat = "<Latest>{0}</Latest>";
    StringBuilder sb = new StringBuilder();
    for (int i = 0; i < blockIds.Count; i++)
    {
        sb.AppendFormat(CultureInfo.InvariantCulture, blockListReuestBodyFormat,
                        Convert.ToBase64String(Encoding.UTF8.GetBytes(blockIds[i])));
    }
    string requestPayLoad = string.Format(CultureInfo.InvariantCulture, commitBlockListRequestBodyFormat,
                                          sb.ToString());
    int contentLengthForCommitBlockList = Encoding.UTF8.GetByteCount(requestPayLoad);
    string requestUriForCommitBlockList = string.Format(CultureInfo.InvariantCulture, "{0}/{1}{2}&comp=blockList", blobContainerUri, blobName, queryString);
    HttpWebRequest req = (HttpWebRequest)WebRequest.Create(requestUriForCommitBlockList);
    req.Method = "PUT";
    req.ContentLength = contentLengthForCommitBlockList;
    using (Stream requestStream = req.GetRequestStream())
    {
        requestStream.Write(Encoding.UTF8.GetBytes(requestPayLoad), 0, contentLengthForCommitBlockList);
    }
    using (HttpWebResponse resp = (HttpWebResponse)req.GetResponse())
    {
 
    }
}

/// Uploads a blob by splitting into blocks in a blob container where SAS permission is defined on a blob using REST API.
/// </summary>
/// <param name="blobSasUri"></param>
static void UploadBlobInBlocksWithRestAPISasPermissionOnBlob(string blobSasUri)
{
    List<string> blockIds = new List<string>();
    for (int i = 0; i < 10; i++)
    {
        string sampleContent = string.Format(CultureInfo.InvariantCulture, "Line {0}: This is sample text.\r\n", i);
        string blockId = i.ToString("d4");
        blockIds.Add(blockId);
        int contentLength = Encoding.UTF8.GetByteCount(sampleContent);
        string requestUri = string.Format(CultureInfo.InvariantCulture, "{0}&comp=block&blockid={1}", blobSasUri, Convert.ToBase64String(Encoding.UTF8.GetBytes(blockId)));
        HttpWebRequest request = (HttpWebRequest)WebRequest.Create(requestUri);
        request.Method = "PUT";
        request.ContentLength = contentLength;
        using (Stream requestStream = request.GetRequestStream())
        {
            requestStream.Write(Encoding.UTF8.GetBytes(sampleContent), 0, contentLength);
        }
        using (HttpWebResponse resp = (HttpWebResponse)request.GetResponse())
        {
 
        }
    }
    string commitBlockListRequestBodyFormat = @"<?xml version=""1.0"" encoding=""utf-8"" ?><BlockList>{0}</BlockList>";
 
    string blockListReuestBodyFormat = "<Latest>{0}</Latest>";
    StringBuilder sb = new StringBuilder();
    for (int i = 0; i < blockIds.Count; i++)
    {
        sb.AppendFormat(CultureInfo.InvariantCulture, blockListReuestBodyFormat,
                        Convert.ToBase64String(Encoding.UTF8.GetBytes(blockIds[i])));
    }
    string requestPayLoad = string.Format(CultureInfo.InvariantCulture, commitBlockListRequestBodyFormat,
                                          sb.ToString());
    int contentLengthForCommitBlockList = Encoding.UTF8.GetByteCount(requestPayLoad);
    string requestUriForCommitBlockList = string.Format(CultureInfo.InvariantCulture, "{0}&comp=blockList", blobSasUri);
    HttpWebRequest req = (HttpWebRequest)WebRequest.Create(requestUriForCommitBlockList);
    req.Method = "PUT";
    req.ContentLength = contentLengthForCommitBlockList;
    using (Stream requestStream = req.GetRequestStream())
    {
        requestStream.Write(Encoding.UTF8.GetBytes(requestPayLoad), 0, contentLengthForCommitBlockList);
    }
    using (HttpWebResponse resp = (HttpWebResponse)req.GetResponse())
    {
 
    }
}

При работе с REST API для помещения блоков необходимо указать « comp = block » и кодированный в Base64 идентификатор блока в URI запроса . Для размещения списка блокировки необходимо указать « comp = blockList » в URI запроса.

Скачать Blobs

Вот код для загрузки BLOB-объекта из контейнера BLOB-объектов. Для загрузки большого двоичного объекта в SAS должно быть указано разрешение « Чтение ».

Использование клиентской библиотеки хранилища

/// <summary>
/// Downloads a blob from a blob cobtainer using storage client library.
/// </summary>
/// <param name="blobSasUri"></param>
static void DownloadBlobWithStorageClientLibrary(string blobSasUri)
{
    CloudBlockBlob blob = new CloudBlockBlob(new Uri(blobSasUri));
    using (MemoryStream ms = new MemoryStream())
    {
        blob.DownloadToStream(ms);
        byte[] data = new byte[ms.Length];
        ms.Position = 0;
        ms.Read(data, 0, data.Length);
        string blobContents = Encoding.UTF8.GetString(data);
        Console.WriteLine(blobContents);
    }
}

Использование REST API

/// <summary>
/// Downloads a blob from a blob cobtainer using REST API.
/// </summary>
/// <param name="blobSasUri"></param>
static void DownloadBlobWithRestAPI(string blobSasUri)
{
    HttpWebRequest request = (HttpWebRequest)WebRequest.Create(blobSasUri);
    request.Method = "GET";
    using (HttpWebResponse resp = (HttpWebResponse)request.GetResponse())
    {
        using (Stream s = resp.GetResponseStream())
        {
            using (StreamReader reader = new StreamReader(s, true))
            {
                string blobData = reader.ReadToEnd();
                Console.WriteLine(blobData);
            }
        }
    }
}

Удаление BLOB-объектов

Вот код для удаления BLOB-объекта из контейнера BLOB-объектов. Для операции удаления в SAS должно быть определено разрешение « Удалить ».

Использование клиентской библиотеки хранилища

/// <summary>
/// Deletes a blob from a blob cobtainer using storage client library.
/// </summary>
/// <param name="blobSasUri"></param>
static void DeleteBlobWithStorageClientLibrary(string blobSasUri)
{
    CloudBlockBlob blob = new CloudBlockBlob(new Uri(blobSasUri));
    blob.Delete();
}

Использование REST API

/// <summary>
/// Deletes a blob from a blob cobtainer using REST API.
/// </summary>
/// <param name="blobSasUri"></param>
private static void DeleteBlobWithRestAPI(string blobSasUri)
{
    HttpWebRequest request = (HttpWebRequest)WebRequest.Create(blobSasUri);
    request.Method = "DELETE";
    using (HttpWebResponse resp = (HttpWebResponse) request.GetResponse())
    {
         
    }
}

Резюме

Вот именно для этого поста. Я мог бы сделать больше и включить больше примеров, но они должны дать вам представление о том, как использовать SAS для выполнения различных операций. Может быть, в другом посте я покажу некоторые функции, связанные с таблицами и очередями с помощью SAS. Я надеюсь, что вы нашли этот пост полезным. Если вы обнаружите какие-либо проблемы с этим сообщением, пожалуйста, дайте мне знать, и я постараюсь исправить их как можно скорее. Не стесняйтесь предоставлять свои комментарии ниже.

Удачного кодирования !!!