人流量展示_使用示例_流数据分析_用户指南

本文以人流量实时显示为例，详细说明如何使用流数据分析进行人流量的统计，并将计算结果输出到函数计算中，在函数计算中更新显示屏内容。示意图如下所示。

前提条件

在开始操作本章内容前，请您确保已根据专业版环境搭建内容创建完成边缘实例。

一、添加设备

参考设备模拟器章节中使用设备模拟器驱动部分的内容，完成如下步骤。

添加闸口产品和设备：
1. 新建闸口产品，添加识别符为 peoplePassed的事件类型自定义功能。
  其中，事件包含一个int32类型、标识符为count的关于通过人数统计的参数。
2. 为闸口产品添加gate01设备，并分配到边缘实例中。
3. 将闸口产品gate01设备的驱动设为设备模拟器驱动。
添加显示器设备：
1. 新建显示器产品，添加识别符为 content、数据类型为的text（字符串）的属性类型自定义功能。
2. 为显示器产品添加设备，并分配到边缘实例中。
3. 将显示器设备的驱动设为设备模拟器驱动。

说明将设备分配到边缘实例后，请先不要部署边缘实例，待完成其他操作后统一部署。

二、添加流数据分析任务

参考分配流数据分析到边缘实例，创建、设置并发布计算人流量的流数据分析任务。

其中，任务类型选择SQL，执行任务选择边缘端。

在任务列表中，已创建的SQL任务名称右侧单击查看，进入SQL编辑器。

复制如下SQL内容到SQL编辑器编辑框中。

-- 计算每个闸口每十秒的人流量并显示到屏幕上

-- 每个闸口检测到人会上报peoplePassed事件，并附带经过的人数count
create table event (
    eventCode varchar,
    params varchar,
    productKey varchar,
    deviceName varchar,
    gmtCreate varchar,
    ts varchar,
    tstamp as to_timestamp (cast (ts as bigint)),
    WATERMARK wk FOR tstamp as withOffset (tstamp, 2000)
) with (
    type = 'edgebus',
    jsonParser = 'device_event'
);

create table edgebus_sink (
    productKey varchar,
    deviceName varchar,
    flowrate int,
    t_start timestamp,
    t_end timestamp
) with (
    type = 'edgebus_sink',
    topic = '/sys/streamCompute/peopleFlowrate'
);

insert into
    edgebus_sink
select
    productKey,
    deviceName,
    sum (cast (json_value (params, '$.count') as int)),
    tumble_start (tstamp, interval '10' second),
    tumble_end (tstamp, interval '10' second)
from
    event
where
    eventCode = 'peoplePassed'
group by
    tumble (tstamp, interval '10' second),
    productKey,
    deviceName;

保存任务并发布。
参考分配流数据分析到边缘实例，将该SQL任务分配到边缘实例中。

三、添加函数

参考函数计算使用流程内容创建服务、并在该服务下创建名为DisplayFlowrate的使用Nodejs8运行环境的函数。

创建函数完成后，在线编辑代码，添加如下内容。

说明请将your_displaydevice_productKey以及your_displaydevice_deviceName换成实际网关设备的ProductKey和DeviceName。

const leSdk = require('linkedge-core-sdk');

const iotData = new leSdk.IoTData();

module.exports.handler = function(event, context, callback) {
    const payload = JSON.parse(JSON.parse(event.toString()).payload);
    const params = payload.params;
    iotData.setThingProperties({
        productKey: 'your_display_device_productKey',
        deviceName: 'your_display_device_deviceName',
        payload: {
            content: `flowrate: ${params.flowrate}`
        }
    }, (err) => {
        if (err) {
            console.log(`display flowrate err: ${err}`);
        }
    });
};

在物联网平台控制台边缘实例的实例详情页面，选择函数计算，单击分配函数。

参考函数计算应用内容，创建边缘应用。

应用信息部分参数说明如下：


参数	描述
应用类型	此处选择函数计算。
地域	选择您创建的服务所在的地域。
服务	选择DisplayFlowrate函数所在的服务名称。
函数	选择DisplayFlowrate函数。
授权	选择AliyunIOTAccessingFCRole。

函数配置部分参数说明如下：


参数	说明
运行模式	选择按需运行。
内存限制（MB）	设置为20 MB。
超时限制（秒）	设置为5秒。
定时运行	使用默认配置：关闭。

其余参数无需配置。

四、添加消息路由

在物联网平台控制台边缘实例的实例详情页面，选择消息路由，将闸口设备的数据路由到人流量计算的流数据分析任务中。
将人流量计算的流数据分析任务路由到DisplayFlowrate函数计算中。消息主题过滤设置为/sys/streamCompute/peopleFlowrate。
将显示器的属性变换数据路由到IoTHub中，方便在云端查看显示器设备的状态。

五、部署边缘实例

在边缘实例的实例详情页面，单击部署，将子设备、流数据分析作业及消息路由下发到边缘端。
在实例详情页面，选择网关页签，单击远程SSH终端，登录远程控制台。

说明需要您先打开网关名称右侧的远程访问按钮，远程SSH终端才可以使用。
进入/linkedge/gateway/build/bin目录，执行如下命令上报有人员通过的事件。
```
./ds_ctrl event a1Wn0t8**** gate01 peoplePassed '{"count": 1}'
```
在物联网平台控制台，选择设备管理 > 设备，在相应设备名称右侧单击查看。
在设备详情页面查看显示器设备的运行状态以及数据。