Data Ingestion

Protocol collectors, message bus, and preprocessing pipeline

Protocol Collectors

Modbus TCP

active

Port 50224 msg/s

SNMP v2c

active

Port 16112 msg/s

BACnet/IP

pending

Port 47808

No equipment assigned yet

LoRaWAN

active

RF 915MHz4 msg/s

OPC-UA

active

Port 48408 msg/s

Message Bus

NATS / MQTT

3,616

msgs/min

4

topics

device.{id}

3 subs720/min

telemetry.*

5 subs2880/min

alarm.*

4 subs12/min

control.*

2 subs4/min

Preprocessing Pipeline

1

Normalize

Unit conversion, schema mapping

active48/s

2

Validate & Enrich

Range checks, metadata join

active47/s

3

Edge Compute

Downsample, local alerts

active45/s

Data Store

Time-Series DB

Power, Env, State

Twin Graph

Zone-Panel-Device