[發明專利]面向用戶用電信息采集系統的實時數據共享系統

有效

• 申請號: 202011347471.1
• 申請日: 2020-11-26
• 公開（公告）號: CN112492024B
• 公開（公告）日: 2022-04-29
• 發明（設計）人: 黃威;謝儉;陳石東;唐義德;趙俊;張亞萌;齊明;李敏士;孫程;彭清舟
• 申請（專利權）人: 國網湖南省電力有限公司;國網湖南省電力有限公司信息通信分公司;國家電網有限公司
• 主分類號: H04L67/1095
• 分類號: H04L67/1095;H04L67/568;H04L9/40;G06F16/2455;G06F21/31;G06Q50/06
• 代理公司: 長沙永星專利商標事務所(普通合伙) 43001
• 代理人: 周詠;米中業

本發明公開了一種面向用戶用電信息采集系統的實時數據共享系統，包括流數據處理模塊、Redis緩存系統、Kafka共享通道和權限管理模塊；流數據處理模塊解析數據流，把解析數據寫入到指定kafka的主題，并接收權限管理模塊下發的數據召測指令并轉發；Redis緩存系統實現用電信息采集系統冷熱數據分離和緩存數據；Kafka共享通道接受外圍系統的數據請求、實現訂閱/發布共享以及返回召測的實時數據；權限管理模塊為外圍系統創建賬號及密碼、token的生產與返回、權限驗證與指令下發以及權限的管理。本發明實現了面向用戶用電信息采集系統的實時數據共享，而且實時性好、可靠性好且穩定可靠。

技術領域

本發明屬于信息自動化領域，具體涉及一種面向用戶用電信息采集系統的實時數據共享系統。

背景技術

隨著經濟技術的發展和人們生活水平的提高，電能已經成為了人們生產和生活必不可少的二次能源，給人們的生產和生活帶來了無盡的便利。因此，電力系統的穩定可靠運行，就成為了電力系統最重要的任務之一。

隨著電網業務的不斷發展，要求用戶用電信息采集更實時、數據內容更全面。目前電網企業外圍系統實時數據需求包括日常批量實時數據共享需求與數據召測實時共享需求兩種，但是電網企業用電信息采集系統實時數據共享給其他外圍系統還存在一定問題：一是，用電信息采集系統采集回來數據后存入到數據庫中，其外圍系統通過數據庫OGG、ETL等方式來實現數據獲取批量實時數據，但是在用電信息采集業務高峰期，數據庫存在IO瓶頸問題，海量數據沒法實時存入數據庫。數據同步需要等待IO資源，業務高峰期時，數據共享延遲可達到2小時，無法滿足日常批量實時數據分析的業務需求；二是，由于現場用戶電表數據返回給用電信息采集系統主站的時間無法確定，外圍系統調用用電信息采集系統的實時數據召測同步接口后，可能長時間處于阻塞狀態，等待數據反饋，造成資源的浪費與程序阻塞。

發明內容

本發明的目的在于提供一種實時性好、可靠性好且穩定可靠的面向用戶用電信息采集系統的實時數據共享系統。

本發明提供的這種面向用戶用電信息采集系統的實時數據共享系統，包括流數據處理模塊、Redis緩存系統、Kafka共享通道和權限管理模塊；用電信息采集系統數據采集消息總線連接流數據處理模塊，流數據處理模塊的輸出端同時連接用電信息采集系統數據庫和Kafka共享通道；Redis緩存系統的輸入端連接用電信息采集系統數據庫，Redis緩存系統的輸出端連接流數據處理模塊；權限管理模塊連接外圍系統，權限管理模塊的輸入端連接外圍系統和Kafka共享通道，權限管理模塊的輸出端連接外圍系統和流數據處理模塊；Kafka共享通道連接外圍系統，同時Kafka共享通道的輸入端連接外圍系統和流數據處理模塊，Kafka共享通道的輸出端連接外圍系統和權限管理模塊；流數據處理模塊用于進行數據流解析，然后把解析后的數據寫入到指定Kafka的主題中，同時流數據處理模塊還用于負責接收權限管理模塊下發的數據召測指令，并負責把指令轉發至用電信息采集系統數據采集消息總線；Redis緩存系統用于實現用電信息采集系統冷熱數據分離，以及緩存用電信息采集系統數據庫中的電網企業用戶的檔案數據；Kafka共享通道用于接受外圍系統的數據請求、實現用電信息采集系統日常批量實時數據的訂閱/發布共享以及向外圍系統返回召測的實時數據；權限管理模塊用于為外圍系統創建賬號及密碼、用于token的生產與返回、權限驗證與指令下發以及權限的管理；所述面向用戶用電信息采集系統的實時數據共享系統用于實現日常批量數據的實時共享和實時召測數據的共享。

所述的流數據處理模塊，從Redis緩存系統中讀取系統用戶檔案信息，然后把采集設備的地址編號與采集計量點id、用戶戶號進行關聯處理，處理后的數據以用戶戶號、計量點id作為數據內容的標識，以JSON格式結構化數據寫入至Kafka共享通道對應的主題中進行共享。