Создать триггер для Object Storage, который вызывает контейнер Serverless Containers

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

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

Чтобы создать триггер, который вызывает контейнер, выполните команду:

yc serverless trigger create object-storage \
  --name <имя_триггера> \
  --bucket-id <идентификатор_бакета> \
  --prefix '<префикс_ключа_объекта>' \
  --suffix '<суффикс_ключа_объекта>' \
  --events 'create-object','delete-object','update-object' \
  --batch-size <размер_группы_событий> \
  --batch-cutoff <максимальное_время_ожидания> \
  --invoke-container-id <идентификатор_контейнера> \
  --invoke-container-service-account-id <идентификатор_сервисного_аккаунта> \
  --retry-attempts <количество_повторных_вызовов> \
  --retry-interval <интервал_между_повторными_вызовами> \
  --dlq-queue-id <идентификатор_очереди_Dead_Letter_Queue> \
  --dlq-service-account-id <идентификатор_сервисного_аккаунта>

Где:

• --name — имя триггера.
• --bucket-id — идентификатор бакета.
• --prefix — префикс ключа объекта в бакете. Необязательный параметр. Используется для фильтрации.
• --suffix — суффикс ключа объекта в бакете. Необязательный параметр. Используется для фильтрации.
• --events — события, после наступления которых триггер запускается.

• --batch-size — размер группы событий. Необязательный параметр. Допустимые значения от 1 до 10, значение по умолчанию — 1.
• --batch-cutoff — максимальное время ожидания. Необязательный параметр. Допустимые значения от 1 до 60 секунд, значение по умолчанию — 1 секунда. Триггер группирует события не дольше batch-cutoff и отправляет их в контейнер. Число событий при этом не превышает batch-size.

• --invoke-container-id — идентификатор контейнера.
• --invoke-container-service-account-id — идентификатор сервисного аккаунта с правами на вызов контейнера.
• --retry-attempts — количество повторных вызовов, которые будут сделаны, прежде чем триггер отправит сообщение в Dead Letter Queue. Необязательный параметр. Допустимые значения — от 1 до 5, значение по умолчанию — 1.
• --retry-interval — время, через которое будет сделан повторный вызов контейнера, если текущий завершился неуспешно. Необязательный параметр. Допустимые значения — от 10 до 60 секунд, значение по умолчанию — 10 секунд.
• --dlq-queue-id — идентификатор очереди Dead Letter Queue. Необязательный параметр.
• --dlq-service-account-id — идентификатор сервисного аккаунта с правами на запись в очередь Dead Letter Queue. Необязательный параметр.

Результат:

id: a1s5msktijh2********
folder_id: b1gmit33hgh2********
created_at: "2022-10-24T15:19:15.353909857Z"
name: os-trigger
rule:
  object_storage:
    event_type:
    - OBJECT_STORAGE_EVENT_TYPE_CREATE_OBJECT
    - OBJECT_STORAGE_EVENT_TYPE_DELETE_OBJECT
    - OBJECT_STORAGE_EVENT_TYPE_UPDATE_OBJECT
    bucket_id: s3-for-trigger
    prefix: dev
    suffix: 12.jpg
    batch_settings:
      size: "3"
      cutoff: 20s
    invoke_container:
      container_id: bba5jb38o8h2********
      service_account_id: aje3932acdh2********
      retry_settings:
        retry_attempts: "1"
        interval: 10s
      dead_letter_queue:
        queue-id: yrn:yc:ymq:ru-central1:aoek49ghmkh2********:dlq
        service-account-id: aje3932acdh2********
status: ACTIVE

Terraform позволяет быстро создать облачную инфраструктуру в Yandex Cloud и управлять ею с помощью файлов конфигураций. В файлах конфигураций хранится описание инфраструктуры на языке HCL (HashiCorp Configuration Language). При изменении файлов конфигураций Terraform автоматически определяет, какая часть вашей конфигурации уже развернута, что следует добавить или удалить.

Terraform распространяется под лицензией Business Source License, а провайдер Yandex Cloud для Terraform — под лицензией MPL-2.0.

Подробную информацию о ресурсах провайдера смотрите в документации на сайте Terraform или в зеркале.

Если у вас еще нет Terraform, установите его и настройте провайдер Yandex Cloud.

Чтобы создать триггер для Object Storage:

1. Опишите в конфигурационном файле параметры триггера:

   resource "yandex_function_trigger" "my_trigger" {
     name = "<имя_триггера>"
     container {
       id                 = "<идентификатор_контейнера>"
       service_account_id = "<идентификатор_сервисного_аккаунта>"
       retry_attempts     = "<количество_повторных_вызовов>"
       retry_interval     = "<интервал_между_повторными_вызовами>"
     }
     object_storage {
       bucket_id    = "<идентификатор_бакета>"
       prefix       = "<префикс_ключа_объекта>"
       suffix       = "<суффикс_ключа_объекта>"
       create       = true
       update       = true
       delete       = true
       batch_cutoff = "<максимальное_время_ожидания>"
       batch_size   = "<размер_группы_событий>"
     }
     dlq {
       queue_id           = "<идентификатор_очереди_Dead_Letter_Queue>"
       service_account_id = "<идентификатор_сервисного_аккаунта>"
     }
   }
   

   Где:

   • name — имя триггера. Формат имени:

     • длина — от 3 до 63 символов;
     • может содержать строчные буквы латинского алфавита, цифры и дефисы;
     • первый символ — буква, последний — не дефис.

   • container — параметры контейнера:

     • id — идентификатор контейнера.
     • service_account_id — идентификатор сервисного аккаунта с правами на вызов контейнера.
     • retry_attempts — количество повторных вызовов, которые будут сделаны, прежде чем триггер отправит сообщение в Dead Letter Queue. Необязательный параметр. Допустимые значения — от 1 до 5, значение по умолчанию — 1.
     • retry_interval — время, через которое будет сделан повторный вызов контейнера, если текущий завершился неуспешно. Необязательный параметр. Допустимые значения — от 10 до 60 секунд, значение по умолчанию — 10 секунд.

   • object_storage — параметры триггера:

     • bucket_id — идентификатор бакета.

     • prefix — префикс ключа объекта в бакете. Необязательный параметр. Используется для фильтрации.

     • suffix — суффикс ключа объекта в бакете. Необязательный параметр. Используется для фильтрации.

     • События, после наступления которых триггер запускается:

       • create — триггер вызовет контейнер при создании нового объекта в хранилище. Принимает значения true или false.
       • update — триггер вызовет контейнер при обновлении объекта в хранилище. Принимает значения true или false.
       • delete — триггер вызовет контейнер при удалении объекта из хранилища. Принимает значения true или false.
     • batch_cutoff — максимальное время ожидания. Необязательный параметр. Допустимые значения от 1 до 60 секунд, значение по умолчанию — 1 секунда. Триггер группирует события не дольше batch_cutoff и отправляет их в контейнер. Число событий при этом не превышает batch_size.
     • batch_size — размер группы событий. Необязательный параметр. Допустимые значения от 1 до 10, значение по умолчанию — 1.
   • dlq — параметры очереди сообщений Dead Letter Queue:
     • queue_id — идентификатор очереди Dead Letter Queue. Необязательный параметр.
     • service_account_id — идентификатор сервисного аккаунта с правами на запись в очередь Dead Letter Queue. Необязательный параметр.

   Более подробную информацию о параметрах ресурса yandex_function_trigger см. в документации провайдера.

2. Создайте ресурсы:

   1. В терминале перейдите в папку, где вы отредактировали конфигурационный файл.

   2. Проверьте корректность конфигурационного файла с помощью команды:

      terraform validate
      

      Если конфигурация является корректной, появится сообщение:

      Success! The configuration is valid.
      

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

      terraform plan
      

      В терминале будет выведен список ресурсов с параметрами. На этом этапе изменения не будут внесены. Если в конфигурации есть ошибки, Terraform на них укажет.

   4. Примените изменения конфигурации:

      terraform apply
      

   5. Подтвердите изменения: введите в терминале слово yes и нажмите Enter.

   Terraform создаст все требуемые ресурсы. Проверить появление ресурсов можно в консоли управления или с помощью команды CLI:

   yc serverless trigger list
   

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