Yandex Message Queue

Сервис очередей для обмена сообщениями между компонентами распределённых приложений и микросервисов.

Стандартные и FIFO-очереди
Используйте стандартные или FIFO (first in — first out) очереди в зависимости от количества запросов в секунду (RPS).
Совместимость с HTTP API Amazon SQS
Используйте привычные инструменты взаимодействия с Amazon SQS: HTTP API, интерфейс командной строки, библиотеки для различных языков программирования.
Быстрая обработка
Для хранения сообщений Message Queue использует быстрые твердотельные накопители с поддержкой технологии NVMe.
Надёжное хранение сообщений
Сообщения сохраняются сразу в нескольких копиях в географически распределённых зонах доступности. Это обеспечивает надёжность хранения при низкой задержке подтверждения записи.
Интеграция с функциями и триггерами
Message Queue интегрирован с Cloud Functions. Триггер вызывает функцию, которая обрабатывает сообщения из очереди. При этом также используется очередь Dead Letter Queue для обработки ошибок.

Решайте свои задачи с Message Queue

Масштабирование приложений

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

Повышение отказоустойчивости

Если приложение не может обработать сообщение, оно вернется в очередь и его сможет прочитать другой обработчик. Также можно настроить Dead Letter Queue (DLQ) — очередь, куда перенаправлются сообщения, которые не смогли обработать получатели в обычных очередях.

Выполнение ресурсоёмких задач

С помощью очереди сообщений можно вынести выполнение длительных задач в отдельные приложения, быстрее освободив ресурсы для новых запросов пользователей.

С чего начать

Создайте очередь и просматривайте количество сообщений и длительность вызовов в статистике.

Создать очередь

Вопросы и ответы

Как обрабатывают сообщения стандартные очереди?

Из стандартных очередей сообщения считываются получателями в произвольном порядке. Стандартные очереди обеспечивают доставку каждого сообщения минимум один раз («at least once»). В редких случаях сообщение может быть получено из стандартной очереди дважды. Используйте стандартные очереди, когда требуется максимальная пропускная способность.

Из стандартных очередей сообщения считываются получателями в произвольном порядке. Стандартные очереди обеспечивают доставку каждого сообщения минимум один раз («at least once»). В редких случаях сообщение может быть получено из стандартной очереди дважды. Используйте стандартные очереди, когда требуется максимальная пропускная способность.

В чём отличие FIFO-очередей от стандартных?

Из очередей FIFO сообщения считываются в порядке их поступления. FIFO-очереди позволяют обеспечить семантику доставки «exactly once», но их пропускная способность ограничена 30 сообщениями в секунду. Используйте очереди FIFO, если требуется обеспечить строгий порядок доставки и однократную обработку сообщений.

Из очередей FIFO сообщения считываются в порядке их поступления. FIFO-очереди позволяют обеспечить семантику доставки «exactly once», но их пропускная способность ограничена 30 сообщениями в секунду. Используйте очереди FIFO, если требуется обеспечить строгий порядок доставки и однократную обработку сообщений.

Начните пользоваться Message Queue