Back to all

Connecting Streamsheets to Industrial Machinery via MQTT

To connect the machinery and the Streamsheet server an MQTT Broker ( is used. Read this article to discover how MQTT connection works.

In order to visualize the machinery, I have installed a factory simulation program called FactoryIO ( This easy-to-use program allows building virtual industrial machinery in a 3D environment including sensors and actuators that operate in real-time.

A screenshot of factoryI/O
FactoryIO screenshot

To make FactoryIO compatible with MQTT I am using a special gateway for FactoryIO that Cedalo has developed. It converts the internal memory map of FactoryIO into a simple JSON payload and publishes the payload on a MQTT broker at a high-speed frequency.

This shows a screenshot of the FactoryIO MQTT bridge reflecting the live status of the sensors and actuators as JSON
Screenshot of the FactoryIO MQTT bridge reflecting the live status of the sensors and actuators as JSON

At the same time, the MQTT gateway is also able to subscribe to an MQTT topic and receive JSON-based payloads to control the actuators (e.g. Pusher 1 to 4) on the machinery.

In the following video, you can see how we build Streamsheets from the ground up. It is very much recommended that you view the video in full screen mode.

Controlling Industrial Machinery with Streamsheets and MQTT

The Streamsheet works in a cyclic mode that recalculates the formulas every 20 ms. In the first part of the video, the sensor status of Sensor 1 to 4 is linked with the corresponding Streamsheet cells.

In addition to reading values from the incoming MQTT payloads, the video also shows how to create functions that publish JSON data to an MQTT topic. This topic is then subscribed by the MQTT gateway of FactoryIO and controls the actuators (e.g. Pusher 1)

To synchronize all actions timewise the Streamsheet uses a function called EDGE.DETECT(). This function determines whether a certain condition is true and is then able to hold and delay the signal for a given number of milliseconds. This makes sure that the pusher is activated at the right moment.

In the next part of this use case, I will show how to integrate some AI capabilities in this scenario. A locally installed voice recognition system (Snips, see will then allow the user to voice control which belt will pick which parts.

In another blog post for this use case, I show an analytic dashboard of the sorter station with charts and statistical functionality. In the following screenshot, you can see a short preview of this analytic dashboard. Follow this link to see how I created the dashboard.

This image is a dynamic dashboard analyzing and visualizing production data in real-time
Dynamic Dashboard analyzing and visualizing production data in real-time
Click to rate this post!
[Total: 1 Average: 5]
About the author
Avatar photo

Kristian Raue

Co-Founder of Cedalo

Kristian Raue is a co-founder of Cedalo GmbH. Previously, he was the founder and CEO of Jedox AG in Freiburg, a leading provider of Business Intelligence software with locations in the USA, Australia, and Singapore.

From 1991 to 2000, Kristian Raue was the CEO of IntelliCube Software AG, which has merged with the INFOR Group. Kristian Raue studied industrial engineering with a focus on mechanical engineering at TU Darmstadt.

Newsletters icon

Subscribe for monthly updates