[發明專利]一種實時告警數據定制轉發方法

在審

• 申請號: 202111314208.7
• 申請日: 2021-11-08
• 公開（公告）號: CN114064270A
• 公開（公告）日: 2022-02-18
• 發明（設計）人: 牛雪朋;李永照;鐵永奎;孫振;包芳;陳哲;沈志廣;李宏川;張海庭;郭利軍;胡斌
• 申請（專利權）人: 許繼集團有限公司;許昌許繼軟件技術有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F9/54
• 代理公司: 北京中創云知識產權代理事務所(普通合伙) 11837
• 代理人: 任必為

本發明公開了一種實時告警數據定制轉發方法，包括如下步驟：變電站告警數據的生產者向消息中心發送包含告警數據的生產消息；從消息中心接收消息中心發出的告警消息，根據訂閱方式處理所述告警消息；3)向告警接收客戶端發送處理后的告警消息。通過按照業務不同需求定制轉發告警消息的方法，解決了告警信息的數據傳輸量、處理量大的技術問題，提高了CPU的利用率。

技術領域

本發明涉及變電站監控領域，特別涉及一種實時告警數據定制轉發方法。

背景技術

隨著變電站技術的快速發展，變電站的監視范圍已經從只監視變電站一次設備、二次設備，慢慢延伸到輔助設備如消防設備、安防設備、動環類設備、在線監測類等的變電站全景化監視。在變電站的全景監視下，數據采集信息越來越龐大，告警信息也越來越繁多，告警種類也越來越復雜。告警信息承載著后方各種不同業務的關鍵數據，其智能化水平的提升對于提高變電站設備狀態全面感知、快速應對電網異常告警具有重要意義，因此告警信息的處理越來越重要，其處理的精準性決定了后方各種不同業務的消息來源的可靠性，其處理的快速化決定了其他依賴告警消息的業務的時效性。

傳統的變電站監控系統在告警信息分析處理時存在以下問題：現有各個客戶端、圖形插件等都需要獨立接收全部告警信息并且獨立進行數據過濾，導致告警信息的數據傳輸量、處理量大，CPU利用率低。

發明內容

基于此，有必要針對上述技術問題，提供一種實時告警數據定制轉發方法，包括如下步驟：

包括如下步驟：

1)變電站告警數據的生產者向消息中心發送包含告警數據的生產消息；

2)從消息中心接收消息中心發出的告警消息，根據訂閱方式處理所述告警消息；

3)向告警接收客戶端發送處理后的告警消息。

進一步地，步驟1)中消息中心包括Kafka消息總線，變電站告警數據的生產者向Kafka消息總線發送包含告警數據的生產消息；Kafka消息總線的消費者包括實時告警數據定制轉發模塊；根據Kafka消息總線的生產者與消費者協議定義Kafka消息總線的告警主題，實時告警數據定制轉發模塊向Kafka消息總線訂閱所述告警主題。

進一步地，步驟2)從消息中心接收消息中心發出的告警消息，根據訂閱方式處理所述告警消息具體包括步驟：

步驟2.1)實時告警數據定制轉發模塊中定義一個消息接收棧，用于從Kafka消息總線中消費所述告警消息并存放到消息接收棧；

步驟2.2)將消息接收棧中的告警消息發送到線程池中的線程；

步驟2.3)告警接收客戶端向實時告警數據定制轉發模塊訂閱告警消息，訂閱時包含告警接收客戶端的訂閱方式；

步驟2.4)線程根據所述訂閱方式處理告警消息。

進一步地，步驟3)向告警接收客戶端發送處理后的告警消息具體包括步驟：當實時告警數據定制轉發模塊發現滿足告警接收客戶端要求的告警消息時直接向告警接收客戶端發送處理后的告警消息。

進一步地，步驟2.1)消息接收棧內每條告警消息有唯一的告警消息ID，告警消息ID從1開始遞增，告警消息ID最大條目為可存入的告警消息條目，告警消息ID達到最大條目則重新從1開始遞增。

進一步地，步驟2.2)將消息接收棧中的消息發送到線程池中的線程具體包括：

告警消息出棧時，首先判斷線程池中當前是否存在未處理任務的線程，如果存在則直接將告警消息發送給未處理任務的線程，如果不存在未處理任務的線程，則判斷當前線程個數是否小于2倍的CPU核數，小于時創建新線程處理告警消息，不小于時對告警消息ID進行取模操作，將告警消息平均分配給所有的線程。