[發明專利]數據處理和查詢方法及裝置

在審

• 申請號: 201610875245.8
• 申請日: 2016-09-30
• 公開（公告）號: CN107885752A
• 公開（公告）日: 2018-04-06
• 發明（設計）人: 李國忠
• 申請（專利權）人: 阿里巴巴集團控股有限公司
• 主分類號: G06F17/30
• 分類號: G06F17/30
• 代理公司: 北京市惠誠律師事務所11353
• 代理人: 劉子敬

1.一種數據處理方法，其特征在于，包括：

對實時流數據進行局部合并，得到至少一個局部數據；

將所述局部數據進行緩存；

在滿足預設的匯總條件時，對當前緩存的數據進行匯總，以得到匯總數據；其中所述當前緩存的數據至少包括所述局部數據。

2.根據權利要求1所述的方法，其特征在于，所述當前緩存的數據均為局部數據。

3.根據權利要求1所述的方法，其特征在于，所述當前緩存的數據中包括上次滿足所述匯總條件時得到的匯總數據以及當前匯總條件下的局部數據。

4.根據權利要求1-3任一項所述的方法，其特征在于，所述在滿足預設的匯總條件時，對當前緩存的數據進行匯總，以得到匯總數據之后，還包括：

清除經過匯總后的所述局部數據；

緩存匯總得到的所述匯總數據。

5.根據權利要求4所述的方法，其特征在于，所述對實施流數據進行局部合并，得到至少一個局部數據，包括：

將預設的時間間隔內的所有流數據進行合并，以得到所述局部數據。

6.根據權利要求5所述的方法，其特征在于，所述匯總條件為預設的時間長度或者緩存的數據個數。

7.一種數據查詢方法，其特征在于，包括：

接收客戶端發送的查詢請求；

查詢接收到所述查詢請求時的匯總數據以及局部數據；其中，所述匯總數據為在滿足預設的匯總條件時，對當前緩存的數據進行匯總得到的數據，所述局部數據為對實時流數據進行局部合并得到的數據；

將接收到所述查詢請求時的匯總數據以及局部數據進行聚合，以得到聚合數據；

將所述聚合數據發送給所述客戶端。

8.一種數據查詢方法，其特征在于，包括：

接收客戶端發送的查詢請求；

查詢接收到所述查詢請求時的匯總數據以及局部數據；其中，所述匯總數據為在滿足預設的匯總條件時，對當前緩存的數據進行匯總得到的數據，所述局部數據為對實時流數據進行局部合并得到的數據；

將接收到所述查詢請求時的匯總數據以及局部數據發送給所述客戶端。

9.根據權利要求8所述的方法，其特征在于，所述將接收到所述查詢請求時的匯總數據以及局部數據發送給所述客戶端之后，還包括：

接收所述客戶端返回的所述聚合數據，所述聚合數據是由所述客戶端對接收到所述查詢請求時的匯總數據以及局部數據進行聚合得到的。

10.一種數據查詢方法，其特征在于，包括：

向存儲端發送查詢請求，以使所述存儲端根據所述查詢請求查詢接收到所述查詢請求時的匯總數據以及局部數據；其中，所述匯總數據為在滿足預設的匯總條件時，對當前緩存的數據進行匯總得到的數據，所述局部數據為對實時流數據進行局部合并得到的數據；

接收所述存儲端發送的所述匯總數據以及所述局部數據；

將所述匯總數據以及所述局部數據進行聚合得到聚合數據。

11.根據權利要求10所述的方法，其特征在于，所述將所述匯總數據以及所述局部數據進行聚合得到聚合數據之后，包括：

將所述聚合數據發送給所述存儲端進行存儲。

12.一種數據處理裝置，其特征在于，包括：

局部合并模塊，用于對實時流數據進行局部合并，得到至少一個局部數據；

緩存模塊，用于將所述局部數據進行緩存；

匯總模塊，用于在滿足預設的匯總條件時，對當前緩存的數據進行匯總，以得到匯總數據；其中所述當前緩存的數據至少包括所述局部數據。

13.一種數據查詢裝置，其特征在于，包括：

接收模塊，用于接收客戶端發送的查詢請求；

查詢模塊，用于查詢接收到所述查詢請求時的匯總數據以及局部數據；其中，所述匯總數據為在滿足預設的匯總條件時，對當前緩存的數據進行匯總得到的數據，所述局部數據為對實時流數據進行局部合并得到的數據；

聚合模塊，用于將接收到所述查詢請求時的匯總數據以及局部數據進行聚合，以得到聚合數據；

發送模塊，用于將所述聚合數據發送給所述客戶端。