[Документация Yandex Cloud](../../../index.md) > [Yandex Cloud Functions](../../index.md) > [Пошаговые инструкции](../index.md) > Создание триггера > Создать триггер для Message Queue # Создать триггер для Message Queue, который передает сообщения в функцию Cloud Functions Создайте [триггер](../../concepts/trigger/ymq-trigger.md) для [очереди сообщений](../../../message-queue/concepts/queue.md) сервиса Message Queue и обрабатывайте их с помощью [функции](../../concepts/function.md) Cloud Functions. {% note warning %} * Триггер можно создать только для стандартной очереди сообщений. * Триггер должен находиться в одном облаке с очередью, из которой он читает сообщения. * Для одной очереди сообщений можно создать только один триггер. {% endnote %} ## Перед началом работы {#before-begin} Для создания триггера вам понадобятся: * Функция, которую триггер будет вызывать. Если у вас нет функции: * [Создайте функцию](../function/function-create.md). * [Создайте версию функции](../function/version-manage.md). * [Сервисные аккаунты](../../../iam/concepts/users/service-accounts.md) с правами: * на вызов функции, например [functions.functionInvoker](../../security/index.md#functions-functionInvoker); * на чтение из очереди, из которой триггер будет принимать сообщения, например [ymq.reader](../../../message-queue/security/index.md#ymq-reader). Вы можете использовать один и тот же сервисный аккаунт или разные. Если у вас нет сервисного аккаунта, [создайте его](../../../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. Перейдите в сервис **Cloud Functions**. 1. На панели слева выберите ![image](../../../_assets/console-icons/gear-play.svg) **Триггеры**. 1. Нажмите кнопку **Создать триггер**. 1. В блоке **Базовые параметры**: * Введите имя и описание триггера. * В поле **Тип** выберите **Message Queue**. * В поле **Запускаемый ресурс** выберите **Функция**. 1. В блоке **Настройки сообщений Message Queue** выберите очередь сообщений и сервисный аккаунт с правами на чтение из нее. 1. В блоке **Настройки группирования сообщений** укажите: * **Время ожидания, с**. Допустимые значения от 0 до 20 секунд, значение по умолчанию — 10 секунд. * **Размер группы**. Допустимые значения от 1 до 1000, значение по умолчанию — 1. Триггер группирует сообщения не дольше указанного времени ожидания и отправляет их в функцию. Число сообщений при этом не превышает указанный размер группы. 1. В блоке **Настройки функции** выберите функцию и укажите: * [Тег версии функции](../../concepts/function.md#tag). * [Сервисный аккаунт](../../../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-function-id <идентификатор_функции> \ --invoke-function-service-account-id <идентификатор_сервисного_аккаунта> \ --batch-size <размер_группы_сообщений> \ --batch-cutoff <максимальное_время_ожидания> ``` Где: * `--name` — имя триггера. * `--queue` — идентификатор очереди. Чтобы узнать идентификатор очереди: 1. В [консоли управления](https://console.yandex.cloud) перейдите в каталог, в котором находится очередь. 1. Перейдите в сервис **Message Queue**. 1. Выберите очередь. 1. Идентификатор очереди будет в блоке **Общая информация**, в поле **ARN**. * `--invoke-function-id` — идентификатор функции. * `--queue-service-account-name` — идентификатор сервисного аккаунта с правами на чтение из очереди сообщений. * `--invoke-function-service-account-id` — идентификатор сервисного аккаунта с правами на вызов функции. * `--batch-size` — размер группы сообщений. Необязательный параметр. Допустимые значения от 1 до 1000, значение по умолчанию — 1. * `--batch-cutoff` — максимальное время ожидания. Необязательный параметр. Допустимые значения от 0 до 20 секунд, значение по умолчанию — 10 секунд. Триггер группирует сообщения не дольше `batch-cutoff` и отправляет их в функцию. Число сообщений при этом не превышает `batch-size`. Результат: ```text id: dd0cspdch6********** folder_id: aoek49ghmk********** created_at: "2019-08-28T12:14:45.762915Z" name: ymq-trigger rule: message_queue: queue_id: yrn:yc:ymq:kz1:aoek49ghmk**********:my-mq service_account_id: bfbqqeo6jk********** batch_settings: size: "1" cutoff: 10s invoke_function: function_id: b09e5lu91t********** function_tag: $latest service_account_id: bfbqqeo6j********** 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. Опишите в конфигурационном файле параметры триггера: ``` resource "yandex_function_trigger" "my_trigger" { name = "<имя_триггера>" description = "<описание_триггера>" function { id = "<идентификатор_функции>" service_account_id = "<идентификатор_сервисного_аккаунта>" } message_queue { queue_id = "<идентификатор_очереди>" service_account_id = "<идентификатор_сервисного_аккаунта>" batch_size = "<размер_группы_сообщений>" batch_cutoff = "<максимальное_время_ожидания>" } ``` Где: * `name` — имя триггера. Формат имени: * длина — от 3 до 63 символов; * может содержать строчные буквы латинского алфавита, цифры и дефисы; * первый символ — буква, последний — не дефис. * `description` — описание триггера. * `function` — параметры функции: * `id` — идентификатор функции. * `service_account_id` — идентификатор сервисного аккаунта с правами на вызов функции. * `message_queue` — параметры триггера: * `queue_id` — идентификатор очереди сообщений. Чтобы узнать идентификатор очереди: 1. В [консоли управления](https://console.yandex.cloud) перейдите в каталог, в котором находится очередь. 1. Перейдите в сервис **Message Queue**. 1. Выберите очередь. 1. Идентификатор очереди будет в блоке **Общая информация**, в поле **ARN**. * `service_account_id` — идентификатор сервисного аккаунта с правами на чтение из очереди сообщений. * `batch_size` — размер группы сообщений. Необязательный параметр. Допустимые значения от 1 до 1000, значение по умолчанию — 1. * `batch_cutoff` — максимальное время ожидания. Необязательный параметр. Допустимые значения от 0 до 20 секунд, значение по умолчанию — 10 секунд. Триггер группирует сообщения не дольше `batch-cutoff` и отправляет их в функцию. Число сообщений при этом не превышает `batch-size`. Подробнее о параметрах ресурса `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} Чтобы создать триггер для Yandex 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 %} - Cloud Functions Проверьте, что триггер работает корректно. Для этого посмотрите [логи функции](../function/function-logs.md), в них отображается информация о вызовах. - Message Queue Проверьте, что количество сообщений в очереди уменьшается. Для этого посмотрите статистику очереди: 1. В [консоли управления](https://console.yandex.cloud) Перейдите в сервис **Message Queue**. 1. Выберите очередь, для которой создали триггер. 1. Перейдите в раздел **Мониторинг**. Посмотрите график **Сообщений в очереди**. {% endlist %} ## Полезные ссылки {#see-also} * [Создать триггер для Message Queue, который передает сообщения в контейнер Serverless Containers](../../../serverless-containers/operations/ymq-trigger-create.md) * [Создать триггер для Message Queue, который отправляет сообщения в WebSocket-соединения](../../../api-gateway/operations/trigger/ymq-trigger-create.md)