[發明專利]流式計算中的數據聚合方法、裝置、設備及介質

在審

• 申請號: 202210050573.X
• 申請日: 2022-01-17
• 公開（公告）號: CN114461492A
• 公開（公告）日: 2022-05-10
• 發明（設計）人: 鄭伊翎
• 申請（專利權）人: 遠景智能國際私人投資有限公司;上海遠景科創智能科技有限公司
• 主分類號: G06F11/30
• 分類號: G06F11/30;G06F9/38
• 代理公司: 北京三高永信知識產權代理有限責任公司 11138
• 代理人: 王靜

本申請公開了一種流式計算中的數據聚合方法、裝置、設備及介質，涉及物聯網領域。該方法包括：聚合計算在第一滾動窗口內接收到的物聯網數據，得到第一聚合數據，所述第一滾動窗口的起始時刻是第一時刻，所述第一滾動窗口的結束時刻是第二時刻；在所述第二時刻之后的第三時刻接收延遲物聯網數據，所述延遲物聯網數據的事件時間戳在所述第一滾動窗口內；在所述第三時刻位于以所述第二時刻為起點的延遲容忍窗內的情況下，將所述延遲物聯網數據合并到所述第一聚合數據中，所述延遲容忍窗的時間長度是預設容忍時長。本申請可以將延遲物聯網數據合并到第一聚合數據，使得第一聚合數據的計算結果更為準確。

技術領域

本申請涉及物聯網領域，特別涉及一種流式計算中的數據聚合方法、裝置、設備及介質。

背景技術

流式計算是在數據不斷變化的過程中實時地進行分析，捕捉到可能有用的信息，并生成計算結果。在物聯網領域，使用流式計算解決分布式能源系統實時監控、計算的問題。

相關技術中，首先計算機設備會先基于時間劃分出互不重疊的滾動窗口，而傳感器會實時采集輸入數據，并將輸入數據上送到計算機設備中，由計算機設備對在同一滾動窗口內接收到的輸入數據進行計算。

但是，由于輸入數據從采集再到上送，中間存在時間差，使得部分輸入數據無法準時到達計算機設備中，導致相關技術的聚合結果與實際存在偏差。

發明內容

本申請實施例提供了一種流式計算中的數據聚合方法、裝置、設備及介質，該方法可以將延遲物聯網數據合并到第一聚合數據中，避免遺漏物聯網數據，使得計算得到的第一聚合數據更加準確。所述技術方案如下：

根據本申請的一個方面，提供了一種流式計算中的數據聚合方法，該方法包括：

聚合計算在第一滾動窗口內接收到的物聯網數據，得到第一聚合數據，所述第一滾動窗口的起始時刻是第一時刻，所述第一滾動窗口的結束時刻是第二時刻；

在所述第二時刻之后的第三時刻接收延遲物聯網數據，所述延遲物聯網數據的事件時間戳在所述第一滾動窗口內；

在所述第三時刻位于以所述第二時刻為起點的延遲容忍窗內的情況下，將所述延遲物聯網數據合并到所述第一聚合數據中，所述延遲容忍窗的時間長度是預設容忍時長。

根據本申請的另一個方面，提供了一種流式計算中的數據聚合裝置，該裝置包括：

計算模塊，用于聚合計算在第一滾動窗口內接收到的物聯網數據，得到第一聚合數據，所述第一滾動窗口的起始時刻是第一時刻，所述第一滾動窗口的結束時刻是第二時刻；

接收模塊，用于在所述第二時刻之后的第三時刻接收延遲物聯網數據，所述延遲物聯網數據的事件時間戳在所述第一滾動窗口內；

所述計算模塊，還用于在所述第三時刻位于以所述第二時刻為起點的延遲容忍窗內的情況下，將所述延遲物聯網數據合并到所述第一聚合數據中，所述延遲容忍窗的時間長度是預設容忍時長。

在本申請的一個可選設計中，所述計算模塊，還用于在所述第三時刻位于以所述第二時刻為起點的所述延遲容忍窗內的情況下，對所述延遲物聯網數據進行篩選，得到篩選后的延遲物聯網數據；將所述篩選后的延遲物聯網數據合并到所述第一聚合數據中。

在本申請的一個可選設計中，所述計算模塊，還用于將滿足數據取值范圍的所述延遲物聯網數據確定為所述篩選后的延遲物聯網數據。

在本申請的一個可選設計中，所述計算模塊，還用于響應于在所述第一滾動窗口內的第四時刻接收到所述物聯網數據，將所述物聯網數據合并到預聚合數據中，得到所述第一聚合數據，所述預聚合數據是聚合計算所述第一時刻至所述第四時刻內的所述物聯網數據得到的；或，在所述第一滾動窗口內，每隔預設時長，聚合計算在所述第一滾動窗口內接收到的所述物聯網數據，得到所述第一聚合數據。