blob storage第一次親密接觸

由於azure上各個雲服務都是分開的，所以當一個地方生成文件后，我在別的地方想要讀取他就變得困難，不過azure上面有解決方案，就是azure blob storage。

在現有的訂閱賬號下，新建一個存儲blob，分私有和公共，私有的為私有存儲，外部鏈接無法訪問，公共則可以在外部直接通過鏈接進行存儲內容的訪問。

首先在cloud service和portal配置文件中均需添加一個key為storageAccount，value則為azure上的blobend，queueend，tableend，以及他的thumbprint。

在configuration文件中配置改存儲名稱。

 public static string EmailFileContainer
        {
            get
            {
                return "email-response-save";
            }
        }

 

建立一個BlobClient類，用來執行blob事件。

public class BlobClient
    {
        private static CloudBlobClient _cloudBlobClient;

        static BlobClient()
        {
            _cloudBlobClient = CloudStorageAccount.Parse(Config.CloudStorageAccount).CreateCloudBlobClient();
            _cloudBlobClient.RetryPolicy = new LinearRetry(TimeSpan.FromSeconds(1), 3);
        }
        
        /// <summary>
        /// Get file from blob
        /// </summary>
        /// <param name="containerName"></param>
        /// <param name="blobName"></param>
        /// <param name="blobPath"></param>
        public static void GetBlob(string containerName, string blobName, string blobPath)
        {
            var container = _cloudBlobClient.GetContainerReference(containerName);

            var blob = container.GetBlockBlobReference(blobName);
            var mode = System.IO.FileMode.Create;
            blob.DownloadToFileAsync(blobPath, mode);

            return;
        }

        /// <summary>
        /// Add file to blob
        /// </summary>
        /// <param name="containerName"></param>
        /// <param name="blobName"></param>
        /// <param name="blobPath"></param>
        /// <param name="blobFileName"></param>
        public static void AddBlob(string containerName, string blobName, string blobPath,string blobFileName)
        {
            var container = _cloudBlobClient.GetContainerReference(containerName);
            container.CreateIfNotExists();

            var blob = container.GetBlockBlobReference(blobName);
            var mode = System.IO.FileMode.Open;
            blob.UploadFromFileAsync(blobPath+blobFileName, mode);

            return;
        }

        public static void DeleteBlob(string containerName, string blobName)
        {
            var container = _cloudBlobClient.GetContainerReference(containerName);
            container.CreateIfNotExists();

            var blob = container.GetBlockBlobReference(blobName);
            blob.DeleteIfExistsAsync();

            return;
        }

        public static void DeleteBlobContainer(string containerName)
        {
            var container = _cloudBlobClient.GetContainerReference(containerName);
            container.CreateIfNotExists();

            foreach (var item in container.ListBlobs(null, false))
            {
                foreach (var item1 in ((CloudBlobDirectory)item).ListBlobs())
                {
                    foreach (var item2 in ((CloudBlobDirectory)item1).ListBlobs())
                    {
                        ((CloudBlockBlob)item2).DeleteIfExistsAsync();
                    }
                }
            }
        }
    }

執行寫入blob storage步驟。

 BlobClient.AddBlob(Config.EmailFileContainer, "MailExportTotalImage/"+ imgName, location, imgName); 

讀取blob storage中的文件。

 BlobClient.GetBlob(Config.EmailFileContainer, "MailExportAttachment1/" + sFileName, uploadPath + sFileName); 

 

將內存流數據存入TXT。

var fn = DateTime.Now.ToString("yyyyMMddHHmmss") + ".txt";
byte[] bs = stream.ToArray();
String contentStr = System.Text.Encoding.UTF8.GetString(bs);       
       
BlobClient.AddBlob(Config.FileContainer, fn, contentStr);

 

若要創建公共可訪問文件的鏈接，需在對應雲服務的configuration文件中申明一個設置名稱。

<ConfigurationSettings>
      <!--Local-->
      <Setting name="aaaa" value="bbbbbbbbbbb" />
        .
        .
        .
      <Setting name="EmailBlobStorage" value="http(s)://xxx.blob.core.chinacloudapi.cn/email-response-save/" />
 </ConfigurationSettings>

 

核心configuration文件中建立一個指向雲服務configuration特定設置名稱的屬性。

public static string EmailBlobStorage
        {
            get
            {
                return CloudConfigurationManager.GetSetting("EmailBlobStorage");
            }
        }

使用：

var location = Config.EmailBlobStorage; 
var imgsrc = location + "MailExportTotalImage/" + string.Format("{0:yyyy-MM-dd}", DateTime.Today.ToGmt8()) + _title + ".png";