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

有效

• 申請號: 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.根據權利要求1所述的系統，其中所述組合器節點被配置為通過執行以下項中的至少一項來組合所述第三事件數據的所述至少一些第三事件數據和所述第四事件數據的所述至少一些第四事件數據：

所述第三事件數據的所述至少一些第三事件數據和所述第四事件數據的所述至少一些第四事件數據的聯合、接合，或者時間接合。

3.根據權利要求1所述的系統，其中所述組合器節點還被配置為確定與所述第四事件數據的所述至少一些第四事件數據相關聯的時間戳并且至少部分地基于所述時間戳確定所述請求時間。

4.根據權利要求1所述的系統，其中所述第一組運算符節點的所述運算符節點的運算符節點被配置為：

接收所述請求消息；

至少部分地基于所述請求消息中的所述請求時間和由所述運算符節點引入的延遲時間來確定改變的請求時間；

至少部分地基于所述請求消息和所述改變的請求時間確定改變的請求消息；

向所述通信接口提供所述改變的請求消息以代替所述請求消息。

5.根據權利要求4所述的系統，其中所述運算符節點的至少一個運算符節點被配置為至少部分地基于存儲的反向功能改變所述請求時間。

6.根據權利要求1所述的系統，其中：

所述源被配置為存儲與間隔索引相關聯的所述第一事件數據；

所述請求消息包括將被用于從所述源檢索點和/或間隔事件的一個或多個時間；

間隔事件包括起始邊緣事件和結束邊緣事件。

7.根據權利要求1所述的系統，其中所述請求消息還包括以下項中的至少一項：要從所述源檢索所述第一事件數據的事件的數目的數據或者要從所述源檢索的第一事件數據的量的數據。

8.根據權利要求7所述的系統，其中，所述第一組運算符節點和所述第二組運算符節點的至少一個的所述運算符節點中的一個或多個運算符節點被配置為至少部分地基于在所述運算符節點處定義的操作來修改從所述源將被檢索的事件的所述數目。

9.根據權利要求1所述的系統，其中所述第一組運算符節點的至少一個運算符節點被配置為：

存儲從所述至少一個運算符節點接收的事件的記錄；

接收所述請求消息；

至少部分地基于在所述至少一個運算符節點處接收的事件的所述記錄與由所述請求消息請求的事件數據之間的差異，確定將被檢索的事件數據；

生成傳出請求消息并且向所述通信接口發送所述傳出請求消息，所述傳出請求消息請求將被檢索的經確定的所述事件數據的至少一些經確定的事件數據。