Подключение Superset

В этом разделе описывается процесс подключения интерактивной платформы Apache Superset к функциональному решению "Подсчет объектов" с целью анализа исторических данных.

Инструкция по подготовке дашборда к импорту и его добавлению в Superset находится в разделе, описывающем подключение Superset к функциональному решению "Сорока".

Репликация данных в TimescaleDB

Для работы функционального решения "Подсчет объектов" с Superset необходимо реплицировать результаты подсчета в SQL-хранилище.

Для таких целей реализован репликатор, который запускается совместно с сервисами функционального решения "Подсчет объектов", читает топик с данными для компонента notifier и сохраняет данные в TimescaleDB.

Схема данных в SQL-хранилище

CREATE TABLE IF NOT EXISTS cameras (
    id text PRIMARY KEY,
    name text
);

CREATE TABLE IF NOT EXISTS rules (
    id text PRIMARY KEY,
    name text
);

CREATE TABLE IF NOT EXISTS results (
    time timestamp with time zone NOT NULL,
    object_type text NOT NULL,
    cam_id text NOT NULL REFERENCES cameras(id),
    rule_id text NOT NULL REFERENCES rules(id),
    org_id text NOT NULL,
    count integer NOT NULL
);