Базы данных

Система ЛиманИСУ 2.0 использует две СУБД:

PostgreSQL 14 -- реляционная СУБД для хранения конфигурационных данных, справочников и управления пользователями
ClickHouse 24.2.1 -- колонковая СУБД для хранения и анализа телеметрических данных

Обзор схем

СУБД	Схема	Назначение
PostgreSQL	`lisu`	Основная схема: пользователи, роли, дерево объектов, измерительные точки, журналы
PostgreSQL	`defects_reference_book`	Справочник типов дефектов оборудования
PostgreSQL	`bearing_reference_book`	Справочник подшипников качения
ClickHouse	`default`	Телеметрия, события, дефекты, прогнозы, тренды

PostgreSQL -- схема `lisu`

Основная схема системы. Содержит данные о пользователях, иерархии объектов, измерительных точках, журналах событий и техобслуживания.

users -- Пользователи

Хранение учетных записей пользователей системы.

Поле	Тип	PK/FK	Описание
id	BIGINT	PK	Уникальный идентификатор пользователя
lastname	VARCHAR(60)		Фамилия
name	VARCHAR(60)		Имя
patronymic	VARCHAR		Отчество
username	VARCHAR		Логин для входа
password	VARCHAR		Хэш пароля
email	VARCHAR		Email
phone	VARCHAR(20)		Номер телефона
position	VARCHAR		Должность
email_notification	BOOLEAN		Включена ли email-нотификация (по умолчанию `false`)
sms_notification	BOOLEAN		Включена ли SMS-нотификация (по умолчанию `false`)
verified	BOOLEAN		Подтверждена ли учетная запись (по умолчанию `false`)
active	BOOLEAN		Активен ли пользователь (по умолчанию `false`)
time_zone	VARCHAR(20)		Часовой пояс
lang	SMALLINT		Язык интерфейса (по умолчанию 0)
created	TIMESTAMP		Дата и время регистрации
password_exp_date	TIMESTAMP		Дата истечения срока действия пароля
type_notification	JSONB		Типы оповещений (гибкая структура)
active_sending_reports	BOOLEAN		Отправлять ли отчеты (по умолчанию `false`)
period_sending_reports	INTEGER		Период отправки отчетов в днях (по умолчанию 1)
last_sending_reports	TIMESTAMP		Дата последней отправки отчета

Связи:

user_role (многие-ко-многим): пользователь может иметь несколько ролей (ON DELETE CASCADE)
user_hash_history (один-ко-многим): история паролей (ON DELETE CASCADE)
journal (один-ко-многим): события аудита
permission (один-ко-многим): права доступа к объектам дерева (ON DELETE CASCADE)

Триггеры:

after_create_password_trigger -- при создании пользователя добавляет хэш пароля в историю
after_update_password_trigger -- при смене пароля добавляет новый хэш в историю (если не дублируется)

role -- Роли

Хранение ролей пользователей (например, "Администратор", "Инженер").

Поле	Тип	PK/FK	Описание
id	BIGINT	PK	Идентификатор роли
name	VARCHAR(25)		Название роли (уникальное)
description	VARCHAR(255)		Описание роли

user_role -- Связь пользователей и ролей

Реализует связь "многие-ко-многим" между пользователями и ролями.

Поле	Тип	PK/FK	Описание
user_id	BIGINT	PK, FK -> users.id	Идентификатор пользователя
role_id	BIGINT	PK, FK -> role.id	Идентификатор роли

tree -- Древовидная структура объектов

Иерархическое представление объектов: локации, узлы, оборудование.

Поле	Тип	PK/FK	Описание
id	BIGINT	PK	Идентификатор узла
path	LTREE		Путь в иерархии (например, `1.5.12`)
type	tree_type (ENUM)		Тип объекта: `LOCATION`, `UNIT`, `EQUIPMENT`, `NODE`
name	VARCHAR		Имя объекта
description	VARCHAR		Описание
mnemo	JSONB		Мнемосхема оборудования
attributes	JSONB		Метаданные узла
unit_data	JSONB		Доп. данные (двигатель с подшипниками)
created	TIMESTAMP		Дата создания
mode_work	JSONB		Режимы работы оборудования
diagnostics	JSONB		Диагностические параметры
last_repair	TIMESTAMP		Дата последнего ремонта

Расширение ltree

Используется расширение PostgreSQL ltree для работы с иерархией. Триггер tree_insert_trigger автоматически заполняет поле path при вставке. Индексы: path_idx (btree), path_gist_idx (gist) для быстрого поиска.

Пример unit_data (насос с подшипниками):

{
  "id": 155,
  "name": "Насос",
  "type": "EQUIPMENT",
  "path": "5.89.151.152.155",
  "equipmentType": "pump",
  "bearingsType": "rolling",
  "pumps": [
    {
      "count": "3",
      "title": "Плунжер",
      "bearings": [
        {
          "id": 18293,
          "model": "3640",
          "company": "GPZ",
          "companyModel": "GPZ 3640",
          "innerRing": "8.18",
          "outerRing": "7.82",
          "separator": "0.49",
          "rollingElements": "5.96"
        }
      ]
    }
  ]
}

Пример mode_work (режимы работы):

{
  "data": [
    {
      "id": "90d9e4ee-f30c-4f15-bb00-a2c0159a95f4",
      "name": "Выключен",
      "conditionModeWork": [
        {
          "id": "f121221f-f279-4cc7-8f3b-1faf8f795901",
          "value": "1",
          "condition": "<",
          "parameter": "revolutions_per_minute",
          "measurmentPoint": 267
        }
      ]
    }
  ]
}

data_hub -- Датахабы

Источники данных (MQTT-брокеры, API и т.п.).

Поле	Тип	PK/FK	Описание
id	BIGINT	PK	Идентификатор
name	VARCHAR	UNIQUE	Уникальное название
url	VARCHAR	UNIQUE	Адрес подключения (IP:порт или DNS)
username	VARCHAR		Логин для подключения
password	VARCHAR		Пароль для подключения
active	BOOLEAN		Активен ли источник (по умолчанию `false`)
created	TIMESTAMP		Дата создания

Связи: telemetry_node (один-ко-многим) -- один DataHub обслуживает множество точек (без каскадного удаления).

telemetry_type -- Типы источников телеметрии

Поле	Тип	PK/FK	Описание
id	BIGINT	PK	Идентификатор типа
name	VARCHAR(100)	UNIQUE	Название типа
parse_topic	VARCHAR(6)		Тип парсера: JSON, String, Bool, Float, Int

telemetry_node -- Измерительные точки

Конкретные источники телеметрии (датчики, устройства), привязанные к объектам дерева.

Поле	Тип	PK/FK	Описание
id	BIGINT	PK	Идентификатор точки
name	VARCHAR(255)		Название
topic	VARCHAR(255)		MQTT/другой топик
telemetry_type_id	BIGINT	FK -> telemetry_type.id	Тип источника данных
data_hub_id	BIGINT	FK -> data_hub.id	Источник данных
tree_id	BIGINT	FK -> tree.id	Объект в дереве (`ON DELETE CASCADE`)
created	TIMESTAMP		Дата создания

stick_name -- Параметры измерительной точки

Конкретные параметры ("температура", "давление") для конкретной измерительной точки.

Поле	Тип	PK/FK	Описание
id	BIGINT	PK	Идентификатор параметра
name	VARCHAR		Название параметра
alias	VARCHAR		Псевдоним
unit	VARCHAR		Единица измерения
precition	INTEGER		Точность отображения (по умолчанию 2)
telemetry_node_id	BIGINT	FK -> telemetry_node.id	Измерительная точка (`ON DELETE CASCADE`)

stick_name_ref -- Справочник параметров

Шаблонные параметры, используемые при создании новых точек.

Поле	Тип	PK/FK	Описание
id	BIGINT	PK	Идентификатор параметра
name	VARCHAR		Название
alias	VARCHAR		Псевдоним
unit	VARCHAR		Единица измерения
precition	INTEGER		Точность (по умолчанию 2)

PostgreSQL -- схема `defects_reference_book`

defect -- Справочник типов дефектов

Хранение шаблонов дефектов оборудования с диагностическими параметрами и рекомендациями по устранению.

Поле	Тип данных	DEFAULT / NOT NULL	Описание
id	UUID	NOT NULL	Уникальный идентификатор дефекта
name	VARCHAR	NOT NULL	Название дефекта (например, "Подшипник: Внешнее кольцо")
key	VARCHAR	NOT NULL	Уникальный ключ дефекта (например, `BPFO`)
group_key	VARCHAR	--	Ключ группы дефектов
group_name	VARCHAR	--	Название группы дефектов
recommendations_weak	VARCHAR	--	Рекомендации при слабом проявлении дефекта
recommendations_average	VARCHAR	--	Рекомендации при среднем проявлении
recommendations_strong	VARCHAR	--	Рекомендации при сильном проявлении
default_spectrum_weak	DOUBLE PRECISION	NOT NULL	Пороговое значение в спектре для слабого дефекта
default_spectrum_medium	DOUBLE PRECISION	NOT NULL	Пороговое значение в спектре для среднего дефекта
default_spectrum_strong	DOUBLE PRECISION	NOT NULL	Пороговое значение в спектре для сильного дефекта
default_envelope_weak	DOUBLE PRECISION	DEFAULT 4 NOT NULL	Пороговое значение в огибающей для слабого дефекта
default_envelope_medium	DOUBLE PRECISION	DEFAULT 8 NOT NULL	Пороговое значение в огибающей для среднего дефекта
default_envelope_strong	DOUBLE PRECISION	NOT NULL	Пороговое значение в огибающей для сильного дефекта
default_spectrum_template_weak	DOUBLE PRECISION	DEFAULT 10 NOT NULL	Порог шаблона спектра для слабого дефекта
default_spectrum_template_medium	DOUBLE PRECISION	DEFAULT 20 NOT NULL	Порог шаблона спектра для среднего дефекта
default_spectrum_template_strong	DOUBLE PRECISION	DEFAULT 30 NOT NULL	Порог шаблона спектра для сильного дефекта
diagnostic	JSON	--	Дополнительные диагностические параметры в формате JSON

Индексы: ix_defect_id (btree по id), ix_defect_name (btree по name)

defectequipmentmode -- Настройки дефектов под оборудование и режим

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

Поле	Тип данных	DEFAULT / NOT NULL	Описание
id	UUID	NOT NULL	Уникальный идентификатор записи
defect_id	UUID	NOT NULL, FK -> defect.id	Ссылка на тип дефекта
equipment_id	INTEGER	NOT NULL	Идентификатор оборудования
mode_id	VARCHAR	--	Идентификатор режима работы
spectrum_weak	DOUBLE PRECISION	NOT NULL	Порог в спектре для слабого дефекта
spectrum_medium	DOUBLE PRECISION	NOT NULL	Порог в спектре для среднего дефекта
spectrum_strong	DOUBLE PRECISION	NOT NULL	Порог в спектре для сильного дефекта
envelope_weak	DOUBLE PRECISION	DEFAULT 4	Порог в огибающей для слабого дефекта
envelope_medium	DOUBLE PRECISION	DEFAULT 8	Порог в огибающей для среднего дефекта
envelope_strong	DOUBLE PRECISION	NOT NULL	Порог в огибающей для сильного дефекта
spectrum_template_weak	DOUBLE PRECISION	DEFAULT 10 NOT NULL	Порог шаблона спектра для слабого дефекта
spectrum_template_medium	DOUBLE PRECISION	DEFAULT 20 NOT NULL	Порог шаблона спектра для среднего дефекта
spectrum_template_strong	DOUBLE PRECISION	DEFAULT 30 NOT NULL	Порог шаблона спектра для сильного дефекта

PostgreSQL -- схема `bearing_reference_book`

bearing -- Справочник подшипников

Хранение геометрических и конструктивных параметров подшипников качения, используемых при диагностике оборудования.

Поле	Тип данных	Обязательное	Описание
id	INTEGER	NOT NULL (PK)	Уникальный идентификатор записи (sequence `bearing_id_seq`)
company	VARCHAR	NOT NULL	Производитель подшипника (например, SKF, FAG)
model	VARCHAR	NOT NULL	Модель подшипника (например, 6205, NU206)
balls_coef	DOUBLE PRECISION	--	Коэффициент частоты дефекта тел качения
separator_coef	DOUBLE PRECISION	--	Коэффициент частоты дефекта сепаратора
in_coef	DOUBLE PRECISION	--	Коэффициент частоты дефекта внутреннего кольца
out_coef	DOUBLE PRECISION	--	Коэффициент частоты дефекта наружного кольца
in_diameter	DOUBLE PRECISION	--	Внутренний диаметр подшипника (мм)
out_diameter	DOUBLE PRECISION	--	Внешний диаметр подшипника (мм)
ball_diameter	DOUBLE PRECISION	--	Диаметр тел качения (мм)
number_of_balls	INTEGER	--	Количество тел качения
contact_angle	DOUBLE PRECISION	--	Угол контакта (градусы)

Диагностические частоты

Коэффициенты (balls_coef, in_coef, out_coef, separator_coef) рассчитываются на основе геометрии подшипника и частоты вращения для определения диагностических частот: BPFO (наружное кольцо), BPFI (внутреннее кольцо), BSF (тела качения), FTF (сепаратор).

ClickHouse -- схема `default`

Все таблицы предназначены для хранения диагностических, телеметрических и событийных данных промышленного оборудования.

Схема СУБД ClickHouse

defects -- Агрегированные вибрационные характеристики

Результаты обработки файлов сырого сигнала -- агрегированные вибрационные и спектральные характеристики по точкам измерения.

Поле	Тип данных	Кодек	Описание
ts	DateTime64(3)	DoubleDelta	Метка времени с миллисекундной точностью
equipment_path	LowCardinality(String)	--	Путь до оборудования в дереве предприятия
equipment_id	UInt32	--	Идентификатор оборудования
measurement_point_id	UInt32	--	Идентификатор измерительной точки
rms	Float32	FPC(12), LZ4	СКЗ виброускорения для всего сигнала
mean	Float32	FPC(12), LZ4	Среднее значение амплитуды сигнала
max	Float32	FPC(12), LZ4	Максимальное значение амплитуды
min	Float32	FPC(12), LZ4	Минимальное значение амплитуды
peak_to_peak	Float32	FPC(12), LZ4	Разница макс. и мин. амплитуды
half_peak_to_peak	Float32	FPC(12), LZ4	Половина пик-ту-пик
kurtosis	Float32	FPC(12), LZ4	Эксцесс
crest_factor	Float32	FPC(12), LZ4	Крест-фактор
rotational_frequency	Float32	--	Частота вращения
rms_2_1000	Float32	FPC(12), LZ4	СКЗ виброускорения 2-1000 Гц
rms_10_1000	Float32	FPC(12), LZ4	СКЗ виброускорения 10-1000 Гц
rms_10_2000	Float32	FPC(12), LZ4	СКЗ виброускорения 10-2000 Гц
rms_400_1600	Float32	FPC(12), LZ4	СКЗ виброускорения 400-1600 Гц
rms_1600_6400	Float32	FPC(12), LZ4	СКЗ виброускорения 1600-6400 Гц
rms_10_10000	Float32	FPC(12), LZ4	СКЗ виброускорения 10-10000 Гц
rms_6400_25600	Float32	FPC(12), LZ4	СКЗ виброускорения 6400-25600 Гц
velocity_rms_2_1000	Float32	FPC(12), LZ4	СКЗ виброскорости 2-1000 Гц
velocity_rms_10_1000	Float32	FPC(12), LZ4	СКЗ виброскорости 10-1000 Гц
velocity_rms_10_2000	Float32	FPC(12), LZ4	СКЗ виброскорости 10-2000 Гц
displacement_rms_2_1000	Float32	FPC(12), LZ4	СКЗ виброперемещения 2-1000 Гц
displacement_rms_10_1000	Float32	FPC(12), LZ4	СКЗ виброперемещения 10-1000 Гц
gear	Nullable(String)	DEFAULT NULL	Название ступени текущей скорости
rms_half_rot	Float32	FPC(12), LZ4	СКЗ за пол-оборота вала

-- Движок и партиционирование
ENGINE = MergeTree
PARTITION BY (toYYYYMMDD(ts), equipment_id)
ORDER BY (ts, equipment_id, measurement_point_id)
SETTINGS index_granularity = 8192

defects_modulation -- История развития дефектов

Данные о модуляции и пороговых значениях по уровням силы дефекта.

Поле	Тип данных	Описание
equipment_id	UInt32	Идентификатор оборудования
measurement_point_id	UInt32	Идентификатор измерительной точки
ts	DateTime64(3)	Метка времени
defect_key	LowCardinality(String)	Уникальный ключ дефекта
strength	Nullable(Enum8('weak'=1, 'medium'=2, 'strong'=3))	Сила проявления дефекта
spectrum_modulation	Float32	Модуляция в прямом спектре
envelope_modulation	Float32	Модуляция в спектре огибающей
spectrum_weak	Nullable(Float32)	Граница для слабого дефекта в прямом спектре
spectrum_medium	Nullable(Float32)	Граница для среднего дефекта
spectrum_strong	Nullable(Float32)	Граница для сильного дефекта
envelope_weak	Nullable(Float32)	Граница для слабого дефекта в огибающей
envelope_medium	Nullable(Float32)	Граница для среднего дефекта в огибающей
envelope_strong	Nullable(Float32)	Граница для сильного дефекта в огибающей
spectrum_template_weak	Nullable(Float32)	Пороговое значение шаблона для слабого дефекта
spectrum_template_medium	Nullable(Float32)	Пороговое значение шаблона для среднего
spectrum_template_strong	Nullable(Float32)	Пороговое значение шаблона для сильного

ENGINE = MergeTree
PARTITION BY (toYYYYMMDD(ts), equipment_id)
ORDER BY (ts, equipment_id, measurement_point_id, defect_key)
SETTINGS index_granularity = 8192

detected_defects -- Обнаруженные дефекты

Фиксация обнаруженных дефектов с указанием времени и силы проявления.

Поле	Тип данных	DEFAULT	Описание
equipment_id	Int32	--	Идентификатор оборудования
defect_key	LowCardinality(String)	--	Уникальный ключ дефекта
mode_id	Nullable(String)	--	Идентификатор режима работы
modulation	Float32	--	Уровень модуляции
strength	Enum8('weak'=1, 'medium'=2, 'strong'=3)	--	Сила дефекта
detected_at	DateTime	now()	Метка времени обнаружения

ENGINE = ReplacingMergeTree
PARTITION BY toYYYYMM(detected_at)
ORDER BY (equipment_id, defect_key, detected_at)
SETTINGS index_granularity = 8192

equipment_defects -- Признаки дефектов

Детализированные спектральные характеристики гармоник и боковых полос.

Поле	Тип данных	DEFAULT	Описание
equipment_id	UInt32	--	Идентификатор оборудования
measurement_point_id	UInt32	--	Идентификатор измерительной точки
ts	DateTime64(3)	DoubleDelta	Метка времени
is_autospectrum	Bool	false	Флаг типа спектра (автоспектр)
defect_type	LowCardinality(String)	--	Тип гармоники (например, `bpfo`, `shaft`)
harmonic_number	Int8	0	Номер гармоники
sideband_number	Int8	0	Номер боковой полосы
frequency	Float32	FPC(12), LZ4	Частота гармоники
amplitude	Float32	FPC(12), LZ4	Амплитуда гармоники
lowcut	Float32	FPC(12), LZ4	Нижняя граница полосового фильтра
highcut	Float32	FPC(12), LZ4	Верхняя граница полосового фильтра
resolution	Float32	FPC(12), LZ4	Разрешение по частоте
z_score	Float32	FPC(12), LZ4	Коэффициент по методике диагностики
delta_l	Float32	FPC(12), LZ4	Коэффициент по методике диагностики
modulation	Nullable(Float32)	FPC(12), LZ4	Коэффициент модуляции для гармоники
template	Nullable(Float32)	FPC(12), LZ4	Значение шаблона для сравнения

ENGINE = MergeTree
PARTITION BY (equipment_id, toYYYYMM(ts))
PRIMARY KEY (equipment_id, measurement_point_id, ts)
ORDER BY (equipment_id, measurement_point_id, ts, defect_type, harmonic_number)
SETTINGS index_granularity = 8192

Архивная таблица

Таблица equipment_defects_old идентична по структуре, но использует UInt8 для harmonic_number. Предназначена для архивных данных.

equipment_forecasts -- Прогнозы наработки

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

Поле	Тип данных	Описание
equipment_id	UInt32	Идентификатор оборудования
ts	DateTime64(3)	Метка времени расчета прогноза
remaining_resource	Nullable(DateTime64(3))	Оставшийся ресурс (прогнозируемая дата отказа)
last_repair_date	Nullable(DateTime64(3))	Метка времени последнего ремонта
hours_until_next_repair	Nullable(UInt32)	Часов до следующего ремонта
last_scheduled_shutdown_date	Nullable(DateTime64(3))	Метка последнего планового останова
hours_until_scheduled_shutdown	Nullable(UInt32)	Часов до планового останова
defect_key	LowCardinality(String)	Ключ дефекта, на основе которого строится прогноз
mode_id	UUID	Идентификатор режима работы

ENGINE = ReplacingMergeTree
ORDER BY equipment_id
SETTINGS index_granularity = 8192

equipment_modes_history -- История режимов работы

История режимов работы оборудования (включая простои).

Поле	Тип данных	DEFAULT	Описание
equipment_id	UInt32	--	Идентификатор оборудования
mode_id	UUID	--	Идентификатор режима
start_time	DateTime64(3)	DoubleDelta	Метка времени начала режима
end_time	Nullable(DateTime64(3))	DoubleDelta	Метка времени окончания режима
duration	UInt32	Delta(4), ZSTD(1)	Длительность режима в секундах
is_not_operating_mode	Bool	false	Признак простоя (не рабочий режим)

ENGINE = MergeTree
PARTITION BY toYYYYMM(start_time)
ORDER BY (equipment_id, start_time)
SETTINGS index_granularity = 8192

event_journal -- Журнал событий

Аудит критических, предупреждающих и информационных событий.

Поле	Тип данных	Описание
uuid	UUID	Идентификатор события
event_type	Enum8('instant'=1, 'duration'=2)	Тип события
event_kind	LowCardinality(Nullable(String))	Категория события (например, `vibration`)
created_at	DateTime64(3)	Время создания
resolved_at	Nullable(DateTime64(3))	Время разрешения
resolved_by	Nullable(String)	Кто закрыл событие
equipment_id	UInt32	Идентификатор оборудования
severity	Enum8('critical'=1, 'warning'=2, 'info'=3)	Уровень важности
message	String	Текст события
acknowledged	Bool	Флаг подтверждения события
acknowledged_at	Nullable(DateTime64(3))	Время подтверждения
acknowledged_by	Nullable(String)	Кто подтвердил
additional_data	Nullable(String)	Дополнительная информация (JSON)
status	Enum8('open'=1, 'closed'=2, 'acknowledged'=3)	Статус события
duration_seconds	Nullable(UInt32)	Длительность события в секундах

ENGINE = MergeTree
PARTITION BY (toYYYYMM(created_at), equipment_id)
ORDER BY (created_at, equipment_id, severity)
SETTINGS index_granularity = 8192

passer_t2_current -- Телеметрия по току

Текущие значения тока электродвигателя и пороги.

Поле	Тип данных	Кодек	Описание
ts	DateTime64(3)	DoubleDelta	Метка времени
equipment_id	UInt32	--	Идентификатор оборудования
measurement_point_id	UInt32	--	Идентификатор измерительной точки
rms	Float32	FPC(12), LZ4	СКЗ силы тока
rms_warn	Float32	FPC(12), LZ4	Граница предупреждения для СКЗ тока
rms_error	Float32	FPC(12), LZ4	Граница аварии для СКЗ тока

ENGINE = MergeTree
PARTITION BY (toYYYYMMDD(ts), equipment_id)
ORDER BY (ts, equipment_id, measurement_point_id)
SETTINGS index_granularity = 8192

passer_v2_vibrations -- Телеметрия по вибрациям

Текущие значения и пороги для ускорения, скорости и перемещения.

Поле	Тип данных	Кодек	Описание
ts	DateTime64(3)	DoubleDelta	Метка времени
equipment_id	UInt32	--	Идентификатор оборудования
measurement_point_id	UInt32	--	Идентификатор измерительной точки
acceleration_rms	Float32	FPC(12), LZ4	СКЗ виброускорения 10-1000 Гц
velocity_rms	Float32	FPC(12), LZ4	СКЗ виброскорости
displacement_rms	Float32	FPC(12), LZ4	СКЗ виброперемещения
acceleration_absolute	Float32	FPC(12), LZ4	Абсолютное значение виброускорения
acceleration_absolute_max	Float32	FPC(12), LZ4	Максимальное значение амплитуды
acceleration_absolute_min	Float32	FPC(12), LZ4	Минимальное значение амплитуды
acceleration_peak_to_peak	Float32	FPC(12), LZ4	Пик-ту-пик
acceleration_half_peak_to_peak	Float32	FPC(12), LZ4	Половина пик-ту-пик
kurtosis	Float32	--	Эксцесс
crest_factor	Float32	--	Крест-фактор
acceleration_rms_warn	Float32	FPC(12), LZ4	Граница предупреждения для СКЗ виброускорения
acceleration_rms_error	Float32	FPC(12), LZ4	Граница аварии для СКЗ виброускорения
velocity_rms_warn	Float32	FPC(12), LZ4	Граница предупреждения для СКЗ виброскорости
velocity_rms_error	Float32	FPC(12), LZ4	Граница аварии для СКЗ виброскорости
displacement_rms_warn	Float32	FPC(12), LZ4	Граница предупреждения для СКЗ виброперемещения
displacement_rms_error	Float32	FPC(12), LZ4	Граница аварии для СКЗ виброперемещения

ENGINE = MergeTree
PARTITION BY (toYYYYMMDD(ts), equipment_id)
ORDER BY (ts, equipment_id, measurement_point_id)
SETTINGS index_granularity = 8192

passer_v2t2_tachometer -- Телеметрия по тахометрам

Обороты и пороги тахометров.

Поле	Тип данных	Кодек	Описание
ts	DateTime64(3)	DoubleDelta	Метка времени
equipment_id	UInt32	--	Идентификатор оборудования
measurement_point_id	UInt32	--	Идентификатор измерительной точки
impulses_per_revolution	UInt16	--	Импульсов на один оборот
revolutions_per_second	Float32	FPC(12), LZ4	Частота вращения
revolutions_per_second_warn	Float32	FPC(12), LZ4	Граница предупреждения
revolutions_per_second_error	Float32	FPC(12), LZ4	Граница аварии
revolutions_per_minute	Float32	FPC(12), LZ4	Обороты в минуту
revolutions_per_minute_warn	Float32	FPC(12), LZ4	Граница предупреждения
revolutions_per_minute_error	Float32	FPC(12), LZ4	Граница аварии

ENGINE = MergeTree
PARTITION BY (toYYYYMMDD(ts), equipment_id)
ORDER BY (ts, equipment_id, measurement_point_id)
SETTINGS index_granularity = 8192

telemetry_trends -- Тренды параметров

Результаты линейной регрессии для трендов параметров телеметрии.

Поле	Тип данных	Кодек	Описание
ts	DateTime64(3)	DoubleDelta	Метка времени расчета тренда
equipment_id	UInt32	--	Идентификатор оборудования
measurement_point_id	UInt32	--	Идентификатор измерительной точки
parameter_name	LowCardinality(String)	--	Имя параметра (например, `temperature`)
coefficient_0	Float64	FPC(12), LZ4	Свободный член линейной регрессии
coefficient_1	Float64	FPC(12), LZ4	Угловой коэффициент линейной регрессии
r_squared	Float64	FPC(12), LZ4	Коэффициент детерминации
p_value	Float64	FPC(12), LZ4	p-значение регрессии
standard_error	Float64	FPC(12), LZ4	Стандартная ошибка
data_points_count	UInt32	--	Количество точек данных в расчете
trend_start	DateTime64(3)	--	Начало периода тренда
trend_end	DateTime64(3)	--	Окончание периода тренда
calculation_time	DateTime64(3)	--	Время выполнения расчета

ENGINE = ReplacingMergeTree(calculation_time)
PARTITION BY (toYYYYMMDD(ts), equipment_id)
ORDER BY (equipment_id, measurement_point_id, parameter_name)
SETTINGS index_granularity = 8192

Индексы:

idx_parameter_name -- parameter_name TYPE set(0) GRANULARITY 1
idx_trend_time -- (trend_start, trend_end) TYPE minmax GRANULARITY 1

Диагностические запросы

ClickHouse

-- Последние 10 записей телеметрии
SELECT * FROM telemetry ORDER BY timestamp DESC LIMIT 10;

-- Проверка вставки данных
SELECT count() FROM defects WHERE ts > now() - INTERVAL 1 HOUR;

-- События за последний день
SELECT * FROM event_journal
WHERE created_at > now() - INTERVAL 1 DAY
ORDER BY created_at DESC
LIMIT 20;

PostgreSQL

-- Количество подшипников в справочнике
SELECT COUNT(*) FROM bearings;

-- Проверка пользователей
SELECT id, username, email, active FROM users;

-- Дерево объектов
SELECT id, name, type, path FROM tree ORDER BY path;

Обзор схем​

PostgreSQL -- схема lisu​

users -- Пользователи​

role -- Роли​

user_role -- Связь пользователей и ролей​

tree -- Древовидная структура объектов​

data_hub -- Датахабы​

telemetry_type -- Типы источников телеметрии​

telemetry_node -- Измерительные точки​

stick_name -- Параметры измерительной точки​

stick_name_ref -- Справочник параметров​

PostgreSQL -- схема defects_reference_book​

defect -- Справочник типов дефектов​

defectequipmentmode -- Настройки дефектов под оборудование и режим​

PostgreSQL -- схема bearing_reference_book​

bearing -- Справочник подшипников​

ClickHouse -- схема default​

defects -- Агрегированные вибрационные характеристики​

defects_modulation -- История развития дефектов​

detected_defects -- Обнаруженные дефекты​

equipment_defects -- Признаки дефектов​

equipment_forecasts -- Прогнозы наработки​

equipment_modes_history -- История режимов работы​

event_journal -- Журнал событий​

passer_t2_current -- Телеметрия по току​

passer_v2_vibrations -- Телеметрия по вибрациям​

passer_v2t2_tachometer -- Телеметрия по тахометрам​

telemetry_trends -- Тренды параметров​

Диагностические запросы​

ClickHouse​

PostgreSQL​