Analytics worker

Воркер аналитики (Analytics worker) – cервис, который получает запросы на обработку аудио- и видеопотоков, осуществляет захват и обработку этих потоков и генерирует события аналитики.

Компонент, который принимает запросы и запускает скрипты аналитики, называется менеджером процессов (Analytics propcess manager).

Скрипты аналитики имеют доступ к:

• Видеопотоку

• Внешним ресурсам (model server) через интерфейсы, предоставляемые менеджером процессов

• Каналам для отправки событий, сообщений, логов менеджеру процессов

Таким образом, связь скриптов с внешним ресурсами происходит через менеджер процессов.

Воркер аналитики является связкой из сущностей сервера моделей и клиентских приложений (препроцессоров). Препроцессоры выполняют следующие функции:

• Захватывают и обрабатывают видеопотоки

• Подготавливают артефакты для обработки нейросетями

• Обращаются к серверу моделей для инференса нейросетей с артефактами и событиями, указывающими на параметры обработки

• Принимают события о результатах от сервера моделей

Препроцессоры состоят из следующих элементов:

• Скрипты аналитики, в которых описана логика обработки видеопотока

• «Движок» – компонент, который принимает запросы на обработку, запускает нужные скрипты, ими управляет, обогащает события от скриптов и отправляет их по назначению

Скрипт аналитики предоставляет «движку» точку входа. Аргумент этой функции – объект, предоставляющий методы для получения параметров кейса, инференса нейросетей, логирования, отправки событий и двустороннего общения с «движком».