将Cache-Control和Expires标头添加到Azure存储Blob

Question

我正在使用Azure存储来提供静态文件blob,但我希望在提供服务时为文件/ blob添加Cache-Control和Expires标头以降低带宽成本.

像CloudXplorer和Cerebrata的Cloud Storage Studio这样的应用程序提供了在容器和blob上设置元数据属性的选项,但在尝试添加Cache-Control时会感到不安.

有人知道是否可以为文件设置这些标头？

Answer 1

我不得不在大约600k blob上运行批处理作业,发现了两件真正有用的东西:

1. 从同一数据中心的辅助角色运行操作.只要Azure服务位于同一个关联组中,Azure服务之间的速度就很快.此外,没有数据传输成本.

2. 并行运行操作..net v4中的任务并行库(TPL)使这非常简单.下面是为容器中的每个blob并行设置缓存控制头的代码:

   // get the info for every blob in the container
   var blobInfos = cloudBlobContainer.ListBlobs(
       new BlobRequestOptions() { UseFlatBlobListing = true });
   Parallel.ForEach(blobInfos, (blobInfo) =>
   {
       // get the blob properties
       CloudBlob blob = container.GetBlobReference(blobInfo.Uri.ToString());
       blob.FetchAttributes();
   
       // set cache-control header if necessary
       if (blob.Properties.CacheControl != YOUR_CACHE_CONTROL_HEADER)
       {
           blob.Properties.CacheControl = YOUR_CACHE_CONTROL_HEADER;
           blob.SetProperties();
       }
   });
   

Answer 2

这是Joel Fillmore答案的更新版本:

Azure现在无需创建网站和使用WorkerRole,而是可以运行"WebJobs".您可以在存储帐户所在的同一数据中心的网站上按需运行任何可执行文件,以设置缓存标头或任何其他标头字段.

1. 在与存储帐户相同的数据中心中创建一个临时的临时网站.不要担心亲和团体; 创建一个空的ASP.NET站点或任何其他简单站点.内容并不重要.
2. 使用下面的代码创建一个控制台程序,该代码使用更新的Azure存储API.编译它以进行发布,然后将可执行文件和所有必需的DLL压缩为.zip文件.
3. 创建WebJob并从步骤#2上载.zip文件.
4. 运行WebJob.写入控制台的所有内容都可以在创建的日志文件中查看,并可从WebJob控制页面访问.
5. 请注意UpdateAzureServiceVersion方法.显然,在默认情况下,Azure存储走秀格式不正确的ETag,所以你不妨一旦运行该代码,详情请看:这

下面的代码为每个容器运行一个单独的任务,我每个容器每秒更新大约70个标头.没有出口费用.

using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Auth;
using Microsoft.WindowsAzure.Storage.Blob;

namespace AzureHeaders
{
    class Program
    {
        static StorageCredentials storageCredentials =
            new StorageCredentials("azureaccountname", @"azzureaccountkey");
        private static string newCacheSettings = "public, max-age=7776000"; // 3 months
        private static string[] containersToProcess = { "container1", "container2" };

        static void Main(string[] args)
        {
            var account = new CloudStorageAccount(
                storageCredentials,
                false /* useHttps */);

            CloudBlobClient blobClient = account.CreateCloudBlobClient();

            var tasks = new List<Task>();
            foreach (var container in blobClient.ListContainers())
            {
                if (containersToProcess.Contains(container.Name))
                {
                    var c = container;
                    tasks.Add(Task.Run(() => FixHeaders(c)));
                }
            }
            Task.WaitAll(tasks.ToArray());
        }

        private static async Task FixHeaders(CloudBlobContainer cloudBlobContainer)
        {
            int totalCount = 0, updateCount = 0, errorCount = 0;

            Console.WriteLine("Starting container: " + cloudBlobContainer.Name);
            IEnumerable<IListBlobItem> blobInfos = cloudBlobContainer.ListBlobs(useFlatBlobListing: true);

            foreach (var blobInfo in blobInfos)
            {
                try
                {
                    CloudBlockBlob blockBlob = (CloudBlockBlob)blobInfo;
                    var blob = await cloudBlobContainer.GetBlobReferenceFromServerAsync(blockBlob.Name);
                    blob.FetchAttributes();

                    // set cache-control header if necessary
                    if (blob.Properties.CacheControl != newCacheSettings)
                    {
                        blob.Properties.CacheControl = newCacheSettings;
                        blob.SetProperties();
                        updateCount++;
                    }
                }
                catch (Exception ex)
                {
                    // Console.WriteLine(ex.Message);
                    errorCount++;
                }
                totalCount++;
            }
            Console.WriteLine("Finished container: " + cloudBlobContainer.Name + 
                ", TotalCount = " + totalCount + 
                ", Updated = " + updateCount + 
                ", Errors = " + errorCount);
        }

        // http://geekswithblogs.net/EltonStoneman/archive/2014/10/09/configure-azure-storage-to-return-proper-response-headers-for-blob.aspx
        private static void UpdateAzureServiceVersion(CloudBlobClient blobClient)
        {
            var props = blobClient.GetServiceProperties();
            props.DefaultServiceVersion = "2014-02-14";
            blobClient.SetServiceProperties(props);
        }
    }
}

Answer 3

Cerebrata Cloud Storage Studio的最新版本v2011.04.23.00支持在单个blob对象上设置缓存控制。右键单击Blob对象，选择“查看/编辑Blob属性”，然后设置Cache-Control属性的值。（例如public, max-age=2592000）。

如果使用curl检查blob对象的HTTP标头，则会看到返回的缓存控制标头带有您设置的值。