2021-09-03发表EdgeX6 分钟读完 (大约895个字)0次访问

EdgeX的使用

演示功能需要包含设备数据采集，数据分析，数据分析后的设备控制命令发送，以及云端的数据导出和远程数据访问显示。设备目前可以使用edgeX 的虚拟设备。

以虚拟设备为例：edgex自带的虚拟设备应该不会自己时刻产生数据，只有当edgex请求或者用户通过api请求其中的方法时，才会返回数据。在devices.toml文件中，对每个设备配置了DeviceList/DeviceList.AutoEvents，也就是自动事件，以此完成每个interval从虚拟设备收集数据发送到核心数据。

下面的步骤通过postman操作：

数据采集

1	192.168.0.107:59882/api/v2/device/name/Random-Integer-Device/Int8

数据分析以及数据分析后设备控制命令发送

通过eKuiper 分析来自 EdgeX消息总线的数据

第一步：创建流

post http://192.168.0.107:59720/streams

body {"sql": "create stream demo() WITH (FORMAT=\"JSON\", TYPE=\"edgex\")"}

创建规则

第一条规则：

监视来自Random-UnsignedInteger-Device设备的事件，如果uint8发现读数值大于20事件中的值，则向Random-Boolean-Device设备发送命令以开始生成随机数（将随机生成 bool 设置为 true）。

1 2	#post http://192.168.0.107:59720/rules

#body
{
  "id": "rule1",
  "sql": "SELECT uint8 FROM demo WHERE uint8 > 20",
  "actions": [
    {
      "rest": {
        "url": "http://edgex-core-command:59882/api/v2/device/name/Random-Boolean-Device/WriteBoolValue",
        "method": "put",
        "dataTemplate": "{\"Bool\":\"true\", \"EnableRandomization_Bool\": \"true\"}",
        "sendSingle": true
      }
    },
    {
      "log":{}
    }
  ]
}

第二条规则：

监视来自Random-Integer-Device设备的事件，如果int8读取值的平均值（20 秒内）大于 0，则向Random-Boolean-Device设备发送命令以停止生成随机数字（将随机生成 bool 设置为 false）。

1 2	#post http://192.168.0.107:59720/rules

{
  "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:59882/api/v2/device/name/Random-Boolean-Device/WriteBoolValue",
        "method": "put",
        "dataTemplate": "{\"Bool\":\"false\", \"EnableRandomization_Bool\": \"false\"}",
        "sendSingle": true
      }
    },
    {
      "log":{}
    }
  ]
}

打印eKuiper日志

docker logs edgex-kuiper

测试完成

换个例子

删除刚刚创建的两条规则，只创建一条规则，作用是监视来自Random-Integer-Device设备的事件，如果int8读取值的平均值（20 秒内）小于30，则向Random-Boolean-Device设备发送命令以开始生成随机数字，如果int8读取值的平均值（20 秒内）大于等于30，则向Random-Boolean-Device设备发送命令以停止生成随机数字。

1 2	#post http://192.168.0.107:59720/rules

#body
{
  "id": "rule2",
  "sql": "SELECT avg(int8) AS avg_int8 FROM demo WHERE int8 != nil GROUP BY TUMBLINGWINDOW(ss, 20)",
  "actions": [
    {
      "rest": {
        "url": "http://edgex-core-command:59882/api/v2/device/name/Random-Boolean-Device/WriteBoolValue",
        "method": "put",   
        "dataTemplate": "{\"Bool\":\"{{if lt .avg_int8 30.0}}true\"{{else if ge .avg_int8 30.0}}false\"{{end}},\"EnableRandomization_Bool\": \"{{if lt .avg_int8 30.0}}true\"{{else if ge .avg_int8 30.0}}false\"{{end}}}",
        "sendSingle": true
      }
    },
    {
      "log":{}
    }
  ]
}