Search Crosser Knowledge Base

Apply processing logic and send results to Cloud

With Crosser you can not only connect different devices, equipment, applications and services to the UNS, you can also create flows that process the data from simple aggregations up to running AI models within a flow.

Below's example shows how to subscribe to the temperature of robots, calculates the average over a time window of 10 seconds and sends the result to Azure Event Hubs.

Crosser Example

1. Use wildcards in the MQTT topic to subscribe to topics of interest stockholm/packaging/+/+/Robot1/temperature.

Crosser Example

2. In the aggregate module set the source property to ‘topic’ to be able to calculate the aggregated values for every topic/tag.

Crosser Example

3. Publish the data to the external service that requires it. In this case we published the data to the Azure Event Hubs from where it is used by a dashboard.

Note. The aggregate module was just used as an example. Instead of this you can also bring down extended logic in the form of Python code or even a trained AI model which processes the data right next to the UNS.

About the author

David Nienhaus | Senior Solution Engineer

David is a Senior Solution Engineer at Crosser. He has over 15 years experience working with software integration and digitization projects for critical infrastructure.
His engineering background gives him the understanding and focus needed to solve customer use cases in the most efficient and successful way.