Rule engine is the core service provided by OneNET to users for data flow.
Function: Users can screen and distribute the device message in IOT Suite.
Feature: Users can define the data screening rule, transform the data format, and forward the data to follow-up products, thereby obtaining more services.
Rule engine supports the processing and forwarding of the message of a certain product in IOT Suite; the message sources that it can process are as follows:
Message at the device data point: message at the new data point uploaded by the device;
Device life cycle event: Creation, deletion, online, offline events and messages occurring during the device life cycle;
Device mirror image property update: The event and message of properties update of the device mirror image (Coming)
The rule engine supports the self-defining of the processing rule of json data contents of the message source selected through SQL statement.
At present, the system message source inputs the rule engine according to the system fixed basic message format; users can define SQL editing based on the basic message format for the extraction and restructuring of json data; users can define SQL statement for message handling, as shown in the figure below:
The rule engine supports the forwarding of the message processed through self-defining to the rear end; the rear-end service supported at present is as follows:
Message queue (MQ)
The high performance and high availability message middleware is convenient for the application service to obtain the device message stably and efficiently.
Short message Service (SMS)
Triggering includes the fixed form short message of self-defined parameters.
Storage Service (coming soon)
Data storage service based on MySQL database