Rules Engine Application

The Rules Engine Application is used to send data from the EMQX Neuron data collection module to the data processing module.

The Rules Engine Application type node DataProcessing has been configured by default on the North Apps page of EMQX Neuron, and the parameters have been configured. Users only need to add and subscribe the southbound driver data to the DataProcessing node.

Add subscription

Click Add Subscription in the operate bar, then under Subscription South Driver Data expand a driver node and tick the collection groups to subscribe to:

The rules engine application needs no topic — the data goes straight into the data processing module.

At this point, we will be able to send the data in the group1 group of the southbound driver m1 through the DataProcessing node to the neuronStream stream of the data processing module for further processing.

For operations in the data processing module, see neuronStream.

Tips

When the neuronStream stream in the data processing module is used in the rules and data flows in, the connection status of the Dataprocessing node will become Connected.

Data Format

Messages sent to neuronStream through DataProcessing node are in fixed json format, as shown below:

{
   "timestamp": 1646125996000,
   "node_name": "node1",
   "group_name": "group1",
   "values": {
     "tag_name1": 11.22,
     "tag_name2": "string"
   },
   "errors": {},
   "metas":{}
}

Device Control

Through Neuron Sink, the data processing module can send write commands to the southbound driver through the DataProcessing node to control the device. For detailed operations on this part, see Neuron Sink.