边缘规则实例

更新时间：2025-08-21

规则引擎最先被应用在物联网云平台中。针对大量的物联网设备数据，规则引擎通过支持灵活的规则设置，对设备传上云端的设备时序数据、进行过滤、丰富、变换、动作、推送至不同的数据目的地（如时序数据库TSDB、Kafka、对象存储BOS等）以达到不同的业务目标。物联网规则引擎是基于事件驱动的数据流处理引擎，支持多种规则定义方式和描述方式。

在边缘计算场景下，要求边缘框架具有一定的自治能力，其中也包括对于端侧消息流具有一定的处理能力，可以实现消息的本地过滤、统计，再上传云端。边缘规则引擎可以实现端侧的消息路由能力，您可以设置边缘消息规则，控制本地消息在边缘计算节点中的流转，从而实现数据的安全可控。

1、名词解释

baetyl-broker: 单机版消息订阅和发布中心，采用 MQTT3.1.1 协议，是 Baetyl 框架端侧的消息中间件，为所有服务提供消息驱动的互联能力。

Iot Core: 云端 MQTT Broker，具体指一个具体的 Endpoint, 可以使用域名以及用户凭证进行连接，收发 MQTT 消息。

函数：Baetyl 框架的 Node、Python、Sql运行时，可以通过编写相应脚本进行消息的过滤、处理、转换以及丰富，可参考相关资料 baetyl-function 。

本文将以 Sql 运行时为例进行说明。

2、新建IoT Core云端实例

参考百度云IotCore文档新建Iot Core实例并进行相关的设备模板配置。配置成功后，使用 MQTT Box 进行连接，其中 $iot/test/user/# 主题是我们自定义的具有收发权限的用户主题。

3、BIE侧配置

3.1、BIE云端纳管边缘节点

在云端新建边缘节点并安装到边缘设备，需要安装baetyl-rule和baetyl-function两个系统应用。

安装成功后如下所示：

在端侧节点运行如下命令，可看到:

3.2、配置 baetyl-broker

编辑 baetyl-broker 配置，暴露一个外部端口供测试使用。

然后编辑配置文件，配置文件如下：

YAML

1listeners:
2  - address: tcp://0.0.0.0:8003
3principals:
4  - username: test
5    password: hahaha
6    permissions:
7      - action: pub
8        permit: ["#"]
9      - action: sub
10        permit: ["#"]
11
12session:
13  sysTopics:
14    - $link
15    - $baetyl
16logger:
17  level: debug
18  encoding: console

新增 8003 端口供测试使用，并且需要设置映射宿主机端口以供连接。

然后在本地使用MqttBox连接baetyl-broker，测试连通性。

3.3、安装 process SQL处理函数

一段 process 处理函数如下：

Plain Text

1select * where uid > 7

新建相关的配置项，注意添加运行时标签 SQL。

然后新建函数应用，并添加服务 process，引用上述配置项，并通过标签匹配到我们实现创建的节点上。

3.4、配置 baetyl-rule 边缘规则

数据的流转规则我们要配置在 baetyl-rule 模块中，所以这一步要修改 baetyl-rule 相关的配置。

配置文件如下：

Plain Text

1clients:
2  - name: iotcore
3    kind: mqtt
4    address: 'tcp://arncpan.iot.gz.baidubce.com:1883'
5    username: arncpan/test
6    password: xxx
7rules:
8  - name: rule1
9    source:
10      topic: broker/user/a
11      qos: 1
12    target:
13      client: iotcore
14      topic: $iot/test/user/a
15      qos: 1
16    function:
17      name: process
18logger:
19  level: debug
20  encoding: console