[發明專利]基于電力行業的云上數據發布服務兩級共享緩存分析方法

有效

• 申請號: 201811511520.3
• 申請日: 2018-12-11
• 公開（公告）號: CN109614412B
• 公開（公告）日: 2023-06-02
• 發明（設計）人: 李偉東;猶鋒;王淵;夏心鋒
• 申請（專利權）人: 江蘇瑞中數據股份有限公司;南瑞集團有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06F16/25
• 代理公司: 南京蘇高專利商標事務所(普通合伙) 32204
• 代理人: 顏盈靜

1.基于電力行業的云上數據發布服務兩級共享緩存分析方法，其特征在于：包括以下步驟：

S1：原始數據接入，通過業務系統及相關采集端進行數據采集，利用流處理平臺Kafka推送至中心服務器對數據格式進行分析處理；

S2：采用Socket連接的通信方式將數據以JSON報文格式推送至數據共享端，數據共享端得到數據后解析入非關系型數據庫Redis，通過對JSON報文格式的數據塊解析組合得到鍵值對并寫入至非關系型數據庫Redis；

S3：將非關系型數據庫Redis作為一級緩存，采用線程池的方式從非關系型數據庫Redis中抽取數據，采用異步處理即時刪除和設置鍵值對生命周期的方式，對數據進行分析處理并寫入MySQL庫中，設置生命周期的方式為根據數據塊中的指標編碼設置鍵值對的生命周期；

S4：根據業務邏輯不同，在MySQL庫中分為兩種分析策略：第一種為：在分析非關系型數據庫Redis數據時同時抽取MySQL庫中數據進行組合運算，并寫入至MySQL庫中；第二種為：非關系型數據庫Redis中數據即時處理并全量更新至MySQL庫中，若計算線程超時，則根據超時機制以及非關系型數據庫Redis中設置的生命周期，自動清除過期數據，釋放線程進行新一輪運算；

S5：在MySQL中根據接收端需求不同對數據進行二次分析處理并推送至各個客戶端。

2.根據權利要求1所述的基于電力行業的云上數據發布服務兩級共享緩存分析方法，其特征在于：所述S1中，將業務系統及相關采集端采集到的數據根據相關屬性進行格式化處理后由流處理平臺Kafka推送至中心服務器。

3.根據權利要求2所述的基于電力行業的云上數據發布服務兩級共享緩存分析方法，其特征在于：所述S2具體為：根據心跳機制，通過Socket長連接將已格式化的數據采用JSON報文格式以數據流的方式發送，同時通過報文的校驗碼及回參保證數據的完整性，在接收報文數據之后進行解析入非關系型數據庫Redis。

4.根據權利要求1所述的基于電力行業的云上數據發布服務兩級共享緩存分析方法，其特征在于：在所述S4中，從MySQL庫中預設的關系映射表中查詢指標編碼的計算類型，若計算類型為1，則根據JSON串中的發送時間值作為時間戳抽取MySQL中時段數據，與非關系型數據庫Redis的數據組合計算后更新MySQL庫中預設的關系映射表數據；若計算類型為2，則根據JSON串中的發送時間值抽取非關系型數據庫Redis中時段數據進行分析計算，若計算超時則釋放線程，若鍵值對生命周期結束進行空運算并釋放線程。