[發明專利]一種金融數據處理方法、裝置、系統和存儲介質

在審

• 申請號: 202010529708.1
• 申請日: 2020-06-11
• 公開（公告）號: CN111522890A
• 公開（公告）日: 2020-08-11
• 發明（設計）人: 邵茂林
• 申請（專利權）人: 中國建設銀行股份有限公司;建信金融科技有限責任公司
• 主分類號: G06F16/28
• 分類號: G06F16/28;G06Q40/02
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

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

獲取Storm數據處理平臺傳輸的金融數據；

根據Druid連接池預設的數據粒度配置存儲所述金融數據；

確定所述金融數據為新增數據時，控制Druid連接池的計算節點主動拉取所述金融數據進行緩存。

2.根據權利要求1所述的方法，其特征在于，還包括：

根據用戶查詢語句和所述Druid連接池計算節點中的金融數據生成查詢結果。

3.根據權利要求1所述的方法，其特征在于，所述根據Druid連接池預設的數據粒度配置存儲所述金融數據，包括：

基于Druid連接池的實時節點對所述金融數據的數據粒度進行分析；

將所述金融數據中數據粒度為片段的片段數據存儲到深度存儲器；

將所述金融數據中數據粒度為元數據的屬性數據存儲到關系型數據庫。

4.根據權利要求3所述的方法，其特征在于，所述確定所述金融數據為新增數據時，控制Druid連接池的計算節點主動拉取所述金融數據進行緩存，包括：

控制Druid連接池的主節點拉取關系型數據庫存儲的屬性數據；

根據所述屬性數據確定對應的片段數據為新增數據；

控制Zookeeper處理框架根據所述屬性數據生成拉取消息；

控制Druid連接池的計算節點根據所述拉取消息拉取所述深度存儲器存儲的片段數據，并緩存所述片段數據。

5.根據權利要求2或4所述的方法，其特征在于，所述根據用戶查詢語句和所述Druid連接池計算節點中的金融數據生成查詢結果，包括：

當Druid連接池的路由節點獲取到用戶的查詢語句時，將所述查詢語句分發到所述計算節點；

控制所述計算節點根據所述查詢語句查詢金融數據生成查詢結果。

6.根據權利要求1所述的方法，其特征在于，所述Storm數據處理平臺創建有所述金融數據的狀態對象，并基于Zookeeper處理框架維護所述狀態對象。

7.根據權利要求6所述的方法，其特征在于，所述金融數據的數據分片關聯有分片標識符，Storm數據處理平臺的Firehose接口將所述分片標識符持久化到所述Zookeeper處理框架。

8.一種金融數據處理裝置，其特征在于，所述裝置包括：

數據獲取模塊，用于獲取Storm數據處理平臺傳輸的金融數據；

數據存儲模塊，用于根據Druid連接池預設的數據粒度配置存儲所述金融數據；

緩存處理模塊，用于確定所述金融數據為新增數據時，控制Druid連接池的計算節點主動拉取所述金融數據進行緩存。

9.一種系統，其特征在于，所述設備包括：

一個或多個處理器；

存儲器，用于存儲一個或多個程序，

當所述一個或多個程序被所述一個或多個處理器執行，使得所述一個或多個處理器實現如權利要求1-7中任一所述的金融數據處理方法。

10.一種計算機可讀存儲介質，其上存儲有計算機程序，其特征在于，該程序被處理器執行時實現如權利要求1-7中任一所述的金融數據處理方法。