Webinar
数字社交:EMQ 与 JAGAT 探讨社交行业数据潜能 →

实时 MQTT 消息数据处理

使用强大的基于 SQL 的规则引擎和流处理引擎,无需编写代码即可实现一站式的物联网数据提取、过滤、转换,加速应用集成与业务创新。

实时 MQTT 消息数据

功能

基于 SQL 的实时数据处理

基于 SQL 的实时数据处理

用类 SQL 的语法实时处理数据。过滤、转化、分发数据,充分获取数据价值。

灵活的事件触发与条件

灵活的事件触发与条件

规则引擎可以响应各种事件,如消息发布/订阅,并根据特定条件采取相应的动作。这意味着当特定事件发生时,规则引擎能够触发预定义的条件动作,以实现对实时数据的快速响应和灵活处理。

丰富的内置函数

丰富的内置函数

规则引擎提供了一组内置函数,便于更有效和高效的利用规则引擎处理和操作数据流。

Schema Registry 与消息编解码

Schema Registry 与消息编解码

通过内置的 Schema Registry 实现对 JSON、Avro、Protobuf 格式 MQTT 消息的高性能编解码。

HTTP/gRPC 扩展

HTTP/gRPC 扩展

通过跨平台的 HTTP/gRPC 方式扩展处理能力,实现自定义类型的数据处理需求。

复杂 JSON 处理

复杂 JSON 处理

集成强大的 JSON 专用处理工具 jq,毫不费力地转换和处理复杂 JSON 格式数据。

+

优势

简化数据处理


无需定制开发即可实现数据处理。利用类 SQL 的语法轻松实现数据的过滤、转换和分发。

实时洞察和行动


通过根据特定条件触发操作,规则引擎可以快速响应物联网数据和设备状态变化。

减少开发周期和成本


通过规则引擎提供的内置函数简化了应用开发,并最大限度地降低了维护工作量。

高可靠性及扩展性


规则引擎与 MQTT 服务器同步扩容,从容应对业务发展带来的高并发和高吞吐的挑战。