Rule Engine
Low-code data processing and integration using a powerful SQL-based IoT rule engine to help extract, filter, enrich, transform and store IoT data in real-time to accelerate application integration and business innovation.
Try EMQX Enterprise →
Application Scenarios
Action listening
Using rule engine configuration to monitor offline events can push the fault information to the application service and realize the ability of first-time fault detection in the access layer.
Data filtering
Use the rules engine to conditionally filter messages before passing them into the business system, significantly reducing the load on the business system.
Message routing
In the intelligent billing application, the rules engine is used to implement the routing of messages from different topics to different business systems.
Message encoding and decoding
Simplify project integration by converting messages from different formats to an easy-to-handle JSON format through the rules engine.
Integration with Databases
EMQX supports storing MQTT messages to HStreamDB , Redis, MySQL, PostgreSQL, MongoDB, Cassandra, DynamoDB, InfluxDB, OpenTSDB, IoTDB and other databases.
Integration with Message Queues
EMQX supports bridging MQTT messages to Kafka, RabbitMQ, Pulsar, RocketMQ, MQTT servers, or other EMQX nodes.
