Azure StorageAccount's Queues

Как известно Storage в Азуре состоит из 3х основных элементов - BlobStorage, TableStorage, QueueStorage. Подробное описание работы с первыми двумя есть в документации MSDN, а вот про очереди написано мало. Более того, последняя версия Azure SDK не содержит встроенного в MSVS интерфейса для работы с очередями, как приведено на скриншотах ниже. Поэтому для ручной работы с очередями можно использовать упоминавшийся ранее AzureStorageExplorer 5.0 alpha. По сути, очереди используются для отладки в IntelliTrace и реализуют интерфейс FirstInFirstOut, который в принципе каждый смог бы реализовать и на более привычном TableStorage.
Также как и для Таблиц, для очередей нужно создавать клиента:
Copy Source | Copy HTML
  1. #region Работа через queue
  2. private static CloudQueue Queue
  3. {
  4.     get
  5.     {
  6.         CloudQueue _container;
  7.         CloudStorageAccount storageAccount = CloudStorageAccount.Parse(ConfigurationManager.AppSettings["StorageAccount"]);
  8.         CloudQueueClient queueClient = storageAccount.CreateCloudQueueClient();
  9.         // Retrieve a reference to a container  
  10.         _container = queueClient.GetQueueReference("postsforindex");
  11.         // Create the container if it doesn't already exist
  12.         //_container.CreateIfNotExist();
  13.         return _container;
  14.     }
  15. }
  16. #endregion
Важно, чтобы контекст клиента не был просто статической переменной класса, так как это приведет к блокировке. Когда контекст клиента создан, нас интересует 2 базовые операции. Помещение в очередь и обработка очереди. Помещение в очередь возможно одной командой, где одно сообщение представляет из себя простое текстовое сообщение. Уникальная особенность очередей Азура в том, что можно сразу сказать, что помещенное сообщение в очередь станет доступно не сразу, а через некоторое время, в нашем случае это 15 минут.
Copy Source | Copy HTML
  1. //добавили ссылку в очередь на индексирование
  2. Queue.AddMessage(new CloudQueueMessage(url.ExpandedUrl), null, TimeSpan.FromMinutes(15));
  3. //делаем 15 минут задержку на проставление лайков 
Обработка сообщений из очереди возможна следующим кодом.
Copy Source | Copy HTML
  1. for (CloudQueueMessage message = Queue.GetMessage();
  2.                     message != null && !MainService._isStoped
  3.                     //After reading the message, the client should delete it.
  4.                     Queue.DeleteMessage(message),message = Queue.GetMessage()
  5.                     )
  6.                 {
  7.                     PostToIndex pst = MessageDecode(message);
  8.                 }
И обещанный вначале скриншот, показывающий инструмент ручной работы с очередями.

Метки: , ,   Категории:microsoft


blog comments powered by Disqus

Добавить комментарий

Кто я?

Программист. Я слежу за блогосферой и знаю, как будет развиваться интернет. Когда у меня есть время я даже прилагаю для этого усилия. Подробнее

Последние комментарии

Не отображать

Topbot at FeedsBurner

Облако тэгов

Мои Твиты

Копирайт

Все мысли, высказанные в блоге, являются моим мнением и за это мнение меня никто не забанит! Кроме того, никто не имеет право копировать материалы блога без использования ctrl+C/V!

© Copyright 2008