Мониторинг оборудования: 25 млн сообщений/сутки, опрос в 6 раз быстрее

Производству нужна диспетчеризация инженерных систем: сотни датчиков, аварии до поломки, а не отчёт «на следующий день». Данные с контроллеров (Modbus/MQTT) должны попадать на дашборд оператора в реальном времени, с историей и алертами.

Ручной обход и Excel не масштабируются. Нужен контур: опрос → хранение time-series → живые экраны → реакция смены.

Собрали BMS-контур из трёх слоёв.

Сборщик на Go: soft real-time опрос контроллеров, Modbus TCP и MQTT (EMQX), запись в InfluxDB. Алгоритм группировки регистров (smart batch read) сократил RTT и ускорил опрос оборудования в 6 раз. Воркеры изолированы: потеря связи с одним контроллером не роняет остальные.

Бизнес-логика — NestJS, GraphQL, PostgreSQL, роли доступа. Витрина оператора — Next.js, дашборды, схемы оборудования, WebSocket.

Аварии уходят в Telegram. Масштаб — от пилота на линии до 1000+ датчиков.

25 млн+ сообщений в сутки на боевом контуре.

Скорость опроса оборудования выросла в 6 раз за счёт batch-чтения Modbus.

Оператор видит простой и аварию в реальном времени, а не в утреннем отчёте.

Пилот масштабируется от 10 датчиков до 1000+ без смены архитектуры.