Связаться с намиПодключиться

Создание триггеров, которые вызывают функции Cloud Functions для остановки ВМ и отправки уведомлений в Telegram

Статья создана
Обновлена 29 октября 2024 г.

В этом руководстве вы создадите serverless-инфраструктуру, которая при превышении пороговых значений бюджета будет останавливать запущенные виртуальные машины и отправлять пользователю уведомления в Telegram.

Триггер для бюджетов будет вызывать функцию Cloud Functions, а функция — останавливать виртуальные машины Compute Cloud и отправлять сообщение в очередь Yandex Message Queue.

Триггер для Message Queue будет передавать поступившие в очередь сообщения во вторую функцию Cloud Functions, которая будет отправлять уведомления в Telegram с помощью специально созданного бота.

Чтобы развернуть проект:

  1. Подготовьте облако к работе.
  2. Создайте бюджет.
  3. Создайте очередь Message Queue.
  4. Создайте функцию Cloud Functions, которую будет вызывать триггер для бюджетов.
  5. Создайте триггер для бюджетов.
  6. Зарегистрируйте Telegram-бота.
  7. Создайте функцию Cloud Functions, которую будет вызывать триггер для Message Queue.
  8. Создайте триггер для Message Queue.
  9. Создайте виртуальные машины Compute Cloud.
  10. Убедитесь, что по триггеру останавливаются ВМ и отправляются уведомления в Telegram.

Создавайте все указанные ресурсы Yandex Cloud в одном каталоге.

Если созданные ресурсы вам больше не нужны, удалите их.

Подготовьте облако к работе

Зарегистрируйтесь в Yandex Cloud и создайте платежный аккаунт:

  1. Перейдите в консоль управления, затем войдите в Yandex Cloud или зарегистрируйтесь.
  2. На странице Yandex Cloud Billing убедитесь, что у вас подключен платежный аккаунт, и он находится в статусе ACTIVE или TRIAL_ACTIVE. Если платежного аккаунта нет, создайте его и привяжите к нему облако.

Если у вас есть активный платежный аккаунт, вы можете создать или выбрать каталог, в котором будет работать ваша инфраструктура, на странице облака.

Подробнее об облаках и каталогах.

В стоимость ресурсов входят:

Скачайте проект

Склонируйте репозиторий c проектом:

git clone https://github.com/yandex-cloud-examples/yc-telegram-bot-with-trigger-for-budget

Создайте сервисный аккаунт и статический ключ доступа

  1. Создайте сервисный аккаунт:

    1. В консоли управления выберите ваш каталог.
    2. В списке сервисов выберите Identity and Access Management.
    3. Нажмите кнопку Создать сервисный аккаунт.
    4. В поле Имя укажите имя service-account-for-budget.
    5. В поле Роли в каталоге нажмите кнопку Добавить роль и выберите роль editor.
    6. Нажмите кнопку Создать.

    Если у вас еще нет интерфейса командной строки Yandex Cloud, установите и инициализируйте его.

    По умолчанию используется каталог, указанный в профиле CLI. Вы можете указать другой каталог с помощью параметра --folder-name или --folder-id.

    1. Создайте сервисный аккаунт service-account-for-budget:

      yc iam service-account create \
  --name service-account-for-budget

      Результат:

      done (1s)
id: ajed1o6dd581********
folder_id: b1g9d2k0itu4********
created_at: "2024-02-23T18:32:38.365175925Z"
name: service-account-for-budget

      Сохраните идентификатор (id) созданного сервисного аккаунта: он пригодится на следующем шаге.

      Подробнее о команде yc iam service-account create читайте в справочнике CLI.

    2. Назначьте сервисному аккаунту роль editor на ваш каталог:

      yc resource-manager folder add-access-binding <имя_каталога> \
  --role editor \
  --subject serviceAccount:<идентификатор_сервисного_аккаунта>

      Где:

      • <имя_каталога> — имя вашего каталога в Yandex Cloud.
      • <идентификатор_сервисного_аккаунта> — идентификатор сервисного аккаунта, сохраненный ранее.

      Результат:

      done (2s)
effective_deltas:
  - action: ADD
    access_binding:
      role_id: editor
      subject:
        id: ajed1o6dd581********
        type: serviceAccount

      Подробнее о команде yc resource-manager folder add-access-binding читайте в справочнике CLI.

    Чтобы создать сервисный аккаунт, воспользуйтесь методом REST API create для ресурса ServiceAccount или вызовом gRPC API ServiceAccountService/Create.

    Чтобы назначить сервисному аккаунту роль на каталог, воспользуйтесь методом REST API updateAccessBindings для ресурса Folder или вызовом gRPC API FolderService/UpdateAccessBindings.

  2. Создайте статический ключ доступа:

    1. В консоли управления выберите ваш каталог.

    2. В списке сервисов выберите Identity and Access Management.

    3. На панели слева выберите Сервисные аккаунты.

    4. В открывшемся списке выберите сервисный аккаунт service-account-for-budget.

    5. На верхней панели нажмите кнопку Создать новый ключ и выберите Создать статический ключ доступа.

    6. При необходимости задайте описание ключа и нажмите кнопку Создать.

    7. Сохраните идентификатор и секретный ключ.

      Внимание

      После закрытия диалога значение ключа будет недоступно.

    Выполните команду:

    yc iam access-key create \
  --service-account-name service-account-for-budget

    Результат:

    access_key:
  id: aje75gg0rp8k********
  service_account_id: ajed1o6dd581********
  created_at: "2024-02-23T18:36:41.061060561Z"
  key_id: YCAJEK_r3Z_EvxRAR********
secret: YCPQhHFMx6rnWXQC9ID425gk3V9YnUc********

    Сохраните идентификатор key_id и секретный ключ secret. Получить значение этого ключа снова будет невозможно.

    Подробнее о команде yc iam access-key create читайте в справочнике CLI.

    Чтобы создать ключ доступа, воспользуйтесь методом REST API create для ресурса AccessKey или вызовом gRPC API AccessKeyService/Create.

Создайте облачную сеть и подсеть

  1. В консоли управления выберите ваш каталог.
  2. В списке сервисов выберите Virtual Private Cloud.
  3. Справа сверху нажмите кнопку Создать сеть.
  4. В поле Имя укажите my-sample-network.
  5. В поле Дополнительно отключите опцию Создать подсети.
  6. Нажмите кнопку Создать сеть.
  7. На панели слева выберите Подсети.
  8. Справа сверху нажмите кнопку Создать.
  9. В поле Имя укажите sample-subnet-ru-central1-b.
  10. В поле Зона выберите зону доступности ru-central1-b.
  11. В поле Сеть выберите облачную сеть my-sample-network.
  12. В поле CIDR укажите 192.168.1.0/24.
  13. Нажмите кнопку Создать подсеть.

  1. Создайте сеть my-sample-network:

    yc vpc network create my-sample-network

    Результат:

    id: enp2gjcvrd59********
folder_id: b1g9d2k0itu4********
created_at: "2024-02-23T18:39:17Z"
name: my-sample-network
default_security_group_id: enp9uobl2c33********

    Подробнее о команде yc vpc network create читайте в справочнике CLI.

  2. Создайте подсеть sample-subnet-ru-central1-b в зоне доступности ru-central1-b:

    yc vpc subnet create sample-subnet-ru-central1-b \
  --zone ru-central1-b \
  --network-name my-sample-network \
  --range 192.168.1.0/24

    Результат:

    id: e2l1ejkvq4jv********
folder_id: b1g9d2k0itu4********
created_at: "2024-02-23T18:40:26Z"
name: sample-subnet-ru-ru-central1-b
network_id: enp2gjcvrd59********
zone_id: ru-central1-b
v4_cidr_blocks:
  - 192.168.1.0/24

    Подробнее о команде yc vpc subnet create читайте в справочнике CLI.

  1. Чтобы создать сеть, воспользуйтесь методом REST API create для ресурса Network или вызовом gRPC API NetworkService/Create.

  2. Чтобы создать подсеть, воспользуйтесь методом REST API create для ресурса Subnet или вызовом gRPC API SubnetService/Create.

Создайте бюджет

Чтобы создать бюджет, у пользователя должна быть роль editor. Чтобы получать оповещения, достаточно роли viewer.

  1. Перейдите в сервис Yandex Cloud Billing.

  2. Выберите платежный аккаунт.

  3. В секции Общие сведения, в поле Идентификатор, скопируйте идентификатор платежного аккаунта. Он пригодится при создании триггера для бюджетов.

  4. Перейдите на вкладку Бюджеты и нажмите кнопку Создать бюджет.

  5. В блоке Общая информация укажите:

    • Имя — vm-budget.

    • Тип — К оплате.

    • Сумма — сумму расходов на потребление, например 10 ₽.

    • Период расчета — Месячный.

    • Дата окончания — дату окончания действия бюджета.

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

    • Уведомить — выберите себя.

  6. В блоке Область действия выберите каталог, в котором ведете работу, и сервис Compute Cloud.

  7. В блоке Пороги укажите пороговые значения в процентах, при достижении которых:

    • Указанным пользователям будут приходить уведомления.
    • Будет срабатывать триггер для бюджетов.

    Например, можно указать два порога — 50% и 100%.

  8. Нажмите кнопку Создать.

  9. В открывшемся окне появился новый бюджет vm-budget. В поле Идентификатор скопируйте идентификатор созданного бюджета. Он пригодится позднее при создании триггера.

Чтобы создать бюджет, воспользуйтесь методом create для ресурса Budget или вызовом gRPC API BudgetService/Create.

Создайте очередь Message Queue

  1. В консоли управления выберите ваш каталог.

  2. Выберите сервис Message Queue.

  3. Нажмите кнопку Создать очередь.

  4. В блоке Базовые параметры укажите:

    • Имя — budget-queue.
    • Тип — Стандартная.

    Остальные параметры оставьте без изменений.

  5. Нажмите кнопку Создать.

  6. Нажмите на имя созданной очереди budget-queue и в открывшемся окне скопируйте значения полей:

    • URL — URL очереди.
    • ARN — идентификатор очереди.

    Сохраните эти значения: они пригодятся на следующих шагах.

  1. Установите и настройте AWS CLI. При настройке используйте созданный ранее статический ключ доступа.

  2. Создайте очередь:

    aws sqs create-queue \
  --queue-name budget-queue \
  --endpoint https://message-queue.api.cloud.yandex.net/

    Результат:

    {
    "QueueUrl": "https://message-queue.api.cloud.yandex.net/b1glti4eser3********/dj600000001c********/budget-queue"
}

    Сохраните значение URL очереди QueueUrl, оно пригодится на следующих шагах.

  3. Получите идентификатор очереди, указав сохраненный ранее URL в параметре --queue-url:

    aws sqs get-queue-attributes \
  --queue-url <URL_очереди> \
  --attribute-names QueueArn \
  --endpoint https://message-queue.api.cloud.yandex.net/

    Результат:

    {
    "Attributes": {
        "QueueArn": "yrn:yc:ymq:ru-central1:b1g9d2k0itu4********:budget-queue"
    }
}

    Сохраните идентификатор очереди QueueArn, он пригодится на следующих шагах.

Создайте функцию Cloud Functions, которую будет вызывать триггер для бюджетов

  1. Подготовьте ZIP-архив с кодом функции.

    Перейдите в директорию yc-telegram-bot-with-trigger-for-budget/steps/4-create-budget-trigger-handler и добавьте файлы в ZIP-архив src_bgt.zip:

    zip src_bgt.zip budget_trigger_handler.go go.mod

  2. Создайте функцию:

    1. В консоли управления выберите ваш каталог.

    2. Выберите сервис Cloud Functions.

    3. Создайте функцию:

      1. Нажмите кнопку Создать функцию.
      2. Введите имя функции budget-trigger-handler.
      3. Нажмите кнопку Создать.

    4. Создайте версию функции:

      1. Выберите среду выполнения golang119, выключите опцию Добавить файлы с примерами кода и нажмите кнопку Продолжить.

      2. Укажите способ загрузки ZIP-архив и прикрепите архив src_bgt.zip, который создали на предыдущем шаге.

      3. Укажите точку входа budget_trigger_handler.Handler.

      4. В блоке Параметры укажите:

        • Таймаут, c — 5;
        • Память — 512 МБ;
        • Сервисный аккаунт — service-account-for-budget;
        • Переменные окружения:
          • FOLDER_ID — идентификатор каталога, в котором вы хотите останавливать виртуальные машины.
          • TAG — target-for-stop.
          • AWS_ACCESS_KEY_ID — значение идентификатора статического ключа доступа, сохраненное ранее.
          • AWS_SECRET_ACCESS_KEY — значение секретного ключа статического ключа доступа, сохраненное ранее.
          • BUDGET_QUEUE_URL — значение URL очереди budget-queue, сохраненное ранее.

      5. Нажмите кнопку Сохранить изменения.

    1. Создайте функцию budget-trigger-handler:

      yc serverless function create \
  --name budget-trigger-handler

      Результат:

      id: d4e4aigfdm0b********
folder_id: b1g9d2k0itu4********
created_at: "2024-02-23T20:15:06.456Z"
name: budget-trigger-handler
http_invoke_url: https://functions.yandexcloud.net/d4e4aigfdm0b********
status: ACTIVE

      Подробнее о команде yc serverless function create читайте в справочнике CLI.

    2. Создайте версию функции budget-trigger-handler:

      yc serverless function version create \
  --function-name budget-trigger-handler \
  --memory=512m \
  --execution-timeout=5s \
  --runtime=golang119 \
  --entrypoint=budget_trigger_handler.Handler \
  --service-account-id=<идентификатор_сервисного_аккаунта> \
  --environment FOLDER_ID=<идентификатор_каталога> \
  --environment TAG=target-for-stop \
  --environment AWS_ACCESS_KEY_ID=<идентификатор_статического_ключа> \
  --environment AWS_SECRET_ACCESS_KEY=<значение_секретного_ключа> \
  --environment BUDGET_QUEUE_URL=<URL_очереди> \
  --source-path="./src_bgt.zip"

      Где:

      • --service-account-id — идентификатор сервисного аккаунта service-account-for-budget, сохраненный ранее. Сервисный аккаунт будет использоваться для вызова функции.

      • --environment — переменные окружения:

        • FOLDER_ID — идентификатор каталога, в котором вы хотите останавливать виртуальные машины.
        • AWS_ACCESS_KEY_ID — значение идентификатора статического ключа доступа, сохраненное ранее.
        • AWS_SECRET_ACCESS_KEY — значение секретного ключа статического ключа доступа, сохраненное ранее.
        • BUDGET_QUEUE_URL — значение URL очереди budget-queue, сохраненное ранее.

      • --source-path — путь к ZIP-архиву src_bgt.zip.

      Результат:

      done (2m32s)
id: d4em5gaeev2b********
function_id: d4e4aigfdm0b********
created_at: "2024-02-23T20:31:18.458Z"
runtime: golang119
entrypoint: budget_trigger_handler.Handler
resources:
  memory: "536870912"
execution_timeout: 5s
service_account_id: ajed1o6dd581********
image_size: "23977984"
status: ACTIVE
tags:
  - $latest
environment:
  AWS_ACCESS_KEY_ID: YCAJEK_r3Z_EvxRAR********
  AWS_SECRET_ACCESS_KEY: YCPQhHFMx6rnWXQC9ID425gk3V9YnUc0********
  BUDGET_QUEUE_URL: https://message-queue.api.cloud.yandex.net/b1glti4eser3********/dj600000001c********/budget-queue
  FOLDER_ID: b1g9d2k0itu4********
  TAG: target-for-stop
log_options:
  folder_id: b1g9d2k0itu4********

      Подробнее о команде yc serverless function version create читайте в справочнике CLI.

    Чтобы создать функцию, воспользуйтесь методом create для ресурса Function или вызовом gRPC API FunctionService/Create.

    Чтобы создать версию функцию, воспользуйтесь методом createVersion для ресурса Function или вызовом gRPC API FunctionService/CreateVersion.

Создайте триггер для бюджетов

  1. В консоли управления выберите ваш каталог.

  2. Выберите сервис Cloud Functions.

  3. На панели слева выберите Триггеры.

  4. Нажмите кнопку Создать триггер.

  5. В блоке Базовые параметры:

    • В поле Имя укажите имя триггера trigger-for-budget-from-yc.
    • В поле Тип выберите Бюджет.
    • В поле Запускаемый ресурс выберите Функция.

  6. В блоке Настройки бюджета выберите ваш платежный аккаунт и бюджет vm-budget, который создали ранее.

  7. В блоке Настройки функции выберите функцию budget-trigger-handler и укажите сервисный аккаунт service-account-for-budget. От его имени будет вызываться функция.

  8. Нажмите кнопку Создать триггер.

Чтобы создать триггер для бюджетов, который вызывает функцию budget-trigger-handler, выполните команду:

yc serverless trigger create billing-budget \
  --name trigger-for-budget-from-yc \
  --invoke-function-name budget-trigger-handler \
  --invoke-function-service-account-id <идентификатор_сервисного_аккаунта>  \
  --billing-account-id <идентификатор_платежного_аккаунта>  \
  --budget-id <идентификатор_бюджета>

Где:

  • --invoke-function-service-account-id — идентификатор сервисного аккаунта service-account-for-budget, сохраненный ранее. Сервисный аккаунт будет использоваться для вызова функции.
  • --billing-account-id — идентификатор платежного аккаунта, сохраненный ранее при создании бюджета.
  • --budget-id — идентификатор бюджета vm-budget, сохраненный ранее.

Результат:

id: a1sjrukc64hs********
folder_id: b1g9d2k0itu4********
created_at: "2024-02-23T21:20:03.308963151Z"
name: trigger-for-budget-from-yc
rule:
  billing_budget:
    billing_account_id: dn276oa9slgm********
    budget_id: dn2jr6qt0q9k********
    invoke_function:
      function_id: d4e4aigfdm0b********
      function_tag: $latest
      service_account_id: ajed1o6dd581********
status: ACTIVE

Подробнее о команде yc serverless trigger create billing-budget читайте в справочнике CLI.

Чтобы создать триггер для бюджетов, воспользуйтесь методом create для ресурса Trigger или вызовом gRPC API TriggerService/Create.

Зарегистрируйте Telegram-бота

  1. Зарегистрируйте бота в Telegram и получите токен:

    1. Для регистрации нового бота запустите в Telegram бота BotFather и отправьте команду:

      /newbot

      Результат:

      Alright, a new bot. How are we going to call it? Please choose a name for your bot.

    2. В следующем сообщении укажите имя создаваемого бота, например YC VM budget informer. Это имя увидят пользователи при общении с ботом.

      Результат:

      Good. Now let's choose a username for your bot. It must end in `bot`. Like this, for example: TetrisBot or tetris_bot.

    3. Укажите имя пользователя создаваемого бота, например YCVMBudgetInformerBot. По имени пользователя можно будет найти бота в Telegram. Имя пользователя должно оканчиваться на ...Bot или ..._bot. В результате вы получите токен для HTTP API.

      Результат:

      Done! Congratulations on your new bot. You will find it at t.me/YCVMBudgetInformerBot. You can now add a description, about section and profile picture for your bot, see /help for a list of commands. By the way, when you've finished creating your cool bot, ping our Bot Support if you want a better username for it. Just make sure the bot is fully operational before you do this.

Use this token to access the HTTP API:
715063****:AAGuj****-0VrIm7j9i****************
Keep your token secure and store it safely, it can be used by anyone to control your bot.

For a description of the Bot API, see this page: https://core.telegram.org/bots/api

  2. Получите идентификатор ChatID пользователя, которому бот будет направлять уведомления:

    1. Сохраните полученный на предыдущем шаге API-токен в переменную окружения TELEGRAM_BOT_API_TOKEN:

      export TELEGRAM_BOT_API_TOKEN=<Telegram_API-токен>

    2. Перейдите в директорию yc-telegram-bot-with-trigger-for-budget/steps/6-register-telegram-bot и выполните команду:

      go run .

      При необходимости предварительно установите пакеты Go и telegram_bot.

      Команда запустит Telegram-бота, который на любое сообщение будет возвращать идентификатор ChatID текущего пользователя.

    3. В Telegram найдите созданного вами бота по имени пользователя (например, YCVMBudgetInformerBot) и отправьте ему любое сообщение.

      Результат:

      59529*****

      Сохраните полученный идентификатор ChatID. Он пригодится вам позднее.

    4. Вернитесь в терминал и завершите работу бота с помощью сочетания клавиш Ctrl + C.

Создайте функцию Cloud Functions, которую будет вызывать триггер для Message Queue

  1. Подготовьте ZIP-архив с кодом функции.

    Перейдите в директорию yc-telegram-bot-with-trigger-for-budget/steps/7-create-budget-queue-handler и добавьте файлы в ZIP-архив src_queue.zip:

    zip src_queue.zip budget_queue_handler.go utils.go go.mod

  2. Создайте функцию:

    1. В консоли управления выберите ваш каталог.

    2. Выберите сервис Cloud Functions.

    3. Создайте функцию:

      1. Нажмите кнопку Создать функцию.
      2. Введите имя функции budget-queue-handler.
      3. Нажмите кнопку Создать.

    4. Создайте версию функции:

      1. Выберите среду выполнения golang119, выключите опцию Добавить файлы с примерами кода и нажмите кнопку Продолжить.

      2. Укажите способ загрузки ZIP-архив и прикрепите архив src_queue.zip, который создали на предыдущем шаге.

      3. Укажите точку входа budget_queue_handler.HandleBudgetQueueMessage.

      4. В блоке Параметры укажите:

        • Таймаут, c — 5;
        • Память — 512 МБ;
        • Сервисный аккаунт — service-account-for-budget;
        • Переменные окружения:
          • TELEGRAM_BOT_API_TOKEN — API-токен Telegram-бота, сохраненный ранее.
          • TELEGRAM_BOT_CHAT_ID — идентификатор ChatID пользователя Telegram, сохраненный ранее.

      5. Нажмите кнопку Сохранить изменения.

    1. Создайте функцию budget-queue-handler:

      yc serverless function create \
  --name budget-queue-handler

      Результат:

      id: d4e6r2g9trt5********
folder_id: b1g9d2k0itu4********
created_at: "2024-02-24T07:36:04.092Z"
name: budget-queue-handler
http_invoke_url: https://functions.yandexcloud.net/d4e6r2g9trt5********
status: ACTIVE

    2. Создайте версию функции budget-queue-handler:

      yc serverless function version create \
  --function-name budget-queue-handler \
  --memory 512m \
  --execution-timeout 5s \
  --runtime golang119 \
  --entrypoint budget_queue_handler.HandleBudgetQueueMessage \
  --service-account-id <идентификатор_сервисного_аккаунта> \
  --environment TELEGRAM_BOT_API_TOKEN=<API-токен_Telegram-бота> \
  --environment TELEGRAM_BOT_CHAT_ID=<ChatID_пользователя_Telegram> \
  --source-path="./src_queue.zip"

      Где:

      • --service-account-id — идентификатор сервисного аккаунта service-account-for-budget, сохраненный ранее. Сервисный аккаунт будет использоваться для вызова функции.

      • --environment — переменные окружения:

        • TELEGRAM_BOT_API_TOKEN — API-токен Telegram-бота, сохраненный ранее.
        • TELEGRAM_BOT_CHAT_ID — идентификатор ChatID пользователя Telegram, сохраненный ранее.

      • --source-path — путь к ZIP-архиву src_queue.zip.

      Результат:

      done (29s)
id: d4e41l4gj7rk********
function_id: d4e6r2g9trt5********
created_at: "2024-02-24T07:43:32.464Z"
runtime: golang119
entrypoint: budget_queue_handler.HandleBudgetQueueMessage
resources:
  memory: "536870912"
execution_timeout: 5s
service_account_id: ajed1o6dd581********
image_size: "5464064"
status: ACTIVE
tags:
  - $latest
environment:
  TELEGRAM_BOT_API_TOKEN: 7150638333:AAGujjyua-0VrIm7j9iG3mOxmz1********
  TELEGRAM_BOT_CHAT_ID: "59529*****"
log_options:
  folder_id: b1g9d2k0itu4********

    Чтобы создать функцию, воспользуйтесь методом create для ресурса Function или вызовом gRPC API FunctionService/Create.

    Чтобы создать версию функцию, воспользуйтесь методом createVersion для ресурса Function или вызовом gRPC API FunctionService/CreateVersion.

Создайте триггер для Message Queue

  1. В консоли управления выберите ваш каталог.

  2. Выберите сервис Cloud Functions.

  3. На панели слева выберите Триггеры.

  4. Нажмите кнопку Создать триггер.

  5. В блоке Базовые параметры:

    • В поле Имя укажите имя триггера budget-queue-trigger.
    • В поле Тип выберите Message Queue.
    • В поле Запускаемый ресурс выберите Функция.

  6. В блоке Настройки сообщений Message Queue выберите созданные ранее ресурсы:

    • В поле Очередь сообщений — budget-queue.
    • В поле Сервисный аккаунт — service-account-for-budget.

  7. В блоке Настройки функции выберите функцию budget-queue-handler и укажите сервисный аккаунт service-account-for-budget. От его имени будет вызываться функция.

  8. Нажмите кнопку Создать триггер.

Чтобы создать триггер для Message Queue, который вызывает функцию budget-queue-handler, выполните команду:

yc serverless trigger create message-queue \
  --name budget-queue-trigger \
  --queue <идентификатор_очереди> \
  --queue-service-account-id <идентификатор_сервисного_аккаунта> \
  --invoke-function-name budget-queue-handler \
  --invoke-function-service-account-id <идентификатор_сервисного_аккаунта> \
  --batch-size 1 \
  --batch-cutoff 10s

Где:

  • --queue — идентификатор очереди budget-queue, сохраненный при ее создании.
  • --queue-service-account-id — идентификатор сервисного аккаунта service-account-for-budget, сохраненный ранее. Сервисный аккаунт будет использоваться для чтения сообщений из очереди.
  • --invoke-function-service-account-id — идентификатор сервисного аккаунта service-account-for-budget, сохраненный ранее. Сервисный аккаунт будет использоваться для вызова функции.

Результат:

id: a1sqq6341kvh********
folder_id: b1g9d2k0itu4********
created_at: "2024-02-24T08:35:39.296084612Z"
name: budget-queue-trigger
rule:
  message_queue:
    queue_id: yrn:yc:ymq:ru-central1:b1g9d2k0itu4********:budget-queue
    service_account_id: ajed1o6dd581********
    batch_settings:
      size: "1"
      cutoff: 10s
    invoke_function:
      function_id: d4e6r2g9trt5********
      function_tag: $latest
      service_account_id: ajed1o6dd581********
status: ACTIVE

Подробнее о команде yc serverless trigger create message-queue читайте в справочнике CLI.

Чтобы создать триггер для Message Queue, воспользуйтесь методом create для ресурса Trigger или вызовом gRPC API TriggerService/Create.

Создайте виртуальные машины Compute Cloud

  1. В консоли управления выберите каталог, в котором будет создана ВМ.

  2. В списке сервисов выберите Compute Cloud.

  3. На панели слева выберите Виртуальные машины.

  4. Нажмите кнопку Создать виртуальную машину.

  5. В блоке Образ загрузочного диска выберите Ubuntu 22.04 LTS.

  6. В блоке Расположение выберите зону доступности ru-central1-b.

  7. В блоке Сетевые настройки:

    • В поле Подсеть выберите созданную ранее подсеть sample-subnet-ru-central1-b.
    • В поле Публичный адрес выберите Автоматически.

  8. В блоке Доступ выберите SSH-ключ и укажите данные для доступа к ВМ:

    • В поле Логин введите имя пользователя, например, yc-user.

    • В поле SSH-ключ выберите SSH-ключ, сохраненный в вашем профиле пользователя организации.

      Если в вашем профиле нет сохраненных SSH-ключей или вы хотите добавить новый ключ:

      • Нажмите кнопку Добавить ключ.
      • Задайте имя SSH-ключа.
      • Загрузите или вставьте содержимое открытого SSH-ключа. Пару SSH-ключей для подключения к ВМ по SSH необходимо создать самостоятельно.
      • Нажмите кнопку Добавить.

      SSH-ключ будет добавлен в ваш профиль пользователя организации.

      Если в организации отключена возможность добавления пользователями SSH-ключей в свои профили, добавленный открытый SSH-ключ будет сохранен только в профиле пользователя создаваемой виртуальной машины.

  9. В блоке Общая информация:

    • Укажите имя ВМ: target-instance-1.
    • В поле Метки нажмите кнопку Добавить метку и введите target-for-stop:true. Нажмите Enter, чтобы сохранить метку.

  10. Нажмите кнопку Создать ВМ.

Создайте виртуальную машину:

yc compute instance create \
  --name target-instance-1 \
  --labels target-for-stop=true \
  --zone ru-central1-b \
  --network-interface subnet-name=sample-subnet-ru-central1-b,nat-ip-version=ipv4 \
  --create-boot-disk image-folder-id=standard-images,image-family=ubuntu-2204-lts \
  --ssh-key ~/.ssh/<имя_ключа>.pub

Где --ssh-key — путь к публичному SSH-ключу. Для этого ключа на виртуальной машине будет автоматически создан пользователь yc-user.

Результат:

done (39s)
id: epdbhj4gssbp********
folder_id: b1g9d2k0itu4********
created_at: "2024-02-24T09:29:16Z"
name: target-instance-1
labels:
  target-for-stop: "true"
zone_id: ru-central1-b
platform_id: standard-v2
resources:
  memory: "2147483648"
  cores: "2"
  core_fraction: "100"
status: RUNNING
metadata_options:
  gce_http_endpoint: ENABLED
  aws_v1_http_endpoint: ENABLED
  gce_http_token: ENABLED
  aws_v1_http_token: DISABLED
boot_disk:
  mode: READ_WRITE
  device_name: epd4uuhf52oe********
  auto_delete: true
  disk_id: epd4uuhf52oe********
network_interfaces:
  - index: "0"
    mac_address: d0:0d:b8:**:**:**
    subnet_id: e2l1ejkvq4jv********
    primary_v4_address:
      address: 192.168.1.9
      one_to_one_nat:
        address: 158.160.**.***
        ip_version: IPV4
serial_port_settings:
  ssh_authorization: INSTANCE_METADATA
gpu_settings: {}
fqdn: epdbhj4gssbp********.auto.internal
scheduling_policy: {}
network_settings:
  type: STANDARD
placement_policy: {}

Подробнее о команде yc compute instance create читайте в справочнике CLI.

Чтобы создать виртуальную машину, воспользуйтесь методом REST API create для ресурса Instance или вызовом gRPC API InstanceService/Create.

Аналогичным способом создайте еще две виртуальные машины — target-instance-2 и target-instance-3. У последней ВМ для метки target-for-stop укажите значение false.

Убедитесь, что по триггеру останавливаются ВМ и отправляются уведомления в Telegram

Дождитесь, когда будут достигнуты пороговые значения, которые вы указали в бюджете. Убедитесь, что при достижении пороговых значений бюджета виртуальные машины target-instance-1 и target-instance-2 остановились, а Telegram-бот отправил вам уведомление о срабатывании триггера для бюджета:

Budget trigger was triggered!

Как удалить созданные ресурсы

Чтобы перестать платить за созданные ресурсы:

  1. Удалите триггеры Cloud Functions.
  2. Удалите функции Cloud Functions.
  3. Удалите виртуальные машины.
  4. Удалите очередь Message Queue.
  5. Удалите подсеть, затем удалите облачную сеть.
Предыдущая
Развертывание отказоустойчивой архитектуры с прерываемыми ВМ
Следующая
Начало работы с Terraform