New
EMQX 6.1.0 新特性:可回放的 MQTT 消息流、增强的多租户能力与更多数据集成 →
规则引擎 & Flow 编排器

实时处理 MQTT 数据

使用基于 SQL 的规则引擎和可视化 Flow 编排器,实时提取、过滤、增强和转换物联网数据。

核心能力

强大的数据处理能力

满足实时处理、转换和路由物联网数据的全方位需求

SQL 规则
1SELECT
2 payload,
3 now_timestamp() as processed_at
4FROM "sensor/+/data"
5WHERE payload.temperature > 30
输入
{"device_id": "sensor-042", "temperature": 35.2, "humidity": 68}
输出
点击运行执行

使用 SQL 处理数据流,实时过滤、转换和分析数据。

了解更多
Flow 编排器

可视化数据编排

通过拖拽方式轻松构建复杂数据流,无需编写代码。

可视化界面

拖拽式工作流创建,让非编程人员也能轻松上手

SQL 互操作

可视化编辑器与 SQL 无缝切换,规则自动同步

50+ 集成

连接数据库、消息队列和云服务

内置测试

部署前可使用模拟数据或真实数据测试工作流

规则命中
1,284,539
处理成功
1,284,506
处理失败
33
无结果
0
核心优势

简化数据处理流程

使用高性能、高可靠且易于使用的内置工具,高效处理物联网数据。

简化处理流程

使用类 SQL 语法过滤、转换和分发数据,无需自定义代码。

实时响应

基于条件触发操作,实现快速、明智的决策。

降低开发成本

内置功能最大限度减少自定义代码和维护工作。

高性能可扩展

轻松应对高吞吐量和大规模设备连接。

相关资源

深入了解 MQTT 数据处理