[發明專利]用于處理事件流中的事件的方法、系統、存儲介質及裝置

有效

• 申請號: 201780064336.6
• 申請日: 2017-09-07
• 公開（公告）號: CN109863485B
• 公開（公告）日: 2023-04-14
• 發明（設計）人: H·帕克;S·比施諾伊;P·圖卡拉姆
• 申請（專利權）人: 甲骨文國際公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455
• 代理公司: 中國貿促會專利商標事務所有限公司 11038
• 代理人: 邊海梅

公開了一種用于處理事件流中的事件的方法、系統、存儲介質及裝置。該系統被配置用于對流處理器進行配置以對來自流源的傳入事件進行微批處理。該系統還被配置用于為傳入事件的微批生成單個時間戳和/或從流源接收傳入事件的微批。該系統還可以被配置用于向微批的每個事件分配單個時間戳和/或為微批的每個相應事件生成單獨的時間戳值。在一些示例中，該系統還可以被配置用于為微批的每個相應事件分配單獨的時間戳值中的個體時間戳值。

對相關申請的交叉引用

本申請依據35?U.S.C§119(e)要求于2016年9月15日提交的標題為“PROCESSINGTIMESTAMPS?AND?HEARTBEAT?EVENTS?FOR?AUTOMATIC?TIME?PROGRESSION”的美國臨時申請62/395,044的權益和優先權，該申請的全部內容為了所有目的通過引用并入本文。

背景技術

在傳統的數據庫系統中，數據通常以表的形式存儲在一個或多個數據庫中。然后使用數據管理語言(諸如結構化查詢語言(SQL))來查詢和操縱所存儲的數據。例如，可以定義和執行SQL查詢以從存儲在數據庫中的數據中識別相關數據。因此SQL查詢針對存儲在數據庫中的有限數據集來執行。此外，當執行SQL查詢時，SQL查詢針對有限數據集來執行一次并產生有限靜態結果。因此數據庫最佳地被配備為對有限的存儲的數據集運行查詢。

但是，許多現代應用和系統以連續數據或事件流而不是有限數據集的形式生成數據。這樣的應用的示例包括但不限于傳感器數據應用、金融報價機(ticker)、網絡性能測量工具(例如，網絡監視和業務管理應用)、點擊流分析工具、汽車交通監視等。這種應用已經引起了對可以處理數據流的新型應用的需求。例如，溫度傳感器可以被配置為發出溫度讀數。

管理和處理這些類型的基于事件流的應用的數據涉及構建具有強大時間焦點的數據管理和查詢能力。需要包括針對連續的無界(unbounded)數據集的長期運行的查詢的不同種類的查詢機制。雖然一些供應商現在供應面向事件流處理的產品套件，但是這些產品供應物仍然缺乏處置當今的事件處理需求所需的處理靈活性。

發明內容

提供了用于對流處理器進行配置以對來自流源的傳入事件進行微批處理(micro-batch)的技術(例如，方法、系統、存儲能夠由一個或多個處理器執行的代碼或指令的非瞬態計算機可讀介質)。在實施例中，該系統被配置用于為傳入事件的微批(micro-batch)生成單個時間戳和/或從流源接收傳入事件的微批。該系統還被配置用于向微批的每個事件分配單個時間戳和/或至少部分地基于算法為微批的每個相應事件生成單獨的時間戳值。在一些示例中，該系統還可以被配置用于為微批的每個相應事件分配單獨的時間戳值中的個體時間戳值。

在某些實施例中，該算法包括掛鐘推進算法、均勻分布算法、均勻分布的頂部離開(top?off)算法或簡單序列算法。在一些示例中，分配單獨的時間戳值中的個體時間戳值包括將單獨的時間戳值中的個體時間戳值附加到微批的每個事件的單個時間戳。此外，該算法為微批的每個事件提供唯一的時間戳和/或該算法確保微批的每個事件能夠被識別為微批的一部分。在一些情況下，該系統還可以被配置用于將每個事件分配給一個或多個連續查詢語言引擎分區、識別該一個或多個連續查詢語言引擎分區中的第一分區，和/或確定第一分區具有比批中分配給第一分區的多個事件中的事件的數量更大的窗口尺寸。此外，在一些情況下，該系統可以被配置用于為第一分區生成心跳事件和/或將該心跳事件插入到第一分區中。

以上和以下描述的技術可以以許多方式和在許多上下文中實現。參考如下面更詳細描述的以下各圖提供了若干示例實現和上下文。但是，以下實現和上下文只是許多實現和上下文中的一小部分。

附圖說明

圖1描繪了根據本公開的實施例的示例事件處理系統的方面。

圖2是可以結合本公開的實施例的事件處理系統的簡化高級圖。

圖3是圖示根據本公開的實施例的分布式事件處理系統的示例用例的框圖。