[發明專利]時序數據的聚合查詢方法、裝置、計算機設備及可讀介質

有效

• 申請號: 201711267294.4
• 申請日: 2017-12-05
• 公開（公告）號: CN108268589B
• 公開（公告）日: 2019-07-23
• 發明（設計）人: 朱鴻偉;簡恒懿
• 申請（專利權）人: 北京百度網訊科技有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06F16/2458
• 代理公司: 北京鴻德海業知識產權代理事務所(普通合伙) 11412
• 代理人: 袁媛

1.一種時序數據的聚合查詢方法，其特征在于，所述方法包括：

接收用戶的時序數據的聚合查詢請求；所述聚合查詢請求中攜帶聚合函數、查詢的時間窗口以及查詢的時間范圍；

根據所述聚合函數的內層聚合函數的所述時間窗口、所述時間范圍、以及時序數據的時間與時序數據的存儲節點的對應關系，建立所述時間范圍內的、時間維度與存儲維度上的二維分片信息，所述二維分片信息中標識所述時間范圍內的、各所述時間窗口對應的多個所述存儲節點標識；

根據所述內層聚合函數以及各所述時間窗口對應的多個所述存儲節點標識，控制各所述時間窗口對應的所述存儲節點在本地執行所述內層聚合函數的相關操作，并返回操作結果；

根據接收到的所述時間范圍內的、各所述時間窗口對應的操作結果以及所述聚合函數，生成聚合查詢結果。

2.根據權利要求1所述的方法，其特征在于，若所述聚合函數為單聚合函數，所述聚合函數僅包括所述內層聚合函數，根據接收到的所述時間范圍內的、各所述時間窗口對應的操作結果以及所述聚合函數，生成聚合查詢結果，具體包括：

根據接收到的所述時間范圍內的、各所述時間窗口對應的操作結果以及所述內層聚合函數，獲取各所述時間窗口對應的所述內層聚合函數的處理結果，作為所述聚合查詢結果。

3.根據權利要求1所述的方法，其特征在于，若所述聚合函數為嵌套聚合函數，所述聚合函數還包括外層聚合函數，根據所述時間范圍內的、各所述時間窗口對應的操作結果以及所述聚合函數，生成聚合查詢結果，具體包括：

根據接收到的所述時間范圍內的、各所述時間窗口對應的操作結果以及所述內層聚合函數，獲取各所述時間窗口對應的所述內層聚合函數的處理結果；

根據各所述時間窗口對應的所述內層聚合函數的處理結果以及所述外層聚合函數，獲取所述外層聚合函數的處理結果，作為所述聚合查詢結果。

4.根據權利要求1-3任一所述的方法，其特征在于，根據所述內層聚合函數以及各所述時間窗口對應的多個所述存儲節點標識，控制各所述時間窗口對應的所述存儲節點在本地執行所述內層聚合函數的相關操作，并返回操作結果，具體包括：

根據所述內層聚合函數，生成各所述時間窗口對應的所述存儲節點的本地任務，以供所述存儲節點在本地執行所述內層聚合函數的相關操作；

根據各所述時間窗口對應的多個所述存儲節點標識，向各所述時間窗口對應的所述存儲節點下發所述本地任務，以供對應的所述存儲節點執行所述本地任務，并返回所述操作結果。

5.根據權利要求4所述的方法，其特征在于，若所述內層聚合函數為時序無關的函數，根據所述內層聚合函數，生成各所述時間窗口對應的所述存儲節點的本地任務，具體包括：

根據所述內層聚合函數，生成各所述時間窗口對應的每個所述存儲節點的本地任務；

對應地，根據各所述時間窗口對應的每個所述存儲節點標識，向各所述時間窗口對應的所述存儲節點下發所述本地任務，具體包括：

根據各所述時間窗口對應的多個所述存儲節點標識，向各所述時間窗口對應的每個所述存儲節點下發對應的所述本地任務。

6.根據權利要求4所述的方法，其特征在于，若所述內層聚合函數為時序有關的函數，根據所述內層聚合函數，生成各所述時間窗口對應的所述存儲節點的本地任務，具體包括：

從各所述時間窗口對應的多個所述存儲節點標識中選取一個作為目標存儲節點標識；

根據所述內層聚合函數以及各所述時間窗口對應的多個所述存儲節點標識，生成各所述時間窗口對應的所述目標存儲節點的本地任務；所述本地任務中指示所述目標存儲節點先從對應于同一所述時間窗口的其他所述存儲節點拷貝所述時間窗口的所有時序數據，然后執行所述內層聚合函數的相關操作；

對應地，根據各所述時間窗口對應的多個所述存儲節點標識，向各所述時間窗口對應的每個所述存儲節點下發對應的所述本地任務，具體包括：

根據各所述時間窗口對應的所述目標存儲節點標識，向各所述時間窗口對應的所述目標存儲節點下發對應的所述本地任務。