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»). В редких случаях сообщение может быть получено из стандартной очереди дважды. Используйте стандартные очереди, когда требуется максимальная пропускная способность.

В документацию

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

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

В документацию