【产品应用】如何利用IoT云平台统计设备数据？—进阶篇

// 载入需要实现的接口var DataStatisticScriptMethod = Java.type("com.zlgcloud.iotplatform.iotdata.service.data.statistics.DataStatisticScriptMethod");// 创建继承实现接口的类var JsDataStatisticScriptMethod = Java.extend(DataStatisticScriptMethod);
// 创建func对象var func = new JsDataStatisticScriptMethod() {    execute: function(param) {
        //获取创建算法页面的请求参数，参数值会由云平台根据算法实例的选择项，进行自动填充        var thirdThingsId = param.get("devId");        var infoModelId = param.get("devType");        var property = param.get("property");
        //可以自定义统计时间范围，如果查询条件没有range，则会根据算法实例的数据开始时间和数据结束时间范围进行统计        var currentTime = new Date().valueOf();        var anHourAgo = currentTime - 3600000;
        // 拼装elasticseach 查询的dsl        // 这里根据业务需要设置数据范围. 查询时会限制租户和用户管理的设备.        var esParam = {            "aggregations": {                "result_in_hour": {                    "sum": {                        "field": "data." + property                    }                }            },            "query": {                "bool":{                    "must": [                        {                            "term": {                                    "third_things_id.keyword": thirdThingsId                            }                        },                        {                           "range": {                             "timestamp": {                               "gte": anHourAgo,                               "lt": currentTime                             }                           }                        }                    ]                }            }        };        //获取统计结果        var result = Java.super(func).queryEs(infoModelId, esParam);        var rtn = {"result_in_hour":result['aggregations']['result_in_hour']['value']};        return rtn;    }}