Создать триггер для Telegram, который вызывает функцию Cloud Functions
Создайте триггер для Telegram, который будет вызывать функцию Cloud Functions, когда Telegram-бот получает новое обновление.
Перед началом работы
Для создания триггера вам понадобятся:
-
Telegram-бот и его токен. Если у вас нет бота, создайте его через @BotFather
и скопируйте выданный токен. -
Функция, которую триггер будет вызывать. Если у вас нет функции:
-
(Опционально) Очередь Dead Letter Queue, куда будут перенаправляться сообщения, которые не смогла обработать функция. Если у вас нет очереди, создайте ее.
-
Сервисные аккаунты с правами:
- на вызов функции;
- (опционально) на запись в очередь Dead Letter Queue.
Вы можете использовать один и тот же сервисный аккаунт или разные. Если у вас нет сервисного аккаунта, создайте его.
Создать триггер
Примечание
Триггер начинает работать в течение 5 минут после создания.
-
В консоли управления
перейдите в каталог, в котором хотите создать триггер. -
Перейдите
в сервис Cloud Functions. -
На панели слева выберите
Триггеры. -
Нажмите кнопку Создать триггер.
-
В блоке Базовые параметры:
-
(Опционально) Введите имя и описание триггера.
-
В поле Метки нажмите кнопку Добавить метку и укажите метки в формате
ключ: значение. -
В поле Тип выберите
Telegram.
-
-
В блоке Настройки Telegram укажите токен Telegram-бота, полученный от @BotFather
. -
В блоке Настройки группирования сообщений укажите:
- Время ожидания, с. Допустимые значения от 1 до 60 секунд, значение по умолчанию — 1 секунда.
- Размер группы. Допустимые значения от 1 до 100, значение по умолчанию — 1.
Триггер группирует сообщения не дольше указанного времени ожидания и отправляет их в функцию. Число сообщений при этом не превышает указанный размер группы.
-
В блоке Приёмники:
-
В поле Тип приёмника выберите
Функция. -
В блоке Настройки функции выберите функцию и укажите:
- Тег версии функции.
- Сервисный аккаунт, от имени которого будет вызываться функция.
-
(Опционально) В блоке Настройки повторных запросов:
- В поле Интервал укажите время, через которое будет сделан повторный вызов функции, если текущий завершился неуспешно. Допустимые значения — от 10 до 60 секунд, значение по умолчанию — 10 секунд.
- В поле Количество попыток укажите количество повторных вызовов функции, которые будут сделаны, прежде чем триггер отправит сообщение в Dead Letter Queue. Допустимые значения — от 1 до 5, значение по умолчанию — 1.
-
(Опционально) В блоке Настройки Dead Letter Queue выберите очередь Dead Letter Queue и сервисный аккаунт с правами на запись в нее.
-
(Опционально) В поле Фильтр укажите jq-шаблон для фильтрации событий, передаваемых в приемник. Если фильтр не указан, в приемник передаются все события.
-
(Опционально) В поле Шаблон преобразования укажите jq-шаблон для преобразования событий перед отправкой в приемник. Если шаблон не указан, события не преобразуются.
-
-
Нажмите кнопку Создать триггер.
Terraform
Terraform распространяется под лицензией Business Source License
Подробная информация о ресурсах провайдера в документации на сайте Terraform
Если у вас еще нет Terraform, установите его и настройте провайдер Yandex Cloud.
Чтобы управлять инфраструктурой с помощью Terraform от имени сервисного аккаунта или пользовательских аккаунтов: аккаунта на Яндексе, федеративного аккаунта и локального пользователя, аутентифицируйтесь соответствующим способом.
Чтобы создать триггер для Telegram, который вызывает функцию:
-
Опишите в конфигурационном файле параметры триггера:
resource "yandex_serverless_triggers" "my_trigger" { name = "<имя_триггера>" source { telegram_message { bot_token = "<токен_Telegram-бота>" allowed_updates = [ "<тип_обновления>", "<тип_обновления>" ] force = true } } action { invoke_function { function_id = "<идентификатор_функции>" function_tag = "<тег_версии_функции>" service_account_id = "<идентификатор_сервисного_аккаунта>" } filter { jq = ".message.text | startswith(\"/\")" } transformer { jq = ".message" } retry_policy { retry_attempts = "<количество_повторных_отправок>" interval = "<интервал_между_повторными_отправками>" } dead_letter { dead_letter_queue { queue_arn = "<ARN_очереди_Dead_Letter_Queue>" service_account_id = "<идентификатор_сервисного_аккаунта>" } } } }Где:
-
name— имя триггера. Формат имени:- длина — от 3 до 63 символов;
- может содержать строчные буквы латинского алфавита, цифры и дефисы;
- первый символ — буква, последний — не дефис.
-
description— описание триггера. Необязательный параметр. -
labels— метки триггера в форматеключ:значение. Необязательный параметр.
-
source— параметры источника событий:-
telegram_message— параметры Telegram-бота:bot_token— токен Telegram-бота, полученный от @BotFather . Значение передается только при создании и изменении триггера и не возвращается в выводе Terraform. При изменении токена вебхук регистрируется заново.allowed_updates— список типов обновлений Telegram , на которые подписывается бот. Необязательный параметр, значение по умолчанию —[ "message" ].force— переустановка вебхука, если для бота уже настроен вебхук на другой URL. Без этого параметра создание триггера завершится ошибкой. Если вебхук уже указывает на этот триггер, параметр ничего не меняет. Необязательный параметр.
-
-
action— параметры приемника. Блок можно указать несколько раз, чтобы триггер вызывал несколько ресурсов, в том числе разных типов. Максимальное количество ресурсов ограничено лимитами.-
invoke_function— параметры функции:function_id— идентификатор функции.function_tag— тег версии функции. Необязательный параметр. Если параметр не указан, вызывается последняя версия функции.service_account_id— идентификатор сервисного аккаунта с правами на вызов функции.
-
filter— фильтрация событий перед отправкой в приемник. Необязательный блок.jq— jq-шаблон для фильтрации событий, передаваемых в приемник. Если не указан, в приемник передаются все события.
-
transformer— преобразование событий перед отправкой в приемник. Необязательный блок.jq— jq-шаблон для преобразования событий перед отправкой в приемник. Если не указан, события не преобразуются.
-
retry_policy— параметры повторных запросов. Необязательный блок.interval— время, через которое будет сделана повторная отправка события, если текущая завершилась неуспешно.retry_attempts— количество повторных отправок, которые будут сделаны, прежде чем триггер отправит событие в Dead Letter Queue.
-
dead_letter— параметры очереди сообщений Dead Letter Queue. Необязательный блок.-
dead_letter_queue— параметры очереди:queue_arn— ARN очереди.service_account_id— идентификатор сервисного аккаунта с правами на запись в очередь.message_attributes— атрибуты, которые будут добавлены к каждому сообщению в очереди, в форматеключ:значение. Необязательный параметр.
-
-
Подробнее о параметрах ресурса
yandex_serverless_triggersв документации провайдера. -
-
Создайте ресурсы:
-
В терминале перейдите в директорию с конфигурационным файлом.
-
Проверьте корректность конфигурации с помощью команды:
terraform validateЕсли конфигурация является корректной, появится сообщение:
Success! The configuration is valid. -
Выполните команду:
terraform planВ терминале будет выведен список ресурсов с параметрами. На этом этапе изменения не будут внесены. Если в конфигурации есть ошибки, Terraform на них укажет.
-
Примените изменения конфигурации:
terraform apply -
Подтвердите изменения: введите в терминале слово
yesи нажмите Enter.
Terraform создаст все требуемые ресурсы. Проверить появление ресурсов можно в консоли управления
или с помощью команды CLI:yc serverless trigger list -
Проверить результат
Проверьте, что триггер работает корректно. Для этого посмотрите логи функции, в них отображается информация о вызовах.