連線到 Azure 儲存佇列

Azure 中的儲存選項提供 RESTAPI(或者,更好的是,HTTP API)

Azure SDK 為多種語言提供客戶端。讓我們看看如何使用 C#客戶端庫初始化其中一個儲存物件(佇列)。

對 Azure 儲存的所有訪問都通過儲存帳戶完成。你可以通過多種方式建立儲存帳戶:通過門戶,Azure CLI,PowerShell,Azure 資源管理器(ARM),…

在這個例子中,我們假設你已經有一個,並且已將其儲存在 app.config 檔案中。

// Retrieve storage account from connection string.
CloudStorageAccount storageAccount = CloudStorageAccount.Parse(
    CloudConfigurationManager.GetSetting("StorageConnectionString"));

可以通過以下 URL 訪問佇列:http://<storage account>.queue.core.windows.net/<queue>

客戶端庫將為你生成此 URL; 你只需要指定佇列名稱(必須是小寫)。第一步是獲取對佇列客戶端的引用,該客戶端將用於管理佇列(佇列包含在指定的儲存帳戶中)。

CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();

你使用客戶端獲取對佇列的引用。

CloudQueue queue = queueClient.GetQueueReference("<queue>");

現在,使用此 queue 代理,你可以將任何操作指向佇列。

通常,第一個操作是建立佇列(如果它尚不存在)

queue.CreateIfNotExists();

注意操作的名稱。為什麼如果不存在?有幾個原因:

  • 你可能正在部署將執行此程式碼的某事的多個例項(某些東西通常是計算服務 ,如 Web 角色或工作者角色,但它可以是 Web 應用程式,結構服務,某些自定義程式碼一個 VM …)
  • 你的應用可能會隨時重啟。請記住,這是一個雲環境,特別是對於 PaaS 服務,例項是短暫的。你對應用程式的控制程度與對本地部署的應用程式的控制程度不同。

更好的是,你應該使用相同 API 呼叫的非同步版本:

await queue.CreateIfNotExistsAsync();

我們在此示例中使用了一個佇列,但該示例可以輕鬆應用於其他儲存物件(blob,表和檔案)。

建立儲存物件後,即可開始使用它。