[發明專利]一種流數據處理的方法及裝置

在審

• 申請號: 202010131762.0
• 申請日: 2020-02-29
• 公開（公告）號: CN111367951A
• 公開（公告）日: 2020-07-03
• 發明（設計）人: 康雪丹;姜黎明;王大飛;江旻
• 申請（專利權）人: 深圳前海微眾銀行股份有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06F16/2458
• 代理公司: 北京同達信恒知識產權代理有限公司 11291
• 代理人: 侯林林

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

從監測的流數據中獲取符合篩選規則的各類業務數據；

針對每類業務數據，按照所述業務數據的預設結構對所述業務數據進行提取，得到設定緯度的業務數據；所述預設結構包括至少一個設定緯度；

按照預設的分組規則，對各類設定緯度的業務數據進行分組；

按照每個分組的預設算子，對分組內所述設定緯度的業務數據進行處理。

2.如權利要求1所述的方法，其特征在于，所述篩選規則包括以下至少一項：設定的數據源、設定類別的業務數據、設定的時間窗口。

3.如權利要求1所述的方法，其特征在于，所述按照所述業務數據的預設結構對所述業務數據進行提取，得到設定緯度的業務數據，包括：

按照所述業務數據的預設結構，將同一時間窗口內的所述業務數據構建數據矩陣；其中，每條業務數據對應所述數據矩陣中的一行，各條業務數據的同一設定緯度對應所述數據矩陣中的一列。

4.如權利要求1所述的方法，其特征在于，所述分組規則中設定有各分組的緯度主鍵，所述設定緯度包括所述緯度主鍵；

按照預設的分組規則，對各類設定緯度的業務數據進行分組，包括：

針對每個分組的緯度主鍵，得到所述分組的設定緯度的業務數據，其中，每個分組內的業務數據符合所述數據矩陣的方式。

5.如權利要求1至4任一項所述的方法，其特征在于，所述預設算子包括緯度指標和計算所述緯度指標的算子，所述設定緯度包括所述緯度指標；

按照每個分組的預設算子，對分組內所述設定緯度的業務數據進行處理，包括：

按照所述分組的緯度指標，調用所述算子對所述分組內的設定緯度的業務數據進行處理，得到所述分組在所述緯度指標的計算結果。

6.如權利要求5所述的方法，其特征在于，所述調用所述算子對所述分組內的設定緯度的業務數據進行處理，包括：

調用所述算子，對所述分組的數據矩陣中的列數據進行處理。

7.如權利要求5所述的方法，其特征在于，在所述對分組內所述設定緯度的業務數據進行處理之后，還包括：

根據預設的輸出模板，將處理后的計算結果按照所述輸出模板進行輸出。

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

獲取模塊，用于從監測的流數據中獲取符合篩選規則的各類業務數據；

處理模塊，用于針對每類業務數據，按照所述業務數據的預設結構對所述業務數據進行提取，得到設定緯度的業務數據；所述預設結構包括至少一個設定緯度；

所述處理模塊，還用于按照預設的分組規則，對各類設定緯度的業務數據進行分組；

所述處理模塊，還用于按照每個分組的預設算子，對分組內所述設定緯度的業務數據進行處理。

9.一種計算設備，其特征在于，包括：

存儲器，用于存儲程序指令；

處理器，用于調用所述存儲器中存儲的程序指令，按照獲得的程序執行權利要求1至7任一項所述的方法。

10.一種計算機可讀非易失性存儲介質，其特征在于，包括計算機可讀指令，當計算機讀取并執行所述計算機可讀指令時，使得計算機執行如權利要求1至7任一項所述的方法。