Использование очередей Azure Storage

Разработка для Azure Storage

Shahzad Mian

Content Developer, DataCamp

Введение в очереди хранилища

• Очереди хранилища — это служба очередей сообщений.
• Приложения нередко обрабатывают множество запросов одновременно.
• Ожидание завершения каждого процесса замедляет работу системы.
• Очереди Azure Storage обеспечивают асинхронное взаимодействие между компонентами.
• Асинхронный обмен сообщениями помогает поддерживать скорость и масштабируемость.

Реальная задача

• Интернет-магазин Cipher Coffee принимает сотни заказов одновременно.
• Без очередей каждый заказ ждал бы завершения предыдущего.
• Очереди позволяют мгновенно принимать заказы, а обработку откладывать.
• Сайт остаётся быстрым, а клиенты — довольными.

Что такое очередь?

• Очередь — это список ожидания для обработки сообщений.
• Сообщения обрабатываются по порядку: первым пришёл — первым вышел.
• Каждое сообщение представляет небольшую единицу работы.
• После обработки сообщение удаляется из очереди.

Как работают очереди Azure Storage

• Очереди Azure Storage входят в состав учётной записи хранилища.
• Сообщения объёмом до 64 КБ хранятся надёжно.
• Приложения могут:
  • Отправлять сообщения в очередь.
  • Получать и обрабатывать сообщения.
  • Удалять сообщения после обработки.
• Сообщения сохраняются даже при перезапуске системы.

Асинхронный рабочий процесс

 

 

• Отправитель добавляет сообщение, например «Обработать платёж за Order 2045».
• Фоновая служба, например Azure Function, извлекает сообщение.
• После успешной обработки сообщение удаляется.
• Этот шаблон обеспечивает масштабируемость и отзывчивость под нагрузкой.

Cipher Coffee в действии

• Сайт Cipher Coffee отправляет сообщение о заказе в очередь.
• Система выполнения заказов считывает сообщение из очереди.
• Сообщение инициирует обновление базы данных и платёжной системы.
• Бариста получают уведомления, не замедляя оформление покупки.

Преимущества очередей

• Разделение: системы работают независимо друг от друга.
• Масштабируемость: добавляйте обработчики для ускорения.
• Надёжность: сообщения сохраняются даже при сбоях.
• Интеграция: совместимость с Azure Functions и Logic Apps.

Жизненный цикл сообщения

• Сообщение проходит три основных этапа:
  • Постановка в очередь: сообщение добавляется в очередь.
  • Извлечение из очереди: обработчик получает сообщение.
  • Удаление: сообщение удаляется после успешной обработки.
• Сообщения с ошибкой автоматически возвращаются для повторной попытки.

Типичные сценарии применения

• Обработка заказов и фоновый биллинг.

• Отправка уведомлений по электронной почте.

• Буферизация телеметрии IoT.

• Сбор журналов и конвейеры событий.
  • Используйте очереди для независимых операций с поддержкой повторных попыток.
  • И многое другое.

Очереди и Service Bus

• Azure Service Bus применяется для сложных сценариев обмена сообщениями.
• Service Bus поддерживает:
  • Упорядочение сообщений и сессии.
  • Транзакции, разделы и подписки.
• Azure Storage Queues проще и выгоднее для лёгких рабочих нагрузок.
• Cipher Coffee использует очереди для обработки заказов и обновлений в реальном времени.

Давайте потренируемся!

Разработка для Azure Storage