[發明專利]用于歷史/實時/重播的數據的復雜事件處理器

有效

• 申請號: 201680020627.0
• 申請日: 2016-04-01
• 公開（公告）號: CN107438836B
• 公開（公告）日: 2020-08-28
• 發明（設計）人: L·巴薩德;I·J·G·d·桑托斯;O·納諾;T·塔納維斯基;J·戈爾茨坦;B·錢德拉莫利;L·諾維克
• 申請（專利權）人: 微軟技術許可有限責任公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F16/2455;G06F16/2458;G06F16/27
• 代理公司: 北京市金杜律師事務所 11256
• 代理人: 王茂華;姚杰

描述了一種復雜事件處理器，其具有通信接口，其被配置為通過從一個或多個源拉取事件數據來檢索事件數據并且接收被推送到該接口的至少一個實時事件流。連接到通信接口的事件處理管道包括連接在通信接口和組合器節點之間的多個運算符節點，組合器節點是被配置為組合來自源和來自實時事件流的事件數據的節點。通信接口被配置為從源檢索事件并將從源檢索的事件沿事件處理管道推送到組合器節點。通信接口被配置為僅響應于沿著管道在從組合器節點到通信接口的上游方向上傳遞的請求消息來檢索和推送檢索到的事件。

背景技術

復雜事件處理涉及訪問來自不同源的事件數據流，并且組合和分析該數據以計算可被用于控制下游系統或用于其他目的的輸出。復雜事件處理系統將一個或多個查詢應用于事件數據流，以從流中檢索數據并計算結果。

下面描述的實施例不限于解決已知的復雜事件處理系統的任何或所有缺點的實現。

發明內容

以下呈現了本公開的簡要概述，以便向讀者提供一個基本的理解。本發明內容并不旨在標識所要求保護的主題的關鍵特征或基本特征，也不旨在用于限制所要求保護的主題的范圍。其唯一目的是以簡化的形式作為稍后呈現的更詳細描述的序言呈現本文所公開的概念的選擇。

描述了一種復雜事件處理器，其具有通信接口，該通信接口被配置為從至少一個源檢索事件數據并且接收被推送到通信接口的包括至少一個實時/重播事件流的數據。被連接到通信接口的事件處理管道包括被連接在通信接口和作為組合器節點的運算符節點之間的多個運算符結點，組合器節點是被配置為組合從源被檢索的事件數據和從實時/重播事件流推送的數據的節點。通信接口被配置為從源中檢索事件并且沿著事件處理管道在從通信接口朝向組合器節點的下游方向上推送從源檢索的事件。通信接口被配置為僅響應于沿著管道在從組合器節點向通信接口的上游方向上傳遞的請求消息來檢索和推送檢索到的事件。

通過參考結合附圖所考慮的以下詳細描述，許多伴隨的特征可以更容易理解并且變得更好理解。

附圖說明

從根據附圖閱讀的下面的具體實施方式，本說明書將被更好地理解，其中：

圖1是具有與實時/重播的數據流和歷史數據源通信的歷史數據協議的復雜事件處理器的示意圖；

圖2是更詳細的復雜事件處理器的示意圖；

圖3是復雜事件處理器的查詢計劃的示意圖；

圖4是在復雜事件處理器的通信接口處的方法的流程圖；

圖5是在使用點事件批次的復雜事件處理器的運算符節點處的方法的流程圖；

圖6是在使用點事件批次的復雜事件處理器的組合器處的方法的流程圖；

圖7是在使用點或間隔事件批次的復雜事件處理器的運算符節點處的方法的流程圖；

圖8圖示了在其中復雜事件處理器的實施例可以被實現的示例性基于計算的設備。

在附圖中相同的附圖標記用于指明相同的部件。

具體實施方式

以下結合附圖提供的詳細描述旨在作為本實施例的描述，并不旨在表示在其中本實施例可以被構造或利用的唯一形式。該描述闡述了示例的功能和用于構建和操作示例的步驟序列。然而，相同或等同的功能和序列可以通過不同的示例來實現。