Використання Azure Storage Queues

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

Shahzad Mian

Content Developer, DataCamp

Вступ до Storage Queues

• Storage queues — це служба черг повідомлень.
• Додатки часто обробляють багато запитів одночасно.
• Очікування завершення кожного процесу сповільнює систему.
• Azure Storage Queues забезпечують асинхронну взаємодію між компонентами.
• Асинхронні повідомлення зберігають швидкість і масштабованість.

Реальний виклик

• Онлайн-магазин Cipher Coffee отримує сотні замовлень одночасно.
• Без черг кожне замовлення чекало б завершення попередніх.
• Черги дають змогу прийняти замовлення миттєво, а обробити пізніше.
• Це тримає сайт швидким і задовольняє клієнтів.

Що таке черга?

• Черга — це «місце очікування» для повідомлень на обробку.
• Повідомлення обробляються за принципом: першим прийшло — першим пішло.
• Кожне повідомлення — це невелика одиниця роботи.
• Після обробки повідомлення видаляється з черги.

Як працюють Azure Storage Queues

• Azure Storage Queues входять до вашого Storage account.
• Повідомлення можуть бути до 64 KB і зберігаються надійно.
• Додатки можуть:
  • Надсилати повідомлення до черги.
  • Отримувати й обробляти повідомлення.
  • Видаляти повідомлення після завершення.
• Повідомлення зберігаються навіть після перезапуску системи.

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

 

 

• Відправник додає повідомлення, наприклад «Обробити платіж для Order 2045»
• Фоновий сервіс, наприклад Azure Function, отримує повідомлення.
• Після успішної обробки повідомлення видаляється.
• Ця схема зберігає масштабованість і швидку реакцію під навантаженням.

Cipher Coffee в дії

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

Переваги черг

• Роз'єднання: системи працюють незалежно.
• Масштабованість: додавайте виконавців для швидшої обробки.
• Надійність: повідомлення зберігаються навіть під час простою.
• Інтеграція: працює з Azure Functions і Logic Apps.

Життєвий цикл повідомлення

• Повідомлення проходять три основні етапи:
  • Enqueue: повідомлення додається до черги.
  • Dequeue: виконавець забирає повідомлення на обробку.
  • Delete: повідомлення видаляється після успішної обробки.
• Невдалі повідомлення автоматично з'являються знову для повтору.

Типові сценарії використання

• Обробка замовлень і фонове виставлення рахунків.

• Надсилання листів-сповіщень.

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

• Збір логів і конвеєри подій.
  • Використовуйте черги для незалежних, безпечних до повторів операцій.
  • Та багато іншого

Queues проти Service Bus

• Azure Service Bus використовують для розширених сценаріїв обміну повідомленнями.
• Service Bus підтримує:
  • Упорядкування повідомлень і сесії.
  • Транзакції та теми/підписки.
• Azure Storage Queues простіші й економніші для легких навантажень.
• Cipher Coffee використовує черги для обробки замовлень і оновлень у реальному часі.

Давайте потренуємось!

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