[發明專利]一種基于流處理引擎和規則引擎的實時數據告警方法

在審

• 申請號: 202010230307.6
• 申請日: 2020-03-27
• 公開（公告）號: CN111444291A
• 公開（公告）日: 2020-07-24
• 發明（設計）人: 鮑增凱
• 申請（專利權）人: 上海愛數信息技術股份有限公司
• 主分類號: G06F16/28
• 分類號: G06F16/28;G06F16/21
• 代理公司: 上海科盛知識產權代理有限公司 31225
• 代理人: 葉敏華

1.一種基于流處理引擎和規則引擎的實時數據告警方法，其特征在于，包括以下步驟：

S1、創建告警頁面，基于規則引擎配置與目標應用設備匹配的異常信息處理機制，新建實時告警規則；

S2、配置告警規則后，采用Flink流式處理引擎接收目標應用設備的實時數據，利用Flink流式處理引擎連接事件流和配置流；

S3、利用關系型數據庫存放告警規則；

S4、Flink流式處理引擎調用規則引擎Drools，規則引擎Drools對事實和規則進行匹配，判斷Flink流式處理引擎所接收的數據是否需要進行告警處理，對于符合規則引擎告警的條件發出告警動作；

S5、規則引擎Drools對規則進行動態更新。

2.根據權利要求1所述的一種基于流處理引擎和規則引擎的實時數據告警方法，其特征在于，步驟S2中利用Flink流式處理引擎連接事件流和配置流的具體步驟包括：

21)Flink流處理引擎分別監聽Kafka消息隊列創建的事件流主題數據和配置流主題數據，Flink流處理引擎的事件流監聽kafka的事件主題，Flink流處理引擎的配置流監聽kafka的配置主題；

22)Flink流處理引擎通過調用函數BroadcastProcessFunction連接事件流數據和配置流數據，并利用該類調用函數的processElement方法處理事件流的數據，利用該類的processBroadcastElement方法處理配置流進來的數據。

3.根據權利要求1所述的一種基于流處理引擎和規則引擎的實時數據告警方法，其特征在于，步驟S3的具體內容為：

31)規則引擎Drools提供相關的API，識別以.drl為擴展名的文件，并通過KieHelper方法讀取以字符串形式表達的drl文件內容，在規則引擎Drools運行期間，規則引擎Drools讀取drl文件中的規則內容，隨后編譯并存放到規則庫中，告警系統中的業務規則全部抽象為對應的drl文件；

32)采用數據庫的表維護規則引擎Drools中可編譯識別的drl字符串內容，將每一類規則轉換成drl字符串內容并存放在數據的二維表中。

4.根據權利要求3所述的一種基于流處理引擎和規則引擎的實時數據告警方法，其特征在于，存儲在數據庫表的drl字符串內容包括規則內容表和規則原型表。

5.根據權利要求4所述的一種基于流處理引擎和規則引擎的實時數據告警方法，其特征在于，規則內容表的生成過程包括以下步驟：

a.添加規則包名稱；

b.添加import導入類信息；

c.添加declare原型類信息；

d.添加規則名稱，所述的規則名稱采用規則固定名稱及唯一id的方式；

e.添加規則引擎Drools的If邏輯判斷模塊，用于對傳入的事實進行相關的匹配判斷；

f.添加then處理部分，用于獲取上一步匹配判斷的觸發結果，向數據庫中插入告警記錄。

6.根據權利要求5所述的一種基于流處理引擎和規則引擎的實時數據告警方法，其特征在于，規則原型表的生成過程包括以下步驟：

a.規則原型表存放規則內容表中的declare的原型類名稱；

b.規則原型表額外存儲原型表所包含的屬性字段信息。