Телеметрия на пути
от устройства к решению
Слой между активами и теми, кто за них отвечает: адаптеры устройств, приём, который переживает плохую связь, семантика тревог и хранилище, которое потом можно спрашивать. Пришлите бриф. Оценка за 24 часа.
Возможности платформы
От адаптеров устройств до операторского вида — накопители, зарядка и телеметрия флота. Без выдуманных версий протоколов; подтверждаем по списку оборудования.
Подключение устройств
Транспорты MQTT, HTTP и WebSocket плюс протокольные адаптеры для шлюзов и контроллеров, которые говорят на своём языке. Новые семейства устройств добавляются адаптерами, а не форками ядра.
Идентификация и доступ устройств
Индивидуальные учётные данные, авторизация по токенам и ограниченные топики. Скомпрометированный шлюз не сможет читать или публиковать за пределами своих активов.
Отказоустойчивый приём данных
Буферизация, повторы с backoff и дедупликация на стороне edge и сервера. Устройства с нестабильной связью досылают историю, а не теряют её.
Потоковая обработка
Фильтрация, агрегация, обогащение и поиск аномалий на живом потоке. Пороговая и правиловая автоматика срабатывает через секунды после показания, которое её вызвало.
Хранение временных рядов
Уровни хранения, прореживание и непрерывные агрегаты: год истории остаётся доступным для запросов без хранения каждого сырого отсчёта «горячим».
Видимость для оператора
Обзоры парка и активов со статусами, геолокацией и таймлайнами сессий, произвольные виджеты и детализация, разграниченные по ролям для эксплуатации, поддержки и руководства.
Как проходит одно показание
Шесть этапов между датчиком и оператором. Большинство IoT-платформ ломается на стыках между ними — именно туда мы вкладываем проектные усилия.
Edge и шлюз
Прошивка устройства или агент шлюза публикует структурированную телеметрию. Схему полезной нагрузки и раскладку топиков мы задаём до того, как построено что-либо ещё.
Приём данных
Брокер или HTTP-эндпоинт с аутентификацией, ограничением частоты, буферизацией и дедупликацией. Некорректные сообщения уходят в карантин, а не теряются молча.
Нормализация
Единицы измерения, метки времени и метаданные устройств сводятся в одну каноническую модель, чтобы код ниже по потоку не знал о производителе.
Обработка и правила
Окна агрегации, поиск аномалий и правила аварий вычисляются на живом потоке — с уровнями критичности и указанием источника в каждом событии.
Хранение
Горячие временные ряды для дашбордов, свёрнутые агрегаты для трендов, холодный архив для регуляторных требований. Раскладку определяют паттерны запросов.
Потребление
Дашборды операторов, каналы оповещений, выгрузки в BI и интеграции с бэк-офисом читают одни и те же нормализованные данные.
Что работает под капотом
Разворачивается в облаке, на собственных серверах или в гибридной инфраструктуре без переписывания прикладного слоя.
- MQTT
- HTTP
- WebSocket
- Protocol adapters
- Node.js
- Kafka
- RabbitMQ
- Rule engine
- TimescaleDB
- PostgreSQL
- ClickHouse
- Redis
- Docker
- Kubernetes
- OpenTelemetry
- Structured logging
Связанная экспертиза
Дашборды→
Интерфейсы оператора, которые превращают эту телеметрию в то, с чем команда может работать.
Мониторинг BESS→
Тот же конвейер для накопителей энергии и PV-инверторов по Modbus, IEC 61850 и SunSpec.
Облако и on-prem→
Где работает платформа: облако, собственные серверы или гибрид — с одной и той же моделью развёртывания.
CRM, ERP и CMS→
Бизнес-системы, в которые эта телеметрия обычно должна попасть — включая живой операционный стол CRM.
Конвейеры телеметрии
Пришлите бриф. Оценка за 24 часа.
Семейства устройств, частота сообщений и хранение. За рабочий день наметим приём, обработку и хранилище.