Try EMQX Platform on Azure, Enjoy AI Integration and Simplified Billing →

Process Your MQTT Data in Real-time

Efficiently extract, filter, enrich, and transform your IoT data in real-time utilizing the SQL-based rule engine or stream processing engine. Accelerate IoT application integration and business innovation.

 Your MQTT Data in Real-time

Capabilities

SQL-based Real-time Data Processing

SQL-based Real-time Data Processing

Real-time processing of data streams using SQL. Filter, transform, and analyze data on-the-fly to gain insights.

Event Triggers for MQTT Client

Event Triggers for MQTT Client

The rule engine can respond to events such as client connected/disconnected, topic subscribe/unsubscribe, and message publish/deliver.

Rich built-in Functions

Rich built-in Functions

A bunch of predefined operations can be used within the Rule Engine to process and manipulate the data streams more effectively and efficiently.

Schema Registry and Message Codec

Schema Registry and Message Codec

High-performance encode/decode MQTT messages in JSON, Avro, and Protobuf formats via built-in schema registry.

HTTP/gRPC Extension

HTTP/gRPC Extension

Extend processing capabilities with a cross-platform HTTP/gRPC method to achieve custom types of data processing.

Complex JSON Processing

Complex JSON Processing

Integrate the JSON-specific processing tool jq to convert and process complex JSON data effortlessly.

+

Benefits

Simplified Data Processing


Effortlessly filter, transform, and distribute data using SQL-like syntax and stream processing capabilities, eliminating the need for custom code or additional tools.

Real-time Insights and Actions


The Rule Engine facilitates real-time insights by triggering actions based on specific conditions, empowering users to take prompt and informed actions.

Reduced Development Effort


The Rule Engine simplifies the development of IoT applications by providing a wide range of built-in capabilities, reducing the need to develop custom code and minimizing maintenance efforts.

Scalability and Reliability


Designed to handle high throughput and large numbers of connected devices, allowing users to scale their IoT solutions without sacrificing performance or reliability.

Ready to Get Started?