[發明專利]分布式數據聚合方法、系統、設備及存儲介質

有效

• 申請號: 202011207551.7
• 申請日: 2020-11-03
• 公開（公告）號: CN112307066B
• 公開（公告）日: 2023-04-07
• 發明（設計）人: 徐建誠
• 申請（專利權）人: 平安普惠企業管理有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06F16/2458;G06F16/25;G06F16/27
• 代理公司: 北京市京大律師事務所 11321
• 代理人: 姚維

1.一種分布式數據聚合方法，其特征在于，所述分布式聚合方法應用于分布式數據聚合系統，所述分布式數據聚合系統包括聚合管理平臺、N個應用系統和M個數據源，所述聚合管理平臺與所述N個應用系統通信連接，所述N個應用系統與所述M個數據源通信連接，所述分布式數據聚合方法包括：

建立訪問所述數據源的數據庫連接池；創建與所述數據源數量相同的并一一對應的訪問所述數據源的數據庫連接；將所述數據庫連接存儲在所述數據庫連接池中；

所述N個應用系統中有數據查詢需求的應用系統向所述聚合管理平臺發送數據查詢請求，其中，所述N為不小于1的自然數，所述聚合管理平臺用于配置聚合服務的節點管理、配置版本管理和配置推送管理；

所述聚合管理平臺解析所述數據查詢請求，并生成數據查詢指令發送至所述N個應用系統中的對應的應用系統；

接收到所述數據查詢指令的應用系統通過自身配置的聚合SDK解析所述數據查詢指令，從所述M個數據源中配置對應的數據源，其中，所述M為不小于1的自然數；

接收到所述數據查詢指令的應用系統通過數據映射和數據路由，解析所述數據查詢指令，得到對應的數據信息，并根據所述數據信息，通過數據路由配置動態分配合理的數據源實例，并在所述數據庫連接池中選擇對應的數據庫連接，通過數據連接池中的數據庫連接，并行/串行的連接對應數據源執行相應的指令獲取數據，獲取所述數據查詢指令查詢的數據；

接收到所述數據查詢指令的應用系統通過自身配置的聚合SDK將所述數據進行聚合計算，得到數據結果；

各接收到所述數據查詢指令的應用系統將獲得的數據結果發送至所述聚合管理平臺，通過所述聚合管理平臺將所有所述數據結果發送至所述N個應用系統中有數據查詢需求的應用系統。

2.根據權利要求1所述的分布式數據聚合方法，其特征在于，在所述所述N個應用系統中有數據查詢需求的應用系統向所述聚合管理平臺發送數據查詢請求之前，還包括：

獲取具有數據聚合功能的應用程序的源代碼；

對所述源代碼進行解析，并提取出應用程序編程接口的接口信息；

獲取預設編程語言對應的SDK模板，所述SDK模板包括待填充項；

從所述接口信息中獲取與所述SDK模板中每個所述待填充項對應的目標接口信息，將所述目標接口信息按照預設編程語言編譯后填充至所述SDK模板的所述待填充項中，生成聚合SDK；

將所述聚合SDK配置在各應用系統中。

3.根據權利要求1所述的分布式數據聚合方法，其特征在于，所述所述聚合管理平臺解析所述數據查詢請求，并生成數據查詢指令發送至所述N個應用系統中對應的應用系統包括：

所述聚合管理平臺查詢N個所述應用系統的初始配置參數；

根據所述初始配置參數將所述數據查詢請求劃分為多個子請求；

所述聚合管理平臺將所述子請求作為觸發數據查詢指令發送至所述N個應用系統中對應的應用系統。

4.根據權利要求3所述的分布式數據聚合方法，其特征在于，所述接收到所述數據查詢指令的應用系統通過自身配置的聚合SDK解析所述數據查詢指令，從所述M個數據源中配置對應的數據源包括：

接收到所述數據查詢指令的應用系統通過自身配置的所述聚合SDK解析對應的子請求，得到對應的數據信息；

根據預設的所述數據信息與數據源的對應關系，配置接收到所述數據查詢指令的應用系統對應的數據源。

5.根據權利要求4所述的分布式數據聚合方法，其特征在于，所述接收到所述數據查詢指令的應用系統通過自身配置的所述聚合SDK解析對應的子請求，得到對應的數據信息包括：

獲取與所述子請求對應的數據規則；

從所述數據規則中獲取對應的數據庫表；

判斷所述數據庫表的數量是否大于一；

若是，則根據所述數據庫表之間的關聯關系，對獲取所述數據庫表對應的數據源的獲取順序進行排序。