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

在審

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

技術領域

本發明涉及一種數據串流處理，且特別涉及一種事件串流處理系統、方法以及機器可讀內存。

背景技術

事件驅動運算架構（Event-Driven?Architecture，EDA）近幾年逐漸受到重視。所謂事件（Event）指的是企業組織受到環境或內部的影響，造成數量的改變，其呈現的方法是用信息來記錄改變的狀態。事件驅動（Event-Driven）的應用系統區分為四大類，包括簡單事件（Simple?Events）、代收事件處理（Brokered?Event?Processing）、業務流程管理加強應用（Business?Process?Management（BPM）-Enabled?Applications）與復合事件處理（Complex?Event?Processing，CEP）。

復合事件處理是目前最具發展性的架構，不同于前述其他三種事件驅動的應用系統，復合事件處理是一個集中式/分布式的事件管理系統，其處理步驟分成三個階段。首先過濾掉不重要的事件，然后將事件歸類整理成更復雜的事件，最后根據事先設定的規則對這些事件產生對應的回應響應（Response）。然而，無論是在復合事件處理還是其他的事件處理都非常重視時間的有效性。

傳統的數據檢測分析方式是將實時串流數據先儲存至數據庫中。接著，再經由處理器檢測/分析事件，進而通知使用者需處理的事件。然而，是在傳統的數據檢測分析方式須先由數據庫中取出并過濾，將耗費較多的時間或錯失及時反映商務的時機。另外，傳統的數據檢測分析方式將事件傳送至服務器上進行計算，因此大量的網絡頻寬會被占用，若網絡頻寬不足，則將可能造成事件的處理速度下降。

發明內容

本發明實施例提供一種事件串流處理系統，且事件串流處理系統包括網關裝置（gateway?device）與擴充模塊。網關裝置包括事件處理引擎，而擴充模塊包括擴充處理器。事件處理引擎包括事件分群器、收集獲取器、處理器及事件產生器。事件處理引擎將符合條件規則的事件串流的多個事件進行處理。事件分群器將符合條件規則的事件進行分群。收集獲取器耦接于事件分群器，用以從事件中儲存第一群組事件。處理器耦接于事件分群器，用以處理第二群組事件。事件產生器將第一群組事件的第一處理結果與第二群組事件的第二處理結果整合并產生衍生事件。擴充處理器計算第一群組事件并產生第一處理結果。

本發明實施例提供一種事件串流處理方法，適用于事件串流處理系統。事件串流處理系統具有網關裝置與擴充模塊，事件串流處理方法包括以下步驟。首先，網關裝置篩選出符合條件規則的事件串流的多個事件并進行分群。接著，網關裝置將第一群組事件傳送到擴充模塊進行計算，并且將第二群組事件在網關裝置中進行計算。隨后，擴充模塊產生第一處理結果回傳給網關裝置。最后，網關裝置將第一群組事件的第一處理結果與第二群組事件的第二處理結果整合產生衍生事件。

綜上所述，通過本發明實施例的事件串流處理系統、方法及機器可讀內存，使受限于硬件效能及運算處理能力的網關裝置能夠通過外部的擴充模塊協助處理大量數據與運算復雜的處理程序。再者，通過擴充模塊，可依使用者的需求設定所需的定義函式，并且在擴充模塊與網關裝置之間通過通用的通信方式及數據格式的跨平臺整合方式，有效增加事件串流處理的靈活性。值得一提的是，通過本發明實施例由網關裝置對事件串流的事件進行實時處理的方式，網關裝置僅會將須進行處理的事件傳送至其連接的擴充模塊進行運算，故能夠有效節省網絡頻寬。

為使能更進一步了解本發明的特征及技術內容，請參閱以下有關本發明的詳細說明與附圖，但是此等說明與所附圖式僅是用來說明本發明，而非對本發明的權利要求范圍作任何的限制。

附圖說明

圖1為本發明實施例的事件串流處理系統或方法進行事件串流處理流程的示意圖。

圖2為本發明實施例的事件串流處理系統的網關裝置的細部方塊圖。

圖3為本發明實施例的事件串流處理系統的擴充模塊的細部方塊圖。

圖4為本發明另一實施例的事件串流處理系統的網關裝置的細部方塊圖。

圖5為本發明另一實施例的事件串流處理系統的擴充模塊的細部方塊圖。

圖6為本發明再一實施例的事件串流處理系統的擴充模塊的細部方塊圖。

圖7為本發明實施例的事件串流處理方法流程圖。

圖8-1至8-3為本發明實施例的事件串流處理方法的詳細流程圖。

【符號說明】

11：事件串流

13：使用者

14：數據庫