[發(fā)明專利]事件處理系統(tǒng)和方法

在審

• 申請?zhí)枺?/td>: 201410636735.3
• 申請日: 2014-11-06
• 公開（公告）號: CN105279014A
• 公開（公告）日: 2016-01-27
• 發(fā)明（設(shè)計）人: 巴拉特·阿帕德拉斯塔;斯里尼瓦桑·蘇達爾薩納姆;祖賓·道拉蒂;蘇比爾·曼蘇克哈尼
• 申請（專利權(quán)）人: 穆西格馬交易方案私人有限公司
• 主分類號: G06F9/46
• 分類號: G06F9/46;G06F11/30
• 代理公司: 北京英賽嘉華知識產(chǎn)權(quán)代理有限責任公司 11204
• 代理人: 余朦;王艷春

背景技術(shù)

本發(fā)明大體上涉及框架，更具體地涉及一種用于在執(zhí)行可編程任務(wù)的同時對實時數(shù)據(jù)和非實時數(shù)據(jù)進行處理的事件處理系統(tǒng)。

在當今信息量豐富的環(huán)境中，對大量的數(shù)據(jù)進行有效的處理是重要并且具有挑戰(zhàn)性的。通常，當事件發(fā)生時，數(shù)據(jù)可被提供在數(shù)據(jù)流中，并且在許多情況下，實時的生成數(shù)據(jù)值。例如，在追蹤和訪問應(yīng)用中用于射頻識別(RFID)的微傳感器能夠提供關(guān)于正在被追蹤的目標的位置的流數(shù)據(jù)。再如，定義金融交易的數(shù)據(jù)可在這些交易發(fā)生時被提供在數(shù)據(jù)流中。

對于許多行業(yè)來說，對實時到達的流數(shù)據(jù)進行操作的能力能夠提供顯著的競爭優(yōu)勢。例如，基于金融交易結(jié)果的金融操作可在交易發(fā)生時接收關(guān)于交易的數(shù)據(jù)流。此外，對流數(shù)據(jù)中的具體信號迅速地作出響應(yīng)通常是許多應(yīng)用的關(guān)鍵方面。例如，政府機關(guān)所使用的、用來偵測安全威脅的網(wǎng)絡(luò)監(jiān)控系統(tǒng)需要對表現(xiàn)在通過監(jiān)控收集的數(shù)據(jù)流中的事件進行偵測和報告。

然而，在大多數(shù)應(yīng)用中，對流式數(shù)據(jù)的處理通過首先將數(shù)據(jù)存儲到數(shù)據(jù)庫中來執(zhí)行。隨后，能夠通過查詢該數(shù)據(jù)庫來檢索用于進一步處理和分析的數(shù)據(jù)。因此，對實時數(shù)據(jù)進行分析是困難的，這是由于數(shù)據(jù)庫訪問時間所強加的限制，特別是對于具有高數(shù)據(jù)速率的流。

因此，需要一種集成系統(tǒng)，其在執(zhí)行若干軟件應(yīng)用的同時能夠使用事件處理系統(tǒng)中的實時數(shù)據(jù)和非實時數(shù)據(jù)。

發(fā)明內(nèi)容

簡要地，根據(jù)本發(fā)明的一個方面，提供了一種事件處理系統(tǒng)。該事件處理系統(tǒng)包括基于多代理的系統(tǒng)。該基于多代理的系統(tǒng)包括核心引擎，被配置為定義和部署多個代理，其中這多個代理被配置為執(zhí)行由一個或多個用戶定義的第一組可編程任務(wù)。該第一組可編程任務(wù)被配置為與實時數(shù)據(jù)一起進行操作。基于多代理的系統(tǒng)還包括監(jiān)控引擎，被配置為監(jiān)控多個代理的生命周期、多個代理之間的通信、以及可編程任務(wù)的處理時間。基于多代理的系統(tǒng)進一步包括計算引擎，聯(lián)接至核心引擎并被配置為執(zhí)行第一組可編程任務(wù)。上述事件處理系統(tǒng)包括批量處理系統(tǒng)，被配置為使能對第二組可編程任務(wù)的部署，其中第二組可編程任務(wù)與非實時數(shù)據(jù)一起進行操作；以及工作室，聯(lián)接至基于多代理的系統(tǒng)并被配置為使一個或多個用戶能夠?qū)υ摶诙啻淼南到y(tǒng)和批量處理系統(tǒng)進行管理。

根據(jù)另一個方面，提供了一種用于執(zhí)行可編程任務(wù)的、基于實時多代理的系統(tǒng)。該系統(tǒng)包括核心引擎，被配置為定義和部署多個代理，其中這多個代理被配置為執(zhí)行由一個或多個用戶定義的一組可編程任務(wù)。該組可編程任務(wù)被配置為與實時數(shù)據(jù)一起進行操作。上述基于實時多代理的系統(tǒng)還包括監(jiān)控引擎，被配置為監(jiān)控多個代理的生命周期、多個代理之間的通信、以及可編程任務(wù)的處理時間。該基于實時多代理的系統(tǒng)進一步包括計算引擎，聯(lián)接至核心引擎并被配置為執(zhí)行上述一組可編程任務(wù)；以及工作室，聯(lián)接至基于(實時)多代理的系統(tǒng)并被配置為使一個或多個用戶能夠?qū)υ摶?實時)多代理的系統(tǒng)進行管理。

根據(jù)又一個方面，提供了一種用于處理事件的方法。該方法包定義和部署多個代理，這多個代理被配置為執(zhí)行由一個或多個用戶定義的第一組可編程任務(wù)。該第一組可編程任務(wù)被配置為與實時數(shù)據(jù)一起進行操作。上述方法還包括監(jiān)控多個代理的生命周期、多個代理之間的通信、以及可編程任務(wù)的處理時間。該方法進一步包括執(zhí)行第一組可編程任務(wù)和部署第二組可編程任務(wù)，其中第二組可編程任務(wù)與非實時數(shù)據(jù)一起進行操作。另外，該方法包括使一個或多個用戶能夠?qū)崟r數(shù)據(jù)和非實時數(shù)據(jù)進行管理。

附圖說明

在參照附圖對以下詳細描述進行閱讀時，可以更好地理解本發(fā)明的這些和其他特征、方面、以及優(yōu)勢，在整個附圖中，相同的符號代表相同的部件，其中：

圖1是根據(jù)本技術(shù)的方面實現(xiàn)的事件處理系統(tǒng)的一個實施方式的框圖；

圖2是根據(jù)本技術(shù)的方面實現(xiàn)的、基于多代理的系統(tǒng)的一個實施方式的框圖；

圖3是根據(jù)本技術(shù)的方面實現(xiàn)的核心引擎的一個實施方式的框圖；

圖4表現(xiàn)了描繪根據(jù)本技術(shù)的方面實現(xiàn)的、若干處理器之間的、代理的移動性的示例方案；

圖5是根據(jù)本技術(shù)的方面實現(xiàn)的事件處理系統(tǒng)的示例平臺和用于監(jiān)控的相關(guān)操作的框圖；

圖6是根據(jù)本技術(shù)的方面實現(xiàn)的、使一個或多個用戶能夠創(chuàng)建代理、代理集和生態(tài)系統(tǒng)的示例工作室界面的圖示；

圖7是根據(jù)本技術(shù)的方面實現(xiàn)的、用于創(chuàng)建代理的示例用戶界面的圖示；

圖8是根據(jù)本技術(shù)的方面實現(xiàn)的、描繪事件處理系統(tǒng)中的生態(tài)系統(tǒng)、代理集以及代理的示例用戶界面的圖示；以及

圖9是根據(jù)本技術(shù)的方面實現(xiàn)的、用于實現(xiàn)事件處理系統(tǒng)的示例通用計算設(shè)備的框圖。