Очереди сообщений

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

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

Стандартные очередиСтандартные очереди

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

Используйте стандартные очереди, когда требуется максимальная пропускная способность.

Очереди FIFOОчереди FIFO

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

Используйте очереди FIFO, если требуется обеспечить строгий порядок доставки и однократную обработку сообщений.

Группировка сообщенийГруппировка сообщений

С помощью идентификаторов групп можно организовать отправку нескольких упорядоченных потоков сообщений для разных потребителей в одной FIFO-очереди. Идентификатор группы указывается при помощи параметра MessageGroupId при отправке. В рамках одной группы все сообщения записываются и вычитываются в порядке отправления.

Дедупликация на записиДедупликация на записи

FIFO-очереди дедуплицируют сообщения на записи по идентификатору дедупликации или по содержимому сообщения. Подробнее читайте в разделе Дедупликация.

Примеры использованияПримеры использования

• Автоматическое масштабирование группы виртуальных машин для обработки сообщений из очереди Message Queue.
• Конвертация видео в GIF на Python.
• Создание интерактивного serverless-приложения с использованием WebSocket.
• Создание триггеров, которые вызывают функции Cloud Functions для остановки ВМ и отправки уведомлений в Telegram.