文档中心

简介

baetyl-rule 可以实现 baetyl 框架端侧的消息流转，在 baetyl-broker (端侧消息中心)、函数服务、Iot Hub (云端 mqtt broker)，http服务进行消息交换。

支持以下的消息流转方式：

• 订阅来自mqtt的消息。
• 调用函数计算（此步骤可以省略）
• 将处理后的结果发送至mqtt或调用http服务。

其中 baetyl 支持 Python、Node、SQL 等多种运行时，可以配置相关的脚本函数对消息进行过滤、处理、转换以及丰富等。

配置

baetyl-rule 的全量配置文件如下，并对配置字段做了相应解释：

clients: # 消息节点，可以从消息节点订阅消息，也可以发送至消息节点 - name: iothub 

# 名称 kind: mqtt # mqtt 类型 address: 'ssl://u7isgiz.mqtt.iot.bj.baidubce.com:1884'

 # 地址 username: client.example.org # 用户名 ca: ../example/var/lib/baetyl/testcert/ca.pem 

# 连接节点的 CA key: ../example/var/lib/baetyl/testcert/client.key # 连接节点的私钥 cert: 

../example/var/lib/baetyl/testcert/client.pem # 连接节点的公钥 insecureSkipVerify: true 

# 是否跳过服务端证书校验 - name: http-server # 名称 kind: http # http类型 address: 

'http://127.0.0.1:8554' # http服务地址，如果是https，请配置证书，否则默认使用系统证书 ca:

 ../example/var/lib/baetyl/testcert/ca.pem # 连接节点的 CA key: ../example/var/lib/baetyl/

testcert/client.key # 连接节点的私钥 cert: ../example/var/lib/baetyl/testcert/client.pem #

 连接节点的公钥 insecureSkipVerify: true # 是否跳过服务端证书校验 rules: # 消息规则 

- name: rule1 # 规则名称，必须保持唯一 source: # 消息源 topic: broker/topic1 # 消息主题 

qos: 1 # 消息质量 target: # 消息目的地 client: iothub # 消息节点，如果不设置，默认为 

baetyl-broker topic: iothub/topic2 # 消息主题 qos: 0 # 消息质量 function: # 处理函数 

name: node85 # 函数名称 - name: rule2 # 规则名称，必须保持唯一 source: # 消息源 topic:

 broker/topic5 # 消息主题 qos: 0 # 消息质量 target: # 消息目的地 client: http-server

 # 与clients中配置的http服务名称一致 path: /nodes/test # http访问路径 method: PUT

 # http消息类型，支持GET/POST/PUT/DELETE

说明：

• baetyl-rule 后台默认添加边缘系统应用baetyl-broker作为一个消息节点
• 当一条rule规则的source/target 未配置 client 字段时，会默认使用 baetyl-broker 作为其消息节点
• 当一个client消息节点的kind为http 时，若address 连接地址使用https，默认使用baetyl-core签发的系统证书
• http类型消息节点只能作为一条rule的target，并且http请求的Content-Type为application/json

Demo示例

纯消息流转

下面示例定义了两条规则

• edge2iotcore：将边缘侧edgetopic1的消息，转发至云端iotcore，mqtt小的qos=1
• edge2edge：将边缘侧edgetopic1的消息，转发至边缘侧edgetopic2，mqtt消息的qos=1

clients: - name: iotcore kind: mqtt address: 'tcp://aeccdhl.iot.gz.baidubce.com:1883'

 username: xxxcdhl/device6 password: lfWjOxxxmvXPpM rules: - name: edge2iotcore source: 

topic: edgetopic1 qos: 1 target: client: iotcore topic: topic1 qos: 1 - name: edge2edge

 source: topic: edgetopic1 qos: 1 target: topic: edgetopic2 qos: 1 logger: level: debug encoding: console

消息流转+函数计算

下面示例定义了3条规则

• rule1：订阅broker/topic1消息，将消息作为函数py-demo1/func1的输入，将函数计算结果输出至broker/topic2
• rule2：订阅broker/topic3消息，将消息作为函数py-demo1/func2的输入，将函数计算结果通过http POST请求发送至http://10.68.23.42:8554/rule/result

clients: - name: http-server kind: http address: 'http://10.68.23.42:8554' rules:

 - name: rule1 source: topic: broker/topic1 target: topic: broker/topic2 function:

 name: py-demo1/func1 - name: rule2 source: topic: broker/topic3 target: client: 

http-server path: /rule/result method: POST function: name: py-demo1/func2 logger: level: debug encoding: console

更新节点影子

节点影子相关说明可以参考该章节节点影子。 但是由于节点影子的更新仅提供了https接口，因此，可以通过baetyl-rule来路由mqtt消息，从而达成通过mqtt消息更新节点影子的需求。

在云端设置节点影子：

baetyl-rule参考配置如下：

clients: - name: core kind: http address: 'https://baetyl-core.baetyl-

edge-system' rules: - name: shadow source: topic: shadow/put qos: 0 

target: client: core path: /node/properties method: PUT logger: level: debug encoding: console

使用mqtt box连接到mqtt broker后，向定义的topic shadow/put 中发送需要修改的值。

回到云端，可以看到，该节点影子值已被修改。