[發明專利]基于流處理的事件處理方法及系統

在審

• 申請號: 202010537106.0
• 申請日: 2020-06-12
• 公開（公告）號: CN111708645A
• 公開（公告）日: 2020-09-25
• 發明（設計）人: 況衛飛
• 申請（專利權）人: 北京思特奇信息技術股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 北京輕創知識產權代理有限公司 11212
• 代理人: 馮瑛琪

1.一種基于流處理的事件處理方法，其特征在于，包括：

預處理單元對事件進行預處理，將預處理后的事件以消息的方式發送至消息中間件，通過所述消息中間件將所述消息轉發給流處理平臺；

所述流處理平臺將所述事件與預設的事件匹配規則進行匹配，當匹配成功后，將所述事件發送給訂閱關系處理單元；

所述訂閱關系處理單元查閱所述事件的訂閱信息，將所述訂閱信息和所述事件發送給封裝單元；

所述封裝單元根據所述訂閱信息對所述事件進行封裝并分發。

2.根據權利要求1所述的基于流處理的事件處理方法，其特征在于，預處理單元對事件進行預處理，具體包括：

預處理單元對事件進行清洗，將清洗后的事件進行標準化處理。

3.根據權利要求1或2所述的基于流處理的事件處理方法，其特征在于，所述事件匹配規則包括：簡單事件匹配規則和復雜事件匹配規則，其中，所述簡單事件匹配規則包括：事件源編碼、事件標識、事件名稱、生失效標識和規則表達式中的至少一種；所述復雜事件匹配規則包括：至少一個簡單事件，以及每個簡單事件的成立時間。

4.根據權利要求3所述的基于流處理的事件處理方法，其特征在于，所述流處理平臺將所述事件與預設的事件匹配規則進行匹配，當匹配成功后，將所述事件發送給訂閱關系處理單元，具體包括：

所述流處理平臺判斷所述事件是簡單事件或復雜事件，如果是簡單事件，則將所述事件與所述簡單事件匹配規則進行匹配，當匹配成功后，將所述事件發送給訂閱關系處理單元；

如果是復雜事件，則將所述事件通過所述復雜事件匹配規則拆分成簡單事件，再將拆分后的簡單事件與所述簡單事件匹配規則進行匹配，當匹配成功后，將簡單事件發送給復雜事件匹配單元；

所述復雜事件匹配單元查詢所述簡單事件所屬的復雜事件的匹配時長和關聯的簡單事件的列表，將關聯的簡單事件存儲在緩存中，并將有效期設置為所述匹配時長，遍歷所述簡單事件的列表，查詢所述緩存中是否存在拆分后的簡單事件，如果全部存在，則將全部簡單事件拼裝后作為匹配數據發送給訂閱關系處理單元。

5.根據權利要求1所述的基于流處理的事件處理方法，其特征在于，所述封裝單元根據所述訂閱信息對所述事件進行封裝并分發，具體包括：

所述封裝單元根據所述訂閱信息判斷當前時間是否在所述事件的訂閱時間段內，如果在，則根據所述訂閱信息判斷是否滿足訂閱頻次要求，如果滿足，則根據所述訂閱信息將所述事件按照訂閱格式進行拼裝，將拼裝后的數據寫入對應的消息中間件主題。

6.一種基于流處理的事件處理系統，其特征在于，包括：預處理單元、消息中間件、流處理平臺、訂閱關系處理單元和封裝單元，其中：

所述預處理單元用于對事件進行預處理，將預處理后的事件以消息的方式發送至所述消息中間件，通過所述消息中間件將所述消息轉發給所述流處理平臺；

所述流處理平臺用于將所述事件與預設的事件匹配規則進行匹配，當匹配成功后，將所述事件發送給所述訂閱關系處理單元；

所述訂閱關系處理單元用于查閱所述事件的訂閱信息，將所述訂閱信息和所述事件發送給所述封裝單元；

所述封裝單元用于根據所述訂閱信息對所述事件進行封裝并分發。

7.根據權利要求6所述的基于流處理的事件處理系統，其特征在于，所述預處理單元具體用于對事件進行清洗，將清洗后的事件進行標準化處理。

8.根據權利要求6或7所述的基于流處理的事件處理系統，其特征在于，所述事件匹配規則包括：簡單事件匹配規則和復雜事件匹配規則，其中，所述簡單事件匹配規則包括：事件源編碼、事件標識、事件名稱、生失效標識和規則表達式中的至少一種；所述復雜事件匹配規則包括：至少一個簡單事件，以及每個簡單事件的成立時間。