Sparkplug B to UNS flattening

How it works

This Coreflux LoT template takes Sparkplug B data, decodes it to sparkplug/decoded/#, and flattens named metrics into a clean UNS under factory/hall-c/hall-c-edge/.... It turns temperature and state readings from two press devices into structured model records that are easy to subscribe to and alert on.

Key features

• Sparkplug decode: Consumes spBv1.0/# and republishes TVQ JSON.
• Metric flattening: Maps Temperature and State into separate model shapes.
• Device normalization: Converts Press01 and Press02 to lowercase device IDs.
• Clean UNS output: Publishes to factory/hall-c/hall-c-edge/<device>/....
• Alert-ready data: Supports downstream checks on structured temperature topics.

Prerequisites

• Coreflux broker 2.14.2+.
• Sparkplug B source or the included encoder route.
• Access to the local broker on localhost:1883 for the demo path.

Setup

1. Run the models first.
2. Enable SparkplugEncode only for the hardware-free demo path.
3. Enable SparkplugDecode to read spBv1.0/#.
4. Run FlattenSparkplugToUns to publish clean UNS records.
5. Use the provided rules if you want a read-only dashboard user.