Создание триггера для Message Queue
Создайте триггер для очереди сообщений сервиса Yandex Message Queue и обрабатывайте их с помощью функции Cloud Functions или контейнера Serverless Containers.
Важно
- Триггер можно создать только для стандартной очереди сообщений.
- Триггер должен находиться в одном облаке с очередью, из которой он читает сообщения.
- Для одной очереди сообщений можно создать только один триггер.
Перед началом работы
Для создания триггера вам понадобятся:
-
Функция или контейнер, которые триггер будет запускать.
-
Если у вас нет функции:
-
Если у вас нет контейнера:
-
-
Очередь сообщений, из которой триггер будет принимать сообщения. Если у вас нет очереди, создайте ее.
-
Сервисные аккаунты с правами:
- на вызов функции или контейнера;
- на чтение из очереди, из которой триггер будет принимать сообщения;
- (опционально) на запись в очередь Dead Letter Queue.
Вы можете использовать один и тот же сервисный аккаунт или разные. Если у вас нет сервисного аккаунта, создайте его.
Создать триггер
Примечание
Триггер начинает работать в течение 5 минут после создания.
-
В консоли управления перейдите в каталог, в котором хотите создать триггер.
-
Откройте сервис Cloud Functions.
-
На панели слева выберите Триггеры.
-
Нажмите кнопку Создать триггер.
-
В блоке Базовые параметры:
- Введите имя и описание триггера.
- В поле Тип выберите Message Queue.
- Выберите, что будет запускать триггер — функцию или контейнер.
-
В блоке Настройки Message Queue выберите очередь сообщений и сервисный аккаунт c правами на чтение из нее.
-
(опционально) В блоке Настройки группирования сообщений укажите:
- размер группы сообщений. Допустимые значения от 1 до 10, значение по умолчанию — 1.
- максимальное время ожидания. Допустимые значения от 0 до 20 секунд, значение по умолчанию — 10 секунд.
Триггер группирует сообщения не дольше указанного времени ожидания и отправляет их в функцию или контейнер. Число сообщений при этом не превышает указанный размер группы.
-
Если триггер будет запускать:
-
функцию, в блоке Настройки функции выберите ее и укажите:
- тег версии функции;
- сервисный аккаунт, от имени которого будет вызываться функция.
-
контейнер, в блоке Настройки контейнера выберите его и укажите:
- ревизию контейнера;
- сервисный аккаунт, от имени которого будет вызываться контейнер.
-
-
Нажмите кнопку Создать триггер.
Если у вас еще нет интерфейса командной строки Yandex Cloud, установите и инициализируйте его.
По умолчанию используется каталог, указанный в профиле CLI. Вы можете указать другой каталог с помощью параметра --folder-name или --folder-id.
Чтобы создать триггер, который запускает функцию, выполните команду:
yc serverless trigger create message-queue \
--name <имя триггера> \
--queue <идентификатор очереди> \
--queue-service-account-id <идентификатор сервисного аккаунта> \
--invoke-function-id <идентификатор функции> \
--invoke-function-service-account-id <идентификатор сервисного аккаунта> \
--batch-size 1 \
--batch-cutoff 10s
Где:
-
--name— имя триггера. -
--queue— идентификатор очереди.Чтобы узнать идентификатор очереди:
- В консоли управления перейдите в каталог, в котором находится очередь.
- Откройте сервис Message Queue.
- Выберите очередь.
- Идентификатор очереди будет в блоке Общая информация, в поле ARN.
-
--invoke-function-id— идентификатор функции. -
--queue-service-account-name— сервисный аккаунт с правами на чтение из очереди сообщений. -
--invoke-function-service-account-id— сервисный аккаунт с правами на вызов функции. -
--batch-size— размер группы сообщений. Необязательный параметр. Допустимые значения от 1 до 10, значение по умолчанию — 1. -
--batch-cutoff— максимальное время ожидания. Необязательный параметр. Допустимые значения от 0 до 20 секунд, значение по умолчанию — 10 секунд. Триггер группирует сообщения не дольшеbatch-cutoffи отправляет их в функцию или контейнер. Число сообщений при этом не превышаетbatch-size.
Результат:
id: dd0cspdch6dslu9n3i5g
folder_id: aoek49ghmknnpj1ll45e
created_at: "2019-08-28T12:14:45.762915Z"
name: ymq-trigger
rule:
message_queue:
queue_id: yrn:yc:ymq:ru-central1:aoek49ghmknnpj1ll45e:my-mq
service_account_id: bfbqqeo6jkpls2tse5o6
batch_settings:
size: "1"
cutoff: 10s
invoke_function:
function_id: b09e5lu91ta21vdrrgma
function_tag: $latest
service_account_id: bfbqqeo6jkpls2tse5o6
status: ACTIVE
Создать триггер для Yandex Message Queue можно с помощью метода API create.
Проверить результат
Проверьте, что триггер работает корректно. Для этого посмотрите логи функции или логи контейнера, в них отображается информация о вызовах.
Проверьте, что количество сообщений в очереди уменьшается. Для этого посмотрите статистику очереди:
- В консоли управления откройте сервис Message Queue.
- Выберите очередь, для которой создали триггер.
- Перейдите в раздел Мониторинг. Посмотрите график Сообщений в очереди.