設備數據上云，解析后的設備數據一般是時序存儲，但純粹的設備時序數據無法給用戶帶來更大的業(yè)務價值，需要根據業(yè)務需求進行額外的數據統(tǒng)計分析。本文將介紹如何利用ZWS云平臺的自定義統(tǒng)計算法對數據進行統(tǒng)計。

?應用場景

上一篇《如何利用IoT云平臺統(tǒng)計設備數據？—基礎篇》介紹了如何運用ZWS云平臺中的內置統(tǒng)計算法進行數據統(tǒng)計，這次將介紹如何創(chuàng)建自定義統(tǒng)計算法。

為什么需要自定義統(tǒng)計算法？由于業(yè)務需求各式各樣，有的需要求平均值，有的需要求累加值，不同維度需要不同統(tǒng)計算法，開發(fā)者可以通過自定義統(tǒng)計算法來滿足對應的項目需求。

?統(tǒng)計數據準備首先，需要在ZWS云平臺中創(chuàng)建設備并上報設備數據：

?統(tǒng)計算法ZWS云平臺的統(tǒng)計算法有兩種，分別是內置統(tǒng)計算法和自定義統(tǒng)計算法。

1. 內置算法為云平臺定義好的算法，可以直接關聯(lián)設備進行統(tǒng)計，無需關心統(tǒng)計算法內容和過程。

自定義算法可以自己擬定數據統(tǒng)計的方式(例如取某段時間的最大最小值、總和等等)來統(tǒng)計設備數據。

?創(chuàng)建自定義統(tǒng)計算法不同于內置算法，自定義算法從請求參數、統(tǒng)計過程、統(tǒng)計結果均由用戶自定義，需要開發(fā)者編寫腳本。目前自定義統(tǒng)計中支持了Groovy和JavaScript兩種腳本語言解析。

1. 請求參數

• 類別：云平臺提供給自定義算法的參數；

• 參數名：參數的別名。

在云平臺中，提供了6種參數給自定義算法的開發(fā)者使用：

devType：設備類型；

devId：創(chuàng)建設備定義的ID，可以用于選取一個設備進行統(tǒng)計；

dataSource：設備類型功能塊中的某一個字段；

dataCompareOperation：字段的比較條件，有大于、小于和等于；

dataValue：需要比較的數據值；

• group：軟件分組，可以對一整個軟件分組進行統(tǒng)計。

2.算法代碼

統(tǒng)計數據的過程代碼，可以使用Groovy或者JavaScript語言編寫。

3.返回參數

定義統(tǒng)計后結果顯示的字段。

這里以統(tǒng)計一小時內設備的某個數據的總和為例，編寫一個JavaScript腳本：

// 載入需要實現(xiàn)的接口var DataStatisticScriptMethod = Java.type("com.zlgcloud.iotplatform.iotdata.service.data.statistics.DataStatisticScriptMethod");// 創(chuàng)建繼承實現(xiàn)接口的類var JsDataStatisticScriptMethod = Java.extend(DataStatisticScriptMethod);
// 創(chuàng)建func對象var func = new JsDataStatisticScriptMethod() { execute: function(param) {
//獲取創(chuàng)建算法頁面的請求參數，參數值會由云平臺根據算法實例的選擇項，進行自動填充 var thirdThingsId = param.get("devId"); var infoModelId = param.get("devType"); var property = param.get("property");
//可以自定義統(tǒng)計時間范圍，如果查詢條件沒有range，則會根據算法實例的數據開始時間和數據結束時間范圍進行統(tǒng)計 var currentTime = new Date().valueOf(); var anHourAgo = currentTime - 3600000;
// 拼裝elasticseach 查詢的dsl // 這里根據業(yè)務需要設置數據范圍. 查詢時會限制租戶和用戶管理的設備. 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 } } } ] } } }; //獲取統(tǒng)計結果 var result = Java.super(func).queryEs(infoModelId, esParam); var rtn = {"result_in_hour":result['aggregations']['result_in_hour']['value']}; return rtn; }}

將腳本復制到自定義算法中。

同時創(chuàng)建實例，給設備的數據進行統(tǒng)計。

執(zhí)行算法過后，可以看到自定義統(tǒng)計結果。