• 文档
  • 快速入门：存储来自第三方系统的数据

快速入门：存储来自第三方系统的数据


本任务旨在通过一个基于实际客户需求的场景帮助你了解如何开始使用设备集成服务。


第三方系统通过 HTTP 上传设备数据。设备数据上传到 EnOS 后，集成流会通过 HTTP Server 接收消息，然后将上传的消息映射到 EnOS 中定义的资产。最后，集成流会将消息转换为 EnOS 定义的标准 JSON 格式并保存消息数据。


../_images/integration_flow_scenario.png

关于本任务

本任务包括以下步骤。

  1. 创建模型
  2. 创建集成流
  3. 设计集成流
  4. 发布和启动集成流

开始前准备

确保你已请求了 设备集成资源。

步骤 1：创建模型

此步骤默认在EnOS上没有可复用的设备模型。通过下表定义的功能创建一个名为 city_iems_cctv 的新模型。有关模型的更多信息，参见 创建模型。

功能类型 名称 标识符 数据类型 值
属性 Device ID No. device_id_no string 1024
测点 Event Name alarm_data_event_name string 1024
测点 People Count raw_data_count string 1024
测点 People Count Percentage raw_data_count_percentage string 1024
测点 Image Path raw_data_imgpath string 1024
测点 Object Type raw_data_objtype string 1024
测点 Raw Image Path wo OBB raw_data_patch string 1024
测点 People Association raw_data_pplassoc string 1024
测点 Raw Image Path wo BB raw_data_rawimgpath string 1024
测点 Bounding Box raw_data_rect string 1024
测点 Event Start Time raw_data_start_time string 1024
测点 Time Stamp raw_data_timestamp string 1024
测点 Time Stamp Unix raw_data_timestamp_unix string 1024
测点 Track ID raw_data_track_id string 1024
测点 Video Path raw_data_videopath string 1024
测点 Camera ID raw_stream_camera string 1024
测点 Region of Interests raw_stream_roi string 1024
测点 Streaming ID raw_stream_streamingID string 1024
测点 Zone raw_stream_zone string 1024

步骤 2：创建集成流

  1. 登录到 EnOS 管理控制台，点击左侧导航菜单中的 设备数据集成 > 流设计器。
  2. 点击 新建集成流，输入流名称和描述，然后点击 确定。

步骤 3：设计集成流

你将进入带有空白画布的 流设计器 页面。节点列表将会显示在左侧。


按照以下节点所示的顺序设计集成流。

../_images/gettingstarted_http_flow.png


  1. 将 HTTP Server 节点添加到 流设计器 画布。有关 HTTP Server 节点的更多信息，参见 HTTP Server。

  2. 将 Script 节点添加到画布，并将其命名为 Auth。转到 Script 标签，然后输入以下代码。

    var timestamp = metadata.get("Timestamp");
print("header timestamp :" + timestamp);
var auth = metadata.get("Authorization");
print("header auth :" + auth);

var body = JSON.stringify(msg);
var appId = "maimnwk3";
var secretKey = "X56ZXY";

var rawData = appId + body + timestamp;
print("rawData :" + rawData);
var result = tools.HMACSHA256Util.encrypt(rawData, secretKey);

print("result :" + result);
if (result === auth) {
    return tools.resultBuilder.build(true, JSON.stringify(msg));
} else {
    return tools.resultBuilder.build(false);
}
return tools.resultBuilder.build(true, JSON.stringify(msg));


    有关 Script 节点的更多信息，参见 Script。


  3. 将另一个 Script 节点添加到画布，并将其命名为 Parse Data。转到 Script 标签，然后输入以下代码。

    if (!msg.Data) {
    return tools.resultBuilder.build(false);
}
var dataArray = msg.Data.data;
var stream = msg.Data.stream;
var device_id = stream.camera;
var flag = true;

for (var i = 0; i < dataArray.length; i++) {
    var data = dataArray[i];
    if (!data.eventName) {
        flag = false;
        break;
    }

    var paramsArray = new Array();
    if (data.eventName === "Abandon") {
        var mps = {};
        mps["raw_data_count"] = JSON.stringify(data.count);
        mps["alarm_data_event_name"] = data.eventName;
        mps["raw_data_imgpath"] = JSON.stringify(data.imgpath);
        mps["raw_data_objtype"] = data.objType;
        mps["raw_data_pplassoc"] = data.peopleassociation;
        mps["raw_data_rawimgpath"] = JSON.stringify(data.rawimgpath);
        mps["raw_data_rect"] = JSON.stringify(data.rect);
        mps["raw_data_start_time"] = data.startTime;
        mps["raw_data_track_id"] = data.trackId;
        mps["raw_data_timestamp"] = data.timestamp;
        mps["raw_data_timestamp_unix"] = data.tsUnix;
        mps["raw_data_videopath"] = JSON.stringify(data.videopath);
        mps["raw_data_patch"] = JSON.stringify(data.patch);
        mps["raw_stream_camera"] = stream.camera;
        mps["raw_stream_roi"] = stream.roi;
        mps["raw_stream_streamingID"] = stream.streamingID;
        mps["raw_stream_zone"] = stream.zone;

        var timestamp = data.timestamp;
        var params = {};
        params["measurepoints"] = mps;
        params["time"] = new Date().getTime();
        params["device_id_no"] = device_id;
        paramsArray.push(params);
    } else if (data.eventName == "CrowdAlert") {
        var mps = {};
        mps["raw_data_count_number"] = data.count.number;
        mps["raw_data_count_percentage"] = data.count.percentage;
        mps["alarm_data_event_name"] = data.eventName;
        mps["raw_data_imgpath"] = JSON.stringify(data.imgpath);
        mps["raw_data_objtype"] = data.objType;
        mps["raw_data_pplassoc"] = data.peopleassociation;
        mps["raw_data_rawimgpath"] = JSON.stringify(data.rawimgpath);
        mps["raw_data_rect"] = JSON.stringify(data.rect);
        mps["raw_data_start_time"] = data.startTime;
        mps["raw_data_track_id"] = data.trackId;
        mps["raw_data_timestamp"] = data.timestamp;
        mps["raw_data_timestamp_unix"] = data.tsUnix;
        mps["raw_data_videopath"] = JSON.stringify(data.videopath);
        mps["raw_stream_camera"] = stream.camera;
        mps["raw_stream_roi"] = stream.roi;
        mps["raw_stream_streamingID"] = stream.streamingID;
        mps["raw_stream_zone"] = stream.zone;

        var timestamp = data.timestamp;
        var params = {};
        params["measurepoints"] = mps;
        params["time"] = new Date().getTime();
        params["device_id_no"] = device_id;
        paramsArray.push(params);
    } else {

    }
}

if (!flag) {
    return tools.resultBuilder.build(false);
}

return tools.resultBuilder.build(true, JSON.stringify(paramsArray));


  4. 将 Lookup Asset 节点添加到画布，并按照以下说明配置节点。有关 Lookup Asset 节点的更多信息，参见 Lookup Asset。

    ../_images/gettingstarted_asset_query.png


  5. 将 Upload Measurement Point 节点添加到画布。有关 Upload Measurement Point 节点的更多信息，参见 Upload Measurement Point。

  6. 按照上图将所有节点连接在一起。

  7. 打开右上角的 Debug 开关，以记录集成流中节点的日志。

    ../_images/debug_switch.png


  8. 点击 保存。

步骤 4：发布和启动集成流

  1. 转到 流设计器 页面，然后针对已创建的集成流点击 发布。

  2. 分配集成流所需的运行时资源，然后点击 确定。

    ../_images/allocate_runtime_resource.png


  3. 在本地计算机上，使用 POSTMAN 将请求发送到 HTTP Server 节点，其中包含以下消息作为有效负载。

    {
    "Data":{
        "data":[
            {
                "eventName":"Abandon",
                "count":1,
                "imgpath":10,
                "objType":"test",
                "peopleassociation":"xxx",
                "rawimgpath":10,
                "rect":10,
                "startTime":"2020-09-15 10:00:00",
                "txUnix":"xx",
                "vediopath":"xxx",
                "patch":"xxx",
                "camera":"xxx",
                "rox":"xxx",
                "streamID":"",
                "zone":"xxx"
            }
        ],
        "stream":{
            "device_id":"xxxxxId"
        }
    }
}

结果

点击 编辑，进入集成流画布页面。点击每个节点的 日志 标签（若适用），查看各自的输入和输出。

../_images/gettingstarted_logs.png