在本文中，将创建并运行以下两条规则。
-
监视 Random-UnsignedInteger-Device 设备的规则，如果 uint8 值大于 20 ，则向 Random-Boolean-Device 设备发送命令，并开启布尔值的随机生成 。
-
监视 Random-Integer-Device 设备的规则，如果每20秒 int8 的平均值大于0，则向 Random-Boolean-Device 设备服务发送命令以关闭 布尔值的随机生成。
该场景不含任何真实的业务逻辑，而只是为了演示EdgeX Kuiper规则引擎的功能。您可以根据我们的演示制定合理的业务规则。
本文档将不涉及EdgeX和EMQ X Kuiper的基本操作，因此读者应具有以下基本知识：
curl -X POST \
http://$kuiper_docker:48075/streams \
-H 'Content-Type: application/json' \
-d '{
"sql": "create stream demo() WITH (FORMAT=\"JSON\", TYPE=\"edgex\")"
}'
由于这两个规则都会向设备 Random-UnsignedInteger-Device 发送控制命令，通过运行命令 curl http://localhost:48082/api/v1/device/name/Random-Boolean-Device | jq 可以获取该设备的可用命令列表。它将打印类似的输出，如下所示。
{
"id": "9b051411-ca20-4556-bd3e-7f52475764ff",
"name": "Random-Boolean-Device",
"adminState": "UNLOCKED",
"operatingState": "ENABLED",
"labels": [
"device-virtual-example"
],
"commands": [
{
"created": 1589052044139,
"modified": 1589052044139,
"id": "28d88bb3-e280-46f7-949f-37cc411757f5",
"name": "Bool",
"get": {
"path": "/api/v1/device/{deviceId}/Bool",
"responses": [
{
"code": "200",
"expectedValues": [
"Bool"
]
},
{
"code": "503",
"description": "service unavailable"
}
],
"url": "http://edgex-core-command:48082/api/v1/device/bcd18c02-b187-4f29-8265-8312dc5d794d/command/d6d3007d-c4ce-472f-a117-820b5410e498"
},
"put": {
"path": "/api/v1/device/{deviceId}/Bool",
"responses": [
{
"code": "200"
},
{
"code": "503",
"description": "service unavailable"
}
],
"url": "http://edgex-core-command:48082/api/v1/device/bcd18c02-b187-4f29-8265-8312dc5d794d/command/d6d3007d-c4ce-472f-a117-820b5410e498",
"parameterNames": [
"Bool",
"EnableRandomization_Bool"
]
}
}
]
}
从输出中，您能看出有两个命令，第二个命令用于更新设备的配置。此设备有两个参数：
curl -X PUT \
http://edgex-core-command:48082/api/v1/device/c1459444-79bd-46c8-8b37-d6e1418f2a3a/command/fe202437-236d-41c5-845e-3e6013b928cd \
-H 'Content-Type: application/json' \
-d '{"Bool":"true", "EnableRandomization_Bool": "true"}'
第一条规则是监视 Random-UnsignedInteger-Device 设备的规则，如果 uint8 值大于“ 20”，则向 Random-Boolean-Device 设备发送命令，并开启布尔值的随机生成 。以下是规则定义，请注意：
-
当uint8的值大于20时将触发该动作。由于uint8的值不用于向 Random-Boolean-Device 发送控制命令，因此在 rest 操作的 dataTemplate 属性中不使用 uint8 值。
curl -X POST \
http://$kuiper_server:48075/rules \
-H 'Content-Type: application/json' \
-d '{
"id": "rule1",
"sql": "SELECT uint8 FROM demo WHERE uint8 > 20",
"actions": [
{
"rest": {
"url": "http://edgex-core-command:48082/api/v1/device/bcd18c02-b187-4f29-8265-8312dc5d794d/command/d6d3007d-c4ce-472f-a117-820b5410e498",
"method": "put",
"retryInterval": -1,
"dataTemplate": "{\"Bool\":\"true\", \"EnableRandomization_Bool\": \"true\"}",
"sendSingle": true
}
},
{
"log":{}
}
]
}'
第二条规则
第二条规则监视Random-Integer-Device设备，如果每20秒int8的平均值大于0，则向Random-Boolean-Device 设备服务发送命令以关闭 布尔值的随机生成。
curl -X POST \
http://$kuiper_server:48075/rules \
-H 'Content-Type: application/json' \
-d '{
"id": "rule2",
"sql": "SELECT avg(int8) AS avg_int8 FROM demo WHERE int8 != nil GROUP BY TUMBLINGWINDOW(ss, 20) HAVING avg(int8) > 0",
"actions": [
{
"rest": {
"url": "http://edgex-core-command:48082/api/v1/device/bcd18c02-b187-4f29-8265-8312dc5d794d/command/d6d3007d-c4ce-472f-a117-820b5410e498",
"method": "put",
"retryInterval": -1,
"dataTemplate": "{\"Bool\":\"false\", \"EnableRandomization_Bool\": \"false\"}",
"sendSingle": true
}
},
{
"log":{}
}
]
}'
现在创建了两个规则，您可以查看edgex-kuiper的日志以获取规则执行结果。
# docker logs edgex-kuiper
由于分析结果也需要发送到command rest服务，如何从分析结果中提取数据？通过SQL过滤数据的示例如下所示：
SELECT int8, "true" AS randomization FROM demo WHERE uint8 > 20
[{"int8":-75, "randomization":"true"}]
当从字段 int8 读取 value 字段，从字段 randomization 读取 EnableRandomization_Bool 时，假设服务需要以下数据格式：
curl -X PUT \
http://edgex-core-command:48082/api/v1/device/${deviceId}/command/xyz \
-H 'Content-Type: application/json' \
-d '{"value":-75, "EnableRandomization_Bool": "true"}'
Kuiper使用Go模板 从分析结果中提取数据，并且 dataTemplate 内容如下：
"dataTemplate": "{\"value\": {{.int8}}, \"EnableRandomization_Bool\": \"{{.randomization}}\"}"
在某些情况下，您可能需要迭代返回的数组值，或使用if条件设置不同的值，然后参考此链接写入更复杂的数据模板表达式。
如想了解更多的 EMQ X Kuiper 的信息，请参考以下资源。
