[Документация Yandex Cloud](../../index.md) > [Yandex Serverless Containers](../index.md) > [Пошаговые инструкции](index.md) > Создание триггера > Создать триггер для Message Queue # Создать триггер для Message Queue, который передает сообщения в контейнер Serverless Containers Создайте [триггер для очереди сообщений](../concepts/trigger/ymq-trigger.md) сервиса Message Queue и обрабатывайте их с помощью [контейнера](../concepts/container.md) Serverless Containers. {% note warning %} * Триггер можно создать только для стандартной очереди сообщений. * Триггер должен находиться в одном облаке с очередью, из которой он читает сообщения. * Для одной очереди сообщений можно создать только один триггер. {% endnote %} ## Перед началом работы {#before-begin} Для создания триггера вам понадобятся: * Контейнер, который триггер будет вызывать. Если у вас нет контейнера: * [Создайте контейнер](create.md). * [Создайте ревизию контейнера](manage-revision.md#create). * [Сервисные аккаунты](../../iam/concepts/users/service-accounts.md) с правами: * на вызов контейнера; * на чтение из очереди, из которой триггер будет принимать сообщения. Вы можете использовать один и тот же сервисный аккаунт или разные. Если у вас нет сервисного аккаунта, [создайте его](../../iam/operations/sa/create.md). * Очередь сообщений, из которой триггер будет принимать сообщения. Если у вас нет очереди, [создайте ее](../../message-queue/operations/message-queue-new-queue.md). ## Создать триггер {#trigger-create} {% note info %} Триггер начинает работать в течение 5 минут после создания. {% endnote %} {% list tabs group=instructions %} - Консоль управления {#console} 1. В [консоли управления](https://console.yandex.cloud) перейдите в каталог, в котором хотите создать триггер. 1. Перейдите в сервис **Serverless Containers**. 1. На панели слева выберите ![image](../../_assets/console-icons/gear-play.svg) **Триггеры**. 1. Нажмите кнопку **Создать триггер**. 1. В блоке **Базовые параметры**: * Введите имя и описание триггера. * В поле **Тип** выберите `Message Queue`. * В поле **Запускаемый ресурс** выберите `Контейнер`. 1. В блоке **Настройки сообщений Message Queue** выберите очередь сообщений и сервисный аккаунт с правами на чтение из нее. 1. В блоке **Настройки группирования сообщений** укажите: * **Время ожидания, с**. Допустимые значения от 0 до 20 секунд, значение по умолчанию — 10 секунд. * **Размер группы**. Допустимые значения от 1 до 1000, значение по умолчанию — 1. Триггер группирует сообщения не дольше указанного времени ожидания и отправляет их в контейнер. Число сообщений при этом не превышает указанный размер группы. 1. В блоке **Настройки контейнера** выберите его и [сервисный аккаунт](../../iam/concepts/users/service-accounts.md), от имени которого он будет вызываться. 1. Нажмите кнопку **Создать триггер**. - CLI {#cli} Если у вас еще нет интерфейса командной строки Yandex Cloud (CLI), [установите и инициализируйте его](../../cli/quickstart.md#install). По умолчанию используется каталог, указанный при [создании](../../cli/operations/profile/profile-create.md) профиля CLI. Чтобы изменить каталог по умолчанию, используйте команду `yc config set folder-id <идентификатор_каталога>`. Также для любой команды вы можете указать другой каталог с помощью параметров `--folder-name` или `--folder-id`. Если вы обращаетесь к ресурсу по имени, поиск будет выполнен в каталоге по умолчанию. Если вы обращаетесь к ресурсу по идентификатору, поиск будет выполнен глобально — во всех каталогах с учетом прав доступа. Чтобы создать триггер, который вызывает контейнер, выполните команду: ```bash yc serverless trigger create message-queue \ --name <имя_триггера> \ --queue <идентификатор_очереди> \ --queue-service-account-id <идентификатор_сервисного_аккаунта> \ --invoke-container-id <идентификатор_контейнера> \ --invoke-container-service-account-id <идентификатор_сервисного_аккаунта> \ --batch-size <размер_группы_сообщений> \ --batch-cutoff <максимальное_время_ожидания> ``` Где: * `--name` — имя триггера. * `--queue` — идентификатор очереди. Чтобы узнать идентификатор очереди: 1. В [консоли управления](https://console.yandex.cloud) перейдите в каталог, в котором находится очередь. 1. Выберите сервис **Message Queue**. 1. Выберите очередь. 1. Идентификатор очереди будет в блоке **Общая информация**, в поле **ARN**. * `--invoke-container-id` — идентификатор контейнера. * `--queue-service-account-id` — идентификатор сервисного аккаунта с правами на чтение из очереди сообщений. * `--invoke-container-service-account-id` — идентификатор сервисного аккаунта с правами на вызов контейнера. * `--batch-size` — размер группы сообщений. Необязательный параметр. Допустимые значения от 1 до 1000, значение по умолчанию — 1. * `--batch-cutoff` — максимальное время ожидания. Необязательный параметр. Допустимые значения от 0 до 20 секунд, значение по умолчанию — 10 секунд. Триггер группирует сообщения не дольше `batch-cutoff` и отправляет их в контейнер. Число сообщений при этом не превышает `batch-size`. Результат: ```text id: a1s5msktijh2******** folder_id: b1gmit33hgh2******** created_at: "2022-10-24T15:19:15.353909857Z" name: ymq-trigger rule: message_queue: queue_id: yrn:yc:ymq:ru-central1:b1gmit33ngh2********:my-mq service_account_id: bfbqqeo6jkh2******** batch_settings: size: "1" cutoff: 10s invoke_container: container_id: bba5jb38o8h2******** service_account_id: bfbqqeo6jkh2******** status: ACTIVE ``` - Terraform {#tf} [Terraform](https://www.terraform.io/) позволяет быстро создать облачную инфраструктуру в Yandex Cloud и управлять ею с помощью файлов конфигураций. В файлах конфигураций хранится описание инфраструктуры на языке HCL (HashiCorp Configuration Language). При изменении файлов конфигураций Terraform автоматически определяет, какая часть вашей конфигурации уже развернута, что следует добавить или удалить. Terraform распространяется под лицензией [Business Source License](https://github.com/hashicorp/terraform/blob/main/LICENSE), а [провайдер Yandex Cloud для Terraform](https://github.com/yandex-cloud/terraform-provider-yandex) — под лицензией [MPL-2.0](https://www.mozilla.org/en-US/MPL/2.0/). Подробная информация о ресурсах провайдера в документации на сайте [Terraform](https://www.terraform.io/docs/providers/yandex/index.html) или в [зеркале](../../terraform/index.md). Если у вас еще нет Terraform, [установите его и настройте провайдер Yandex Cloud](../../tutorials/infrastructure-management/terraform-quickstart.md#install-terraform). Чтобы управлять инфраструктурой с помощью Terraform от имени сервисного аккаунта или пользовательских аккаунтов: аккаунта на Яндексе, федеративного аккаунта и локального пользователя, [аутентифицируйтесь](../../terraform/authentication.md) соответствующим способом. Чтобы создать триггер для Message Queue: 1. Опишите в конфигурационном файле параметры триггера: ```hcl resource "yandex_function_trigger" "my_trigger" { name = "<имя_триггера>" container { id = "<идентификатор_контейнера>" service_account_id = "<идентификатор_сервисного_аккаунта>" } message_queue { queue_id = "<идентификатор_очереди>" service_account_id = "<идентификатор_сервисного_аккаунта>" batch_cutoff = "<максимальное_время_ожидания>" batch_size = "<размер_группы_сообщений>" } } ``` Где: * `name` — имя триггера. Формат имени: * длина — от 3 до 63 символов; * может содержать строчные буквы латинского алфавита, цифры и дефисы; * первый символ — буква, последний — не дефис. * `container` — параметры контейнера: * `id` — идентификатор контейнера. * `service_account_id` — идентификатор сервисного аккаунта с правами на вызов контейнера. * `message_queue` — параметры триггера: * `queue_id` — идентификатор очереди. Чтобы узнать идентификатор очереди: 1. В [консоли управления](https://console.yandex.cloud) перейдите в каталог, в котором находится очередь. 1. Выберите сервис **Message Queue**. 1. Выберите очередь. 1. Идентификатор очереди будет в блоке **Общая информация**, в поле **ARN**. * `service_account_id` — идентификатор сервисного аккаунта с правами на чтение из очереди сообщений. * `batch_cutoff` — максимальное время ожидания. Необязательный параметр. Допустимые значения от 0 до 20 секунд, значение по умолчанию — 10 секунд. Триггер группирует сообщения не дольше `batch-cutoff` и отправляет их в контейнер. Число сообщений при этом не превышает `batch-size`. * `batch_size` — размер группы сообщений. Необязательный параметр. Допустимые значения от 1 до 1000, значение по умолчанию — 1. Подробнее о параметрах ресурса `yandex_function_trigger` в [документации провайдера](../../terraform/resources/function_trigger.md). 1. Создайте ресурсы: 1. В терминале перейдите в директорию с конфигурационным файлом. 1. Проверьте корректность конфигурации с помощью команды: ```bash terraform validate ``` Если конфигурация является корректной, появится сообщение: ```bash Success! The configuration is valid. ``` 1. Выполните команду: ```bash terraform plan ``` В терминале будет выведен список ресурсов с параметрами. На этом этапе изменения не будут внесены. Если в конфигурации есть ошибки, Terraform на них укажет. 1. Примените изменения конфигурации: ```bash terraform apply ``` 1. Подтвердите изменения: введите в терминале слово `yes` и нажмите **Enter**. Terraform создаст все требуемые ресурсы. Проверить появление ресурсов можно в [консоли управления](https://console.yandex.cloud) или с помощью команды [CLI](../../cli/quickstart.md): ```bash yc serverless trigger list ``` - API {#api} Чтобы создать триггер для Message Queue, воспользуйтесь методом REST API [create](../triggers/api-ref/Trigger/create.md) для ресурса [Trigger](../triggers/api-ref/Trigger/index.md) или вызовом gRPC API [TriggerService/Create](../triggers/api-ref/grpc/Trigger/create.md). {% endlist %} ## Проверить результат {#check-result} {% list tabs %} - Serverless Containers Проверьте, что триггер работает корректно. Для этого посмотрите [логи контейнера](../concepts/logs.md), в них отображается информация о вызовах. - Message Queue Проверьте, что количество сообщений в очереди уменьшается. Для этого посмотрите статистику очереди: 1. В [консоли управления](https://console.yandex.cloud) перейдите в каталог, в котором создали триггер. 1. Перейдите в сервис **Message Queue**. 1. Выберите очередь, для которой создали триггер. 1. Перейдите в раздел **Мониторинг**. Посмотрите график **Сообщений в очереди**. {% endlist %} ## Полезные ссылки {#see-also} * [Создать триггер для Message Queue, который передает сообщения в функцию Cloud Functions](../../functions/operations/trigger/ymq-trigger-create.md) * [Создать триггер для Message Queue, который отправляет сообщения в WebSocket-соединения](../../api-gateway/operations/trigger/ymq-trigger-create.md)