[發明專利]事件串流處理系統及其方法

在審

• 申請號: 201410035203.4
• 申請日: 2014-01-24
• 公開（公告）號: CN104717272A
• 公開（公告）日: 2015-06-17
• 發明（設計）人: 林谷原;王秉豐;周澤民
• 申請（專利權）人: 財團法人資訊工業策進會
• 主分類號: H04L29/08
• 分類號: H04L29/08;H04L12/66
• 代理公司: 北京康信知識產權代理有限責任公司 11240
• 代理人: 余剛;李靜

1.一種事件串流處理系統，其特征在于，所述事件串流處理系統包括：

一網關裝置，所述網關裝置包括：

一事件處理引擎，將符合一條件規則的一事件串流的多個事件進行處理，所述事件處理引擎包括：

一事件分群器，將符合所述條件規則的所述事件進行分群；

一收集獲取器，耦接于所述事件分群器，用以從所述事件中儲存一第一群組事件；

一處理器，耦接于所述事件分群器，用以處理一第二群組事件；以及

一事件產生器，將所述第一群組事件的一第一處理結果與所述第二群組事件的一第二處理結果整合，并產生一衍生事件；以及

至少一擴充模塊，耦接于所述網關裝置，每一個所述擴充模塊包括：

一擴充處理器，計算所述第一群組事件并產生所述第一處理結果。

2.根據權利要求1所述的事件串流處理系統，其特征在于，所述收集獲取器還包括：

至少一暫存單元，用以分別儲存所述第一群組事件中的至少一第一子群組事件。

3.根據權利要求1所述的事件串流處理系統，其特征在于，所述事件處理引擎還包括：

一篩選器，用以篩選符合所述條件規則的事件，并提供至所述事件分群器。

4.根據權利要求1所述的事件串流處理系統，其特征在于，所述收集獲取器用以將儲存的所述第一群組事件進行一特征獲取，并產生一特征向量與一殘存數據。

5.根據權利要求1所述的事件串流處理系統，其特征在于，所述收集獲取器用以將儲存的所述第一群組事件嵌入一時間標簽。

6.根據權利要求5所述的事件串流處理系統，其特征在于，每一個所述擴充模塊還包括：

一事件分析器，當每一個所述擴充模塊收到所述第一群組事件時檢查所述時間標簽。

7.根據權利要求1所述的事件串流處理系統，其特征在于，所述事件分群器用以將每一個所述事件嵌入一數據識別。

8.根據權利要求7所述的事件串流處理系統，其特征在于，所述事件產生器根據所述數據識別將所述第一處理結果與所述第二處理結果整合。

9.根據權利要求1所述的事件串流處理系統，其特征在于，每一個所述擴充模塊還包括：

一格式轉換單元，用以將所述第一群組事件進行格式轉換。

10.一種事件串流處理方法，適用于一事件串流處理系統，所述事件串流處理系統具有一網關裝置與至少一擴充模塊，其特征在于，所述事件串流處理方法包括：

所述網關裝置篩選出符合一條件規則的一事件串流的多個事件并進行分群；

所述網關裝置將一第一群組事件傳送到所述擴充模塊進行計算，并且將一第二群組事件在所述網關裝置中進行計算；

所述擴充模塊產生一第一處理結果并回傳給所述網關裝置；以及

所述網關裝置將所述第一群組事件的所述第一處理結果與所述第二群組事件的一第二處理結果整合，產生一衍生事件。

11.根據權利要求10所述的事件串流處理方法，其特征在于，在所述網關裝置將所述第一群組事件傳送到所述擴充模塊進行計算的步驟中，包括：

根據一預設參考值來判斷是否將所述第一群組事件進行傳送。

12.根據權利要求10所述的事件串流處理方法，其特征在于，在所述網關裝置將所述第一群組事件傳送到所述擴充模塊進行計算的步驟之前，包括：

所述網關裝置將所述第一群組事件進行一特征獲取，并產生一特征向量與一殘存數據。

13.根據權利要求12所述的事件串流處理方法，其特征在于，所述特征獲取為小波轉換、傅立葉轉換或離散余弦轉換。

14.根據權利要求10所述的事件串流處理方法，其特征在于，在所述網關裝置將所述第一群組事件傳送到所述擴充模塊進行計算的步驟之前，包括：

所述網關裝置將所述第一群組事件中每一個所述事件嵌入一時間標簽。

15.根據權利要求14所述的事件串流處理方法，其特征在于，在所述網關裝置將所述第一群組事件傳送到所述擴充模塊進行計算的步驟中，包括：

所述擴充模塊在收到所述第一群組事件時檢查所述時間標簽。