ADVAIT Pipeline

Data Processing Pipeline

Every OT record flows through five governed stages inside ADVAIT before reaching consumers.

ADVAIT

Online

Ingest Rate

3,200/s

Publish Rate

2,800/s

MES

Online

Pipeline Stages

Left to right — ingestion to publish

Stage 1

Ingestion

3,200 msgs/s

MQTT / TCP ingress from 22 WP500 gateways

Stage 2

Contextualization

3,136 msgs/s

Asset model tagging, unit conversion, calculated KPIs

Stage 3

Quality

3,104 checks/s

Freshness, range and completeness rules

Stage 4

Storage

3,072 writes/s

Time-series + event stores with retention policies

Stage 5

Publish

2,800 msgs/s

Northbound to 42Q MES + REST/API consumers

Governance

· Every record carries a lineage stamp: machine → gateway → protocol → ingest ts.
· ADVAIT applies quality rules before storage; failing records are quarantined, not discarded.
· Northbound publishers only see governed, contextualized events.

Consumers