[發明專利]一種智慧園區數據分析補償系統

在審

• 申請號: 202210875239.8
• 申請日: 2022-07-25
• 公開（公告）號: CN115202845A
• 公開（公告）日: 2022-10-18
• 發明（設計）人: 李順;秦鋼;宋楊;花京武
• 申請（專利權）人: 杭州指令集智能科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/54;G06F5/06;H04L67/12
• 代理公司: 杭州品眾專利代理事務所(特殊普通合伙) 33459
• 代理人: 陳雅晨

1.一種智慧園區數據分析補償系統，其特征在于：包括：

規則配置模塊，用于配置數據模型；

數據采集器，與規則配置模塊通信，用于通過規則配置模塊配置后與外部數據提供方通信連接，以通過訂閱數據或是數據拉取的方式采集數據內容，；

數據提取分發器，與規則配置模塊通信，還與數據采集器通信，用于通過規則配置模塊配置后將數據采集器采集的數據進行提取和分發；

Fink計算任務模塊，與數據提取分發器通信，以接收數據提取分發器分發的數據后對數據進行計算，計算出結果數據后輸出；

結果數據分發器，與Fink計算任務模塊通信，還與外部數據使用方通信連接，以接收Fink計算任務模塊輸出的結果數據，并傳輸至數據使用方。

2.根據權利要求1所述的智慧園區數據分析補償系統，其特征在于：所述規則配置模塊配置數據模型的信息為數據采集配置、計算配置和發布配置，其中數據采集配置為配置請求地址、參數和調度周期。

3.根據權利要求2所述的智慧園區數據分析補償系統，其特征在于：所述數據采集器采集數據內容的具體步驟如下：

步驟1，對外部數據提供方的數據來源的類型進行識別，分為API、Mysql和Kafka；

步驟2，當類型識別為API和Mysq1時，內置一個統籌的定時器，通過定時器統一管理和調度拉取任務；

步驟3，當類型識別為Kafka時，內置一個具有消息隊列的客戶端，通過客戶端監聽數據推送；

其中，定時器統一管理和調度拉取任務的方式包括時間cron表達式的解析、拉取失敗后的重試以及增量數據的保證，其中增量數據的保證為通過應用redis保證在服務異常情況下減少數據重復消費處理的情況。

4.根據權利要求3所述的智慧園區數據分析補償系統，其特征在于：所述Fink計算任務模塊進行數據計算的具體方式為首先計算事件隊列FIFO，之后根據計算獲得的事件隊列FIFO進行窗口計算和實時輸出計算，然后將窗口計算結果和實時輸出計算結果打包成結果數據后輸出。

5.根據權利要求4所述的智慧園區數據分析補償系統，其特征在于：所述計算事件隊列FIFO的具體步驟為通過Fink流數據接收器接收API、Mysql和Kafka所輸出的數據，然后根據規則配置模塊的配置規則匹配和推送事件至窗口計算和實時輸出計算。

6.根據權利要求5所述的智慧園區數據分析補償系統，其特征在于：所述結果數據分發器分發結果數據的具體方式為調用JAVA服務通知結果數據，之后由JAVA服務存儲和對外分發。

7.根據權利要求6所述的智慧園區數據分析補償系統，其特征在于：所述Fink計算任務模塊在輸出計算結果后進行數據沉淀，然后再進行異步處理結果數據，最后將異步處理后的結果數據輸出。