Skip to main content

From Sensor to Insight - Rapid IIoT Integration for IO-Link Devices with Apache StreamPipes

· 7 min read

Integrating industrial sensors into IIoT architectures often poses significant challenges—especially for IT teams unfamiliar with traditional operational technologies (OT). The complexity of fieldbus protocols, bespoke integrations, and vendor lock-in can create significant barriers to digital transformation on the shop floor.

This blog post introduces an easy, scalable approach to bridging this IT/OT divide using IO-Link, a standardized protocol for industrial sensors, and Apache StreamPipes. We'll walk you through a complete setup—from connecting IO-Link sensors to visualizing actionable insights—with a focus on a vibration sensor and an IO-Link Master.

Whether you're building condition monitoring systems, predictive maintenance pipelines, or just starting with industrial data analytics, this guide will show how StreamPipes makes it simple to move from raw sensor data to intelligent decisions.

Image of IO-Link master and VVB001 sensor

IO-Link is an increasingly popular choice in modern industrial environments—and for good reason. It enables seamless sensor integration without the headaches of proprietary protocols or specialized wiring.

IO-Link sensors support a wide range of measurements including vibration, temperature, flow, and pressure. Thanks to IODD (IO Device Description) files, these sensors are interoperable across manufacturers, making configuration fast and reliable. With simple three-wire cabling and support for up to eight sensors via a single IO-Link master, IO-Link dramatically reduces the complexity of sensor installations.

IO-Link is a globally standardized communication protocol (IEC 61131-9) used to connect industrial sensors and actuators. Unlike traditional analog or proprietary fieldbus protocols, IO-Link communicates digitally and supports detailed sensor diagnostics, parameterization, and status monitoring. It also integrates easily into IT environments, helping to close the gap between OT data generation and IT-driven analytics.

To simplify integration with modern IoT platforms, the Open Industry 4.0 Alliance (OI4) provides a standardized interface specification for IO-Link over MQTT. This includes well-defined JSON structures, topic hierarchies, and security mechanisms such as TLS encryption and authentication. OI4-compliant devices ensure that sensor data can be consumed and interpreted reliably—no matter the vendor.

Use Case: Multi-Sensor Condition Monitoring

Let’s consider a typical industrial use case: monitoring the condition of electric motors using vibration, temperature, and pressure sensors. These sensors are connected to a Hilscher sensorEDGE FIELD gateway, which publishes all sensor values over MQTT using the OI4 format.

Real-Time Insights with StreamPipes

In Apache StreamPipes, this data can be ingested using the OI4 adapter and routed through various processing pipelines. For instance, you can configure alerts for high vibration (e.g., aPeak > 8.0 m/s²) and high temperature (> 80°C) to detect early signs of mechanical stress or overheating. Additionally, a rolling average calculation on pressure data helps identify leaks or irregularities.

This setup not only enables instant notifications via email but also stores the processed data in a timeseries database for long-term trend analysis—reducing the need for manual inspections and improving asset reliability.

Expanding Beyond Vibration

IO-Link sensors can be used across many other domains in industrial environments. Here are a few examples:

Sensor TypeUse CaseStreamPipes Processor(s)
FlowDetect pipe blockages in real-timeThreshold Alert, Rate of Change
DistanceMonitor silo fill levelsMoving Average, Anomaly Detection
PressurePredict pump failure from pressure spikesPattern Matching

Integration Overview: From Hardware to StreamPipes

Setting up the hardware and data flow is straightforward—even for teams without OT experience.

After connecting the VVB001 vibration sensor to an IO-Link Master, it is automatically detected and begins sending data. This gateway then publishes sensor readings to a local or remote MQTT broker in a structured JSON format, following the OI4 specification.

Apache StreamPipes, with its OI4 adapter, subscribes to these MQTT topics, automatically infers the data schema, and prepares the events for downstream processing—completely eliminating the need for manual parsing or custom integration scripts.

Architectural overview

StreamPipes Configuration Guide

Setting up the data stream in StreamPipes is quick and intuitive. Here's how it works:

Adding the OI4 Adapter

Start by opening the Connect section in the StreamPipes UI. From the list of available adapters, choose the OI4 MQTT Adapter. This adapter is purpose-built for consuming OI4-compliant MQTT streams, so it comes with built-in support for schema detection and mapping.

OI4 adapter in connect

Configuring the Adapter

In the configuration screen, specify the connection to your MQTT broker. For this use case, the broker runs at tcp://192.168.188.73:1883, with unauthenticated access. Select the desired sensor type (VVB001) and confirm that all available sensors should be included.

You’ll also need to enter the App ID that identifies the publishing application—in this case, hilscher.com/.../netfield-app-opc-ua-io-link-adapter-1. Once configured, click Next, and StreamPipes will automatically detect the event schema based on the live payloads from the broker.

Configuration of OI4 adapter

Deep Dive: VVB001 Vibration Sensor Data

The VVB001 sensor is an IO-Link-enabled device capable of measuring several key vibration and temperature metrics. These metrics are essential for detecting imbalances, misalignments, and early-stage mechanical wear in rotating equipment.

Key Metrics Explained

  • vRMS (Velocity RMS): Indicates the effective vibration velocity over time. Higher values suggest increasing mechanical stress or imbalance.
  • aPeak (Acceleration Peak): Captures the maximum acceleration value in a sampling window. Sudden spikes may point to impacts or misalignment.
  • aRMS (Acceleration RMS): Reflects consistent vibration intensity. Useful for trend analysis and baseline monitoring.
  • Crest Factor: Calculated as the ratio between peak and RMS acceleration. A rising Crest Factor often signals early-stage bearing damage.
  • Temperature: Measures the internal temperature of the sensor or its surroundings—crucial for thermal condition monitoring.

Sample JSON Payload

{
"Temperature": 37.9,
"sensorId": "000008740649",
"Crest": 4,
"vRms": 0,
"aRms": 0,
"aPeak": 0.2,
"timestamp": 1600599689805
}

Preprocessing in StreamPipes

Before this data can be used for analytics or alerting, it must be scaled and cleaned. For example:

  • vRMS values need to be multiplied by 0.0001.
  • aPeak, aRMS, Temperature, and Crest values are scaled by 0.1.

The StreamPipes connect functionality van handle this effortlessly. You can edit the event schema to apply scaling and remove unused fields.

Configuration of OI4 adapter

Visual Data Exploration

Once the data is flowing, you can use the Data Explorer in StreamPipes to monitor sensor metrics in real-time. Line charts help you visualize trends, spikes, and anomalies in vibration and temperature levels.

Whether you’re fine-tuning processing logic or monitoring asset health, StreamPipes visualizations make it easy to detect anomalies and trends in real time.

Configuration of OI4 adapter

Alerting with Pipelines

With pipelines, you can define rule-based logic to trigger alerts based on sensor values. For example, if the Crest Factor exceeds a defined threshold, you can send an email notification to maintenance staff.

Pipelines are extensible—you can integrate third party tools, store data in databases, or implement predictive analytics using machine learning models.

Configuration of OI4 adapter

Conclusion

Apache StreamPipes and IO-Link together offer a highly accessible yet powerful IIoT solution. From a simple dashboard setup to complex, multi-sensor condition monitoring pipelines, this integration enables IT teams to drive real-time insights from machine data—without needing a background in industrial automation.