[發明專利]一種分布式系統、數據聚合方法和計算機可讀存儲介質

有效

• 申請號: 201911418011.0
• 申請日: 2019-12-31
• 公開（公告）號: CN113132267B
• 公開（公告）日: 2022-09-02
• 發明（設計）人: 于平;韓洪偉
• 申請（專利權）人: 奇安信科技集團股份有限公司;奇安信網神信息技術（北京）股份有限公司
• 主分類號: G06F16/24
• 分類號: G06F16/24;G06F16/27
• 代理公司: 北京英特普羅知識產權代理有限公司 11015
• 代理人: 程超

1.一種分布式系統，其特征在于，所述分布式系統包括若干查詢節點，所述查詢節點用于接收用戶發送的查詢請求，且接收所述查詢請求的查詢節點稱為協調節點，其中：

所述協調節點用于：解析所述查詢請求以確定所述查詢請求指向的目標索引分片，獲取所述目標索引分片的分片信息，確定本地存儲所述目標索引分片的查詢節點，作為目標節點，根據所述分片信息構建查詢子請求，并將所述查詢子請求發送至所述目標節點；

所述目標節點用于：接收并解析所述查詢子請求以得到所述分片信息，根據所述分片信息定位出本地存儲的所述目標索引分片，運行所述目標索引分片以得到所述查詢子請求所請求的查詢結果，在本地存儲的所有所述目標索引分片不唯一時，聚合所有所述目標索引分片的查詢結果得到第一聚合結果，并將所述第一聚合結果返回所述協調節點；

所述協調節點還用于：接收所述目標節點返回的所述第一聚合結果，并聚合若干所述目標節點返回的所有所述第一聚合結果；其中，即便返回所述第一聚合結果的目標節點的數量小于節點數量，但是協調節點一旦判定當前時間距離接收所述查詢請求的時間的時間間隔大于等于預設時間閾值，便開始聚合當前接收到的所有第一聚合結果并返給用戶；當協調節點判定返回所述第一聚合結果的目標節點的數量等于所述節點數量時，聚合所有所述目標節點返回的所有所述第一聚合結果；所述節點數量為確定出的所有目標節點的數量；

所述目標節點在執行解析所述查詢子請求以得到所述分片信息的步驟時，還用于：解析所述查詢子請求以得到所述分片信息和所述分片數量；其中，每個查詢子請求只能攜帶一個目標索引分片的分片信息，所述分片數量為所述目標節點本地存儲的所有所述目標索引分片的數量；

所述目標節點在執行在本地存儲的所有所述目標索引分片不唯一時，聚合所有所述目標索引分片的查詢結果得到第一聚合結果的步驟時，還用于：在所述分片數量大于1且得到的所有所述查詢結果的數量等于所述分片數量時，聚合所有所述查詢結果得到所述第一聚合結果。

2.一種數據聚合方法，其特征在于，應用于目標節點，所述方法包括：

接收協調節點發送的查詢請求，作為第一查詢請求；

解析所述第一查詢請求以得到分片信息；

根據所述分片信息定位出本地存儲的目標索引分片；

運行所述目標索引分片以得到所述第一查詢請求所請求的查詢結果；

在本地存儲的所有所述目標索引分片不唯一時，聚合所有所述目標索引分片的查詢結果得到第一聚合結果，并將所述第一聚合結果返回所述協調節點；其中，即便返回所述第一聚合結果的目標節點的數量小于節點數量，但是協調節點一旦判定當前時間距離接收第二查詢請求的時間的時間間隔大于等于預設時間閾值，便開始聚合當前接收到的所有第一聚合結果并返給用戶；當協調節點判定返回所述第一聚合結果的目標節點的數量等于所述節點數量時，聚合所有所述目標節點返回的所有所述第一聚合結果；所述節點數量為本地存儲所述第二查詢請求指向的目標索引分片的所有目標節點的數量，所述第二查詢請求為所述用戶向所述協調節點發送的查詢請求；

所述解析所述第一查詢請求以得到分片信息的步驟包括：解析所述第一查詢請求以得到所述分片信息和分片數量；其中，每個查詢子請求只能攜帶一個目標索引分片的分片信息，所述分片數量為本地存儲的所有所述目標索引分片的數量；

所述在本地存儲的所有所述目標索引分片不唯一時，聚合所有所述目標索引分片的查詢結果得到第一聚合結果的步驟包括：在所述分片數量大于1且得到的所有所述查詢結果的數量等于所述分片數量時，聚合所有所述查詢結果得到所述第一聚合結果。

3.根據權利要求2所述的方法，其特征在于，所述方法還包括：

在接收的所有第一所述查詢請求不唯一時，統計接收的所有第一所述查詢請求的數量；

判斷接收的所有所述第一查詢請求的數量是否大于預設數量閾值；

在接收的所有第一所述查詢請求的數量大于所述預設數量閾值時，同時解析所述預設數量閾值個所述第一查詢請求，且在得到任一所述第一查詢請求所請求的查詢結果之后，繼續解析接收的所有所述第一查詢請求中剩余的任一所述第一查詢請求。