node-red-contrib-iaes

IAES Industrial Asset Event Standard nodes for Node-RED.

Create, validate, route, and bridge Sparkplug B industrial asset events — no code required.

Install

In your Node-RED directory:

npm install node-red-contrib-iaes

Or via the Node-RED palette manager: search for node-red-contrib-iaes.

Nodes

| Node | Purpose | |------|---------| | iaes measurement | Create asset.measurement events (vibration, temperature, pressure, power factor, THD...) | | iaes health | Create asset.health events (AI diagnosis, health index, fault classification, RUL) | | iaes work order | Create maintenance.work_order_intent events | | iaes validate | Validate any IAES event against the JSON schema | | iaes sparkplug | Bridge Sparkplug B metrics to IAES events (Ignition, Cirrus Link, DXM) | | iaes publish | POST IAES events to any IAES-compatible HTTP endpoint (batching, auth) | | iaes route | Route IAES events by event_type to 7 typed outputs |

Usage

Sensor to IAES measurement

[inject] --> [iaes measurement] --> [mqtt out]

Configure the iaes measurement node with asset_id, measurement_type, and unit. The node reads msg.payload as the value and outputs a complete IAES envelope.

Dynamic values from msg

All nodes accept values from msg properties. Leave a field empty in the config and set it via msg:

• msg.payload — the measurement value (number)
• msg.asset_id — override asset ID
• msg.source — override source identifier
• msg.measurement_type — override measurement type
• msg.unit — override unit

Validate incoming events

[mqtt in] --> [iaes validate] --> [function]
                |
                +--> [debug] (invalid events)

The iaes validate node has two outputs: valid events on output 1, invalid events on output 2.

Sparkplug B to IAES bridge

[mqtt in: spBv1.0/+/DDATA/+/+] --> [iaes sparkplug] --> [mqtt out: iaes/events]
                                         |
                                         +--> [debug] (errors/skipped)

The iaes sparkplug node decodes Sparkplug B protobuf payloads and converts each numeric metric into an IAES asset.measurement event. It auto-detects measurement types from metric names and maps the Sparkplug device ID to the IAES asset ID.

Compatible with: Ignition (Inductive Automation), Cirrus Link, Banner DXM (Sparkplug mode), Eclipse Tahu, any Sparkplug B 3.0 gateway.

Protobuf support: Install sparkplug-payload in your Node-RED directory for native protobuf decoding. JSON payloads work out of the box.

cd ~/.node-red && npm install sparkplug-payload

Examples

Vibration monitoring

[Modbus read] --> [function: extract value] --> [iaes measurement] --> [mqtt out]

Power quality (ION 8650)

[Modbus TCP] --> [iaes measurement (power_factor)] --> [mqtt out]
[Modbus TCP] --> [iaes measurement (thd_voltage)]  --> [mqtt out]

AI health diagnosis pipeline

[mqtt in] --> [iaes validate] --> [function: run model] --> [iaes health] --> [mqtt out]

Publish events to a remote IAES endpoint

[iaes measurement] --> [iaes publish]
                            |
                            +--> [debug] (errors)

Configure the iaes publish node with the base URL of your IAES-compatible server and an optional API key. The node appends /api/v1/iaes/ingest automatically. Set Batch Size > 1 to buffer events and send them as a single HTTP POST.

Route events by type

[mqtt in] --> [iaes route] --1--> [function: process measurement]
                           --2--> [function: process health]
                           --3--> [function: process work order]
                           --4--> [function: process completion]
                           --5--> [function: process hierarchy]
                           --6--> [function: process sensor]
                           --7--> [debug] (spare parts + unknown)

The iaes route node reads event_type from the IAES envelope and sends the message to the corresponding output. Output 7 receives maintenance.spare_part_usage and any unrecognized event types.

Links

• IAES Specification
• Python SDK — pip install iaes
• TypeScript SDK — npm install @iaes/sdk
• GitHub