[發(fā)明專利]一種流數(shù)據(jù)滑動窗口聚集查詢方法

有效

• 申請?zhí)枺?/td>: 201710549374.2
• 申請日: 2017-07-07
• 公開（公告）號: CN109213778B
• 公開（公告）日: 2023-07-18
• 發(fā)明（設(shè)計）人: 王桂玲;韓燕波
• 申請（專利權(quán)）人: 北方工業(yè)大學(xué)
• 主分類號: G06F16/242
• 分類號: G06F16/242;G06F16/2455;G06F16/25
• 代理公司: 北京泛華偉業(yè)知識產(chǎn)權(quán)代理有限公司 11280
• 代理人: 王勇

1.一種流數(shù)據(jù)滑動窗口聚集查詢方法，包括：

1)根據(jù)客戶端的請求，在客戶端與服務(wù)端之間建立HTTP長連接；

2)在所述長連接的存續(xù)期間，由所述服務(wù)端根據(jù)所述請求向所述客戶端推送滑動窗口中的數(shù)據(jù)，包括：

2-1)所述服務(wù)端根據(jù)用于采集流數(shù)據(jù)的監(jiān)測點數(shù)目u、以及所述滑動窗口的數(shù)據(jù)量n，選擇用于對流數(shù)據(jù)進(jìn)行處理的計算模型，包括：

2-11)所述服務(wù)端根據(jù)所述監(jiān)測點數(shù)目u、所述滑動窗口的數(shù)據(jù)量n、以及預(yù)置的延遲查詢表，選擇服務(wù)響應(yīng)的延遲最小的計算模型；

2-12)所述服務(wù)端根據(jù)所述監(jiān)測點數(shù)目u、所述滑動窗口的數(shù)據(jù)量n，利用延遲L與u和n的關(guān)系，計算出計算模型所對應(yīng)的服務(wù)響應(yīng)的延遲大小，其中所述延遲L與u和n的關(guān)系為：L＝A×n+B×u+C，其中A、B、C為待確定的參數(shù)，A是n與L之間的斜率，B是u與L之間的斜率，C是直線的截距。

2.根據(jù)權(quán)利要求1所述的方法，其中還包括：

3)當(dāng)出現(xiàn)以下情況時，關(guān)閉所述HTTP長連接，服務(wù)端釋放為所述客戶端分配的資源：

所述服務(wù)端收到來自所述客戶端的要求關(guān)閉連接的信息；或者

所述服務(wù)端發(fā)送要求關(guān)閉連接的信息到達(dá)客戶端；或者

所述服務(wù)端檢測到所述客戶端已關(guān)閉。

3.根據(jù)權(quán)利要求1所述的方法，所述計算模型包括以下一種或多種：Esper、Hadoop、Storm、Spark。

4.根據(jù)權(quán)利要求1所述的方法，其中，

所述延遲查詢表所存儲的表項被用于確定在相應(yīng)的u、和n下服務(wù)響應(yīng)的延遲最小的計算模型。

5.根據(jù)權(quán)利要求4所述的方法，其中所述延遲查詢表所存儲的表項為通過對在相應(yīng)的u、和n下各個計算模型的真實延遲進(jìn)行檢測而確定。

6.根據(jù)權(quán)利要求1所述的方法，其中步驟2-1)還包括：

2-13)根據(jù)計算獲得的結(jié)果，選擇用于對流數(shù)據(jù)進(jìn)行處理的計算模型。

7.根據(jù)權(quán)利要求1所述的方法，其中所述參數(shù)A、B、C通過最小二乘法的方式以以下步驟計算獲得：

2-12a)對中的參數(shù)A、B、C分別求導(dǎo)，并求導(dǎo)的結(jié)果等于0；

2-12b)對下述方程組進(jìn)行求解，計算參數(shù)A、B、C，

2-12c)利用所獲得的參數(shù)A、B、C以及L＝A×n+B×u+C，確定所述計算模型的延遲；

其中，i表示針對計算模型的第i組測量的標(biāo)號，u_i表示針對計算模型的第i組測量時所采用的監(jiān)測點數(shù)目，n_i表示針對計算模型的第i組測量時所采用的滑動窗口的數(shù)據(jù)量，L_i表示針對計算模型的第i組測量時實際發(fā)生的延遲。

8.一種計算機可讀存儲介質(zhì)，其中存儲有計算機程序，所述計算機程序在被執(zhí)行時用于實現(xiàn)如權(quán)利要求1-7中任意一項所述的方法。