[發明專利]一種能源互聯網的實時數據分析系統及其方法

在審

• 申請號: 201510766730.7
• 申請日: 2015-11-11
• 公開（公告）號: CN105577422A
• 公開（公告）日: 2016-05-11
• 發明（設計）人: 王遠;蔣英明;吳佳;蘇丹;袁衛國;陳立宇;鄭曉露;粟勇;周淳;史英杰;袁軍;李賢慧
• 申請（專利權）人: 江蘇瑞中數據股份有限公司;國家電網公司;國網冀北電力有限公司信息通信分公司
• 主分類號: H04L12/24
• 分類號: H04L12/24;H04L12/26
• 代理公司: 南京知識律師事務所 32207
• 代理人: 汪旭東

1.一種能源互聯網的實時數據分析系統，包括緩存組件、計算組件、協調服務組件，其特征 在于所述的緩存組件向計算組件單向通信，所述的緩存組件和協調服務組件之間雙向通信， 所述的計算組件和協調服務組件之間雙向通信，所述的緩存組件上連接有API接口，所述的 API接口與協調服務組件之間雙向通信，所述的計算組件上連接有存儲組件，所述的存儲組 件與計算組件之間雙向通信。

2.根據權利要求1所述的一種能源互聯網的實時數據分析系統，其特征在于所述的計算組件 包括數據源單元和計算單元，所述的數據源單元向計算單元單向通信。

3.根據權利要求2所述的一種能源互聯網的實時數據分析系統，其特征在于所述的存儲組件 向數據源單元單向通信，所述的計算單元向存儲組件單向通信。

4.根據權利要求1或2所述的一種能源互聯網的實時數據分析系統，其特征在于所述的API 接口為實時數據加載API接口和/或實時消息加載API接口；所述的存儲組件包括實時數據庫、 關系數據庫和HDFS。

5.一種能源互聯網的實時數據分析方法，其特征在于在實時計算分析場景下執行實時流計算； 在歷史數據統計分析場景下執行離線計算。

6.根據權利要求5所述的一種能源互聯網的實時數據分析方法，其特征在于所述的實時流計 算步驟包括：

1)應用程序通過API接口向緩存組件加載實時數據；

2)計算組件的數據源單元從緩存層讀取實時數據；

3)計算組件的數據計算單元，完成實時流數據的計算，并將計算結果存儲于存儲組件。

7.根據權利要求5所述的一種能源互聯網的實時數據分析方法，其特征在于所述的離線計算 分為定時周期離線計算和消息觸發離線計算，所述的定時周期離線計算步驟包括：1)計算組 件的數據源單元通過定時機制，從存儲組件中定時地獲取歷史數據；2)計算組件的計算單元 完成業務計算，并將計算結果存儲于存儲組件，所述的消息觸發離線計算步驟包括：1)應用 程序通過API接口，將觸發消息發送至緩存組件；2)計算組件的數據源單元，從緩存組件獲 取消息，并且數據源單元獲得消息后，則從存儲組件讀取歷史數據；3)計算組件的計算單元 完成業務計算，并將計算結果存儲于存儲組件。