[發明專利]實時計算的方法和系統

有效

• 申請號: 201711052098.5
• 申請日: 2017-10-30
• 公開（公告）號: CN109947736B
• 公開（公告）日: 2021-06-29
• 發明（設計）人: 李猛;支海邦;喻海林;周龍亭
• 申請（專利權）人: 北京京東尚科信息技術有限公司;北京京東世紀貿易有限公司
• 主分類號: G06F16/21
• 分類號: G06F16/21;G06F16/25
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 張一軍;楊曉偉

1.一種實時計算的方法，其特征在于，利用實時計算節點進行實時計算，包括：

根據統計維度需求為接收到的待計算數據生成關鍵字；

根據所述關鍵字從所述實時計算節點的內存緩存中獲取對應的計算結果值，結合所述計算結果值為所述待計算數據生成實時計算結果；

輸出所述實時計算結果，并將所述實時計算結果作為新的計算結果值保存至所述內存緩存中；

其中，根據實時計算需求，創建一級或多級實時計算節點，其中，若創建多級實時計算節點，則級別在前的實時計算節點的定時器較級別在后的實時計算節點的定時器的時間粒度細。

2.根據權利要求1所述的方法，其特征在于，所述方法中，采用STL的map容器作為所述實時計算節點的內存緩存。

3.根據權利要求1所述的方法，其特征在于，所述待計算數據包括移動應用和/或Web應用的流式數據。

4.根據權利要求3所述的方法，其特征在于，所述移動應用或Web應用的流式數據包括：接口模調數據、用戶數據、日志數據中的一種或幾種。

5.根據權利要求1所述的方法，其特征在于，所述方法還包括：

若級別在前的實時計算節點的定時器被觸發，則將保存在其內存緩存中的計算結果值按照關鍵字進行一致性哈希之后發送至存儲模塊，作為級別在后的實時計算節點的待計算數據，并刪除其內存緩存中的所述計算結果值以便進行下一時間粒度的實時計算。

6.一種實時計算的系統，其特征在于，利用實時計算節點進行實時計算，其中，所述實時計算節點包括：

接收單元，用于根據統計維度需求為接收到的待計算數據生成關鍵字；

計算單元，用于根據所述關鍵字從所述實時計算節點的內存緩存中獲取對應的計算結果值，結合所述計算結果值為所述待計算數據生成實時計算結果；

發送單元，用于輸出所述實時計算結果，并將所述實時計算結果作為新的計算結果值保存至所述內存緩存中；

任務監控節點，用于根據實時計算需求，創建一級或多級實時計算節點，其中，若創建多級實時計算節點，則級別在前的實時計算節點的定時器較級別在后的實時計算節點的定時器的時間粒度細。

7.根據權利要求6所述的系統，其特征在于，所述系統中，采用STL的map容器作為所述實時計算節點的內存緩存。

8.根據權利要求6所述的系統，其特征在于，所述待計算數據包括移動應用和/或Web應用的流式數據。

9.根據權利要求8所述的系統，其特征在于，所述移動應用或Web應用的流式數據包括：接口模調數據、用戶數據、日志數據中的一種或幾種。

10.根據權利要求6所述的系統，其特征在于，所述系統中，若級別在前的實時計算節點的定時器被觸發，則所述級別在前的實時計算節點的發送單元還用于：

將保存在其內存緩存中的計算結果值按照關鍵字進行一致性哈希之后發送至存儲模塊，作為級別在后的實時計算節點的待計算數據，并刪除級別在前的實時計算節點的內存緩存中的所述計算結果值以便進行下一時間粒度的實時計算。

11.一種電子設備，其特征在于，包括：

一個或多個處理器；

存儲裝置，用于存儲一個或多個程序，

當所述一個或多個程序被所述一個或多個處理器執行，使得所述一個或多個處理器實現如權利要求1-5中任一所述的方法。

12.一種計算機可讀介質，其上存儲有計算機程序，其特征在于，所述程序被處理器執行時實現如權利要求1-5中任一所述的方法。