Real-time water meter telemetry at any scale
Automatically ingest, decode, and archive MQTT streams from distributed meters without manual intervention.
What it is
WizIIOT MQTT Ingestion Engine connects to your water flow meters (NovaFlow 1000/1200) via MQTT brokers and ingests readings in real time. It automatically detects which communication protocol (LoRaWAN or 4G cellular) sent each message, decodes manufacturer-specific formats, cross-references meter metadata and timezones from the platform database, and writes validated data to the history system for analytics and reporting. Built to handle hundreds of meters with minimal configuration.
Key benefits
Automatic format detection
No integration code needed — automatically routes LoRaWAN (TTN/TTS) and 4G JSON payloads to the right decoder. Supports NovaFlow 1000 binary and 1200 JSON out of the box.
Real-time history persistence
Parses timestamps, resolves device timezones, and writes validated meter readings directly to the platform's history tables. Data is immediately available for analytics and SCADA dashboards.
Operational monitoring
Built-in health checks and metrics endpoints let you track message throughput, processing latency, and service health from your monitoring stack (Prometheus/Grafana compatible).
Database-driven configuration
Meter settings, MQTT listeners, and refresh intervals are stored in the platform database and reloaded every 60 seconds — no service restart needed to onboard new meters.
Capabilities
- Ingest MQTT messages from water meters (NovaFlow 1000/1200) via TTN/TTS LoRaWAN or raw 4G JSON
- Auto-detect payload format and route to manufacturer-specific decoder
- Resolve device identity, timezone, and scale factors from platform database in real time
- Parse and validate timestamps with ±1 year drift tolerance and heuristic DD/MM vs MM/DD detection
- Write validated readings to platform history system with automatic deduplication
- Refresh meter settings and listener configuration every 60 seconds without downtime
- Expose health, metrics, and Prometheus-compatible endpoints for operational monitoring
- Batch-process unprocessed messages from database queue on 60-second intervals