[發明專利]一種基于全內存計算對流數據進行查詢的方法和設備

有效

• 申請號: 202010189737.8
• 申請日: 2020-03-18
• 公開（公告）號: CN111414387B
• 公開（公告）日: 2021-11-12
• 發明（設計）人: 劉睿民
• 申請（專利權）人: 威訊柏睿數據科技（北京）有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06F16/2453
• 代理公司: 北京睿博行遠知識產權代理有限公司 11297
• 代理人: 龔家驊

1.一種基于全內存計算對流數據進行查詢的方法，應用于包括多個并行連接的內存數據庫的內存系統中，其特征在于，所述方法包括：

接收用戶發出的數據查詢請求；

在接收用戶發出的數據查詢請求之前，還包括：

基于監聽流數據事件獲取包含所述流數據的數量的通知，所述流數據事件是當所述流數據進入所述內存系統時觸發的；

根據所述通知建立與所述數量匹配的流處理進程；

根據所述數據查詢請求從流數據的流處理進程的事件窗口中確定查詢結果，所述流處理進程具體為流適配進程和流連接進程，所述事件窗口為所述流連接進程中對所述流數據進行接收與累積的窗口；

向所述用戶返回所述查詢結果。

2.如權利要求1所述的方法，其特征在于，基于所述流適配進程將所述流數據按預設格式寫入預設命名管道，所述流適配進程與所述命名管道一一對應；

基于所述事件窗口對所述命名管道中的流數據進行接收與累積，所述事件窗口是與所述流處理進程同步建立的。

3.如權利要求1所述的方法，其特征在于，在向所述用戶返回所述查詢結果之后，還包括：

將所述查詢結果中的數據進行刪除或存儲。

4.如權利要求2所述的方法，其特征在于，所述預設格式為逗號分隔值CSV格式，所述命名管道為Linux命名管道。

5.如權利要求1所述的方法，其特征在于，還包括，當不存在進入所述內存系統的流數據時，關閉所述事件窗口。

6.一種基于全內存計算對流數據進行查詢的設備，應用于包括多個并行連接的內存數據庫的內存系統中，其特征在于，所述設備包括：

接收模塊，用于接收用戶發出的數據查詢請求；

確定模塊，用于根據所述數據查詢請求從流數據的流處理進程的事件窗口中確定查詢結果，所述流處理進程具體為流適配進程和流連接進程，所述事件窗口為所述流連接進程中對所述流數據進行接收與累積的窗口；

返回模塊，用于向所述用戶返回查詢結果；

其中，所述設備還包括：

獲取模塊，用于基于監聽流數據事件獲取包含所述流數據的數量的通知，所述流數據事件是當所述流數據進入所述內存系統時觸發的。

7.如權利要求6所述的設備，其特征在于，還包括：

寫入模塊，用于基于所述流適配進程將所述流數據按預設格式寫入預設命名管道，所述流適配進程與所述命名管道一一對應；

累積模塊，用于基于所述事件窗口對所述命名管道中的流數據進行接收與累積，所述事件窗口是與所述流處理進程同步建立的。

8.如權利要求6所述的設備，其特征在于，還包括數據處理模塊，用于：

將所述查詢結果中的數據進行刪除或存儲。

9.如權利要求7所述的設備，其特征在于，

所述預設格式為逗號分隔值CSV格式，所述命名管道為Linux命名管道。

10.如權利要求6所述的設備，其特征在于，還包括關閉模塊，用于：

當不存在進入所述內存系統的流數據時，關閉所述事件窗口。