可视化界面
在可视化编辑器中拖放节点，轻松创建工作流。
核心能力
过滤、转换与路由 MQTT 数据
利用 SQL、客户端事件、内置函数、Schema 和扩展，构建 MQTT 数据处理流程。
使用 SQL 过滤、转换和分析实时数据流。
了解规则 SQLSQL 规则
SELECT
payload,
now_timestamp() as processed_at
FROM "sensor/+/data"
WHERE payload.temperature > 30输入
{"device_id": "sensor-042", "temperature": 35.2, "humidity": 68}输出
{"payload": {"device_id": "sensor-042", "temperature": 35.2, "humidity": 68}, "processed_at": 1768461629}在客户端连接、断开、订阅、取消订阅，以及消息发布或投递时触发处理。
了解事件事件流示例
client.connectedclient.disconnectedsession.subscribedsession.unsubscribedmessage.publishmessage.deliveredmessage.ackedmessage.dropped
使用内置 SQL 函数解析 JSON、转换数值和格式化字符串。
了解内置函数函数示例
- 类型转换
str str(100)返回'100'- 类型转换
float float('3.14e4')返回31400- 字符串
lower lower('Hello')返回'hello'- 字符串
split split('a;b;c', ';')返回['a', 'b', 'c']- 映射
map_get map_get("a", {"a": 1})返回1- 哈希
sha256 sha256('hello')返回'2cf24dba...'
对 Avro 和 Protobuf 载荷编解码，并根据 Schema 校验 JSON 数据。
了解 Schemamessage SensorData {
string device_id = 1;
float temperature = 2;
float humidity = 3;
int64 timestamp = 4;
}二进制输入
0a0a73656e736f722d30343215cdcc0c421d00008842JSON 输出
{
"device_id": "sensor-042",
"temperature": 35.2,
"humidity": 68.0,
"timestamp": 1705234567
}通过 HTTP 和 gRPC 接入自定义逻辑，扩展数据处理能力。
了解扩展ExHook 扩展
// gRPC ExHook Server (Go)
func (s *HookProvider) OnMessagePublish(
ctx context.Context,
req *pb.MessagePublishRequest,
) (*pb.ValuedResponse, error) {
msg := req.消息
return &pb.ValuedResponse{}, nil
}Hooks: on_client_connect, on_client_authenticate,
on_message_publish, on_message_delivered...
Languages: Go, Python, Java, Erlang使用内置 jq 工具，查询和转换复杂 JSON 载荷。
了解 jqjq 处理器
表达式
.payload | {
id: .device_id,
readings: [.temperature, .humidity],
status: (if .temperature > 35
then "alert" else "normal" end)
}输入
{"payload": {"device_id": "sensor-042", "temperature": 35.2, "humidity": 68}}输出
{
"id": "sensor-042",
"readings": [35.2, 68],
"status": "alert"
}Flow 编排器
可视化构建数据流
通过拖拽编排数据流，也可使用 SQL 编辑同一套规则。
示例数据流
拖动节点编排数据流，拖动画布平移视图，或使用缩放控件调整显示。
SQL 互操作
在可视化编辑器与 SQL 之间自由切换，保持规则同步。
50 多种集成
连接数据库、消息队列和云服务。
内置测试
部署前使用模拟或真实数据测试工作流。
核心优势
简化 MQTT 数据处理流程
借助内置处理工具减少自定义开发，及时响应实时数据。
可复用的 SQL 规则
通过可复用的 SQL 规则过滤、转换和路由 MQTT 消息。
事件驱动的动作
当消息或客户端事件匹配规则时，执行相应动作。
减少自定义代码
使用内置函数和集成能力，减少自定义开发。
高吞吐量处理
支持海量设备连接与高吞吐消息处理。
相关产品
