Триггер для Cloud Logging, который отправляет сообщения в WebSocket-соединения

Триггер для Cloud Logging отправляет сообщения в WebSocket-соединения, когда в лог-группу добавляют записи.

Триггеру для Cloud Logging необходим сервисный аккаунт для чтения из лог-группы и отправки сообщений в WebSocket-соединения.

О том, как создать триггер для Cloud Logging, читайте в инструкции Создать триггер для Cloud Logging, который отправляет сообщения в WebSocket-соединения.

Группирование сообщенийГруппирование сообщений

Настройки группирования позволяют передавать в WebSocket-соединения сразу несколько сообщений. Эти настройки задают ограничение сверху по размеру группы сообщений и по времени ее накопления. Например, если размер группы сообщений равен 3, то в WebSocket-соединения могут поступать группы, в которых содержится от 1 до 3 сообщений.

Роли, необходимые для корректной работы триггера для Cloud LoggingРоли, необходимые для корректной работы триггера для Cloud Logging

• Для создания триггера вам необходимо разрешение на сервисный аккаунт, от имени которого триггер выполняет операцию. Это разрешение входит в роли iam.serviceAccounts.user, editor и выше.
• Для работы триггера сервисному аккаунту необходимы роли:
  • api-gateway.websocketBroadcaster на каталог, в котором находится API-шлюз.
  • logging.reader на лог-группу, при добавлении записей в которую вызывается триггер.

Формат сообщения от триггера для Cloud LoggingФормат сообщения от триггера для Cloud Logging

После того как триггер сработает, он отправит в WebSocket-соединения следующее сообщение:

{
   "messages":[
      {
         "event_metadata":{
            "event_id":"2c59a567-6666-4b65-a0b0-cc12********",
            "event_type":"yandex.cloud.events.serverless.triggers.LoggingMessageBatch",
            "created_at":{
               "seconds":1630607359,
               "nanos":6794776
            }
         },
         "details":{
            "messages":[
               {
                  "resource":{
                     "type":"serverless.function",
                     "id":"b09tm9raoev5********"
                  },
                  "timestamp":"2021-09-02 18:29:17.118082213 +0000 UTC",
                  "level":"INFO",
                  "message":"START RequestID: 085035c7-2319-40dd-bb03-fd8t******** Version: b09s5cq4b935********",
                  "json_payload":{
                     "request_id":"085035c7-2319-40dd-bb03-fdb2********",
                     "version_id":"b09s5cq4b935********"
                  }
               }
            ]
         }
      }
   ]
}

Полезные ссылкиПолезные ссылки

• Триггер для Cloud Logging, который запускает контейнер Serverless Containers
• Триггер для Cloud Logging, который запускает функцию Cloud Functions