使用 EdgeX Kuiper 规则引擎控制物联网设备

概述

该文章描述了如何在 EdgeX 中使用 Kuiper 规则引擎，根据分析结果来实现对设备的控制。为了便于理解，该文章使用 device-virtual示例，它对device-virtual服务发送的数据进行分析，而后根据由Kuiper规则引擎生成的分析结果来控制物联网设备。git

场景

在本文中，将建立并运行如下两条规则。github

监视Random-UnsignedInteger-Device设备的规则，若是uint8值大于 20，则向Random-Boolean-Device设备发送命令，并开启布尔值的随机生成。
监视Random-Integer-Device设备的规则，若是每20秒 int8的平均值大于0，则向Random-Boolean-Device 设备服务发送命令以关闭布尔值的随机生成。

该场景不含任何真实的业务逻辑，而只是为了演示EdgeX Kuiper规则引擎的功能。您能够根据咱们的演示制定合理的业务规则。golang

预备知识

本文档将不涉及 EdgeX 和 EMQ X Kuiper 的基本操做，所以读者应具备如下基本知识：sql

了解 EdgeX 的基础知识，最好完成快速入门。
阅读 EdgeX Kuiper 规则引擎入门教程：您最好阅读此入门教程，并开始在EdgeX中试用规则引擎。
Go 模板：EMQ X Kuiper 使用Go模板从分析结果中提取数据。了解 Go 模板能够帮助您从分析结果中提取所需的数据。

开始使用

请务必遵循文档 EdgeX Kuiper规则引擎入门教程，确保教程可以成功运行。docker

建立 EdgeX 流

在建立规则以前，应建立一个流，该流可使用来自 EdgeX 应用程序服务的流数据。若是您已经完成 EdgeX Kuiper 规则引擎入门教程，则不须要此步骤。json

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能够获取该设备的可用命令列表。它将打印相似的输出，以下所示。api

{
  "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"
        ]
      }
    }
  ]
}

从输出中，您能看出有两个命令，第二个命令用于更新设备的配置。此设备有两个参数：数组

Bool：当其余服务想要获取设备数据时，设置返回值。仅当EnableRandomization_Bool设置为false时，才使用该参数。
EnableRandomization_Bool：是否启用Bool的随机生成。若是将此值设置为true，则将忽略第一个参数。

所以，示例控制命令将相似于以下命令：app

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设备发送命令，并开启布尔值的随机生成。如下是规则定义，请注意：dom

当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 设备服务发送命令以关闭布尔值的随机生成。

uint8的平均值每20秒计算一次，若是平均值大于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

SQL的输出内容以下：

[{"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的更多特性，请阅读下面的参考资料：

版权声明：本文为 EMQ 原创，转载请注明出处。

原文连接：https://www.emqx.io/cn/blog/control-iot-device-with-kuiper-rules-engine