[發明專利]一種查詢時序數據統計最大連續遞增次數與遞減次數的處理方法

有效

• 申請號: 201910219682.8
• 申請日: 2019-03-21
• 公開（公告）號: CN109948007B
• 公開（公告）日: 2020-07-14
• 發明（設計）人: 王新宇;王新根;魯萍;黃滔;王剛
• 申請（專利權）人: 浙江邦盛科技有限公司
• 主分類號: G06F16/9035
• 分類號: G06F16/9035;G06Q40/04
• 代理公司: 杭州求是專利事務所有限公司 33200
• 代理人: 劉靜;邱啟旺

本發明公開了一種查詢時序數據統計最大連續遞增次數與遞減次數的處理方法，本發明預先對數據序列分組，然后計算每個分組的最大連續遞增與遞減次數、首元素、尾元素、從首元素開始的連續遞增與遞減次數、以尾元素為止的連續遞增與遞減次數及每個分組的元素個數，把中間結果存儲在相應時間戳上，查詢時根據指定時間戳快速得到計算結果；由于只存儲計算后的中間結果，內存耗費降低，存儲效率提高，因為提前計算好了中間結果，所以在查詢時響應速度極快；最為重要的是，這部分結果跟著系統時間移動而不斷變化，能夠達到時間窗口平滑移動的目的。本發明適用于時序數據處理技術等數據分析領域，能夠顯著提升計算時序數據最大連續遞增與遞減次數的速度。

技術領域

本發明是一種時序數據處理技術，根據時序數據中的時間戳，將指定區間的時序運算結果存于該區間對應時間戳上，從而提供時間窗口平行滑動處理的能力。主要適用于時序數據處理技術等數據分析領域。

背景技術

在時序數據分析處理領域，對于時間窗口滑動處理的方案很多，大多都是將某個實體上面的數據進行過濾保留原始數據，從而進行adhoc查詢的方案。adhoc查詢非常靈活，但是一旦實體過大(數據過于密集)，每次需要處理的數據量變大，性能會十分低下。

假設有個賬號具備如下序列，⑦⑤⑥②排布如圖1所示。假設以當前時間作為基準，我們需要統計該賬號過去6小時的交易金額的最大連續遞增次數。按照adhoc處理的形式，需要根據當前時間(18:00:00)，計算統計區間的起點(18-6＝12:00:00)，找到12點到18點的所有數據，然后對這些數據進行統計遞增計算得到4這個答案。每次系統時間向前滑動，就需要重復上述計算步驟。因為每次都需要基于原始時間序列重復計算，整個計算過程復雜且效率低下，唯一的優勢就是計算比較靈活。

發明內容

本發明的目的在于針對現有技術的不足，提供一種查詢時序數據進行統計最大連續遞增次數與遞減次數的處理方法。

本發明的目的是通過以下技術方案來實現的：一種查詢時序數據統計最大連續遞增次數與遞減次數的處理方法，對于一個時序數據集合P＝{(t₁,v₁),(t₂,v₂),(t₃,v₃),…,(t_n,v_n)}，其中t代表不同事件時間，v代表對應時間上的一個事件；對該時序數據集合，計算其在任意時間區間內的最大連續遞增次數或遞減次數，具體處理步驟為：

(1)根據時間切片長度TS對數據集合進行分組，得到集合M＝{{(t₁,v₁),(t₂,v₂)…(t_m1,v_m1)},{(t_m1+1,v_m1+1),(t_m2+2,v_m2+2)…(t_m2,v_m2)}…{(t_mi+1,v_mi+1),(t_mi+2,v_mi+2)…(t_n,v_n)}}：對于集合P里的每個元素(t,v)，都有(t,v)屬于而且僅屬于集合M的一個元素M_x，其中(t,v)與M_x的映射關系為t/TS+1＝x。這樣，M集合里的每個元素M_x代表時序數據集P中事件時間在TS*(x-1)與TS*x之間的元素組成的集合；