[發明專利]分布式數據處理方法、裝置、服務器及可讀存儲介質

在審

• 申請號: 202011374158.7
• 申請日: 2020-11-30
• 公開（公告）號: CN112486592A
• 公開（公告）日: 2021-03-12
• 發明（設計）人: 王健;高斌;陳林;陳俊立
• 申請（專利權）人: 成都新希望金融信息有限公司
• 主分類號: G06F9/445
• 分類號: G06F9/445;G06F16/25;G06F16/242
• 代理公司: 北京超凡宏宇專利代理事務所(特殊普通合伙) 11463
• 代理人: 余菲

1.一種分布式數據處理方法，其特征在于，應用于包括數據執行引擎的分布式服務器，所述方法包括：

通過所述執行引擎中的統一數據接口獲取異構數據；

通過所述執行引擎中的語言轉換模塊將所述異構數據轉換為預設格式的操作語句，并得到所述異構數據的參數變量；

通過所述語言轉換模塊，基于所述操作語句與數據源的數據格式的對應關系，將所述操作語句轉換為與目標數據源對應的目標數據格式的待處理數據，所述目標數據源為任一數據源；

通過所述執行引擎中的解析執行模塊對所述待處理數據進行執行處理，得到所述待處理數據的操作結果，所述操作結果包括所述異構數據的所述參數變量。

2.根據權利要求1所述的方法，其特征在于，通過所述執行引擎中的解析執行模塊對所述待處理數據進行執行處理，得到所述待處理數據的操作結果，包括：

通過所述解析執行模塊根據所述待處理數據中的附加信息，確定所述待處理數據的處理策略，所述附加信息包括所述待處理數據與處理策略的對應關系，所述處理策略包括同步處理策略或異步處理策略；

當所述待處理數據的所述處理策略為所述同步處理策略時，基于所述同步處理策略執行處理所述待處理數據，得到所述操作結果；

當所述待處理數據的所述處理策略為所述異步處理策略時，基于所述異步處理策略執行處理所述待處理數據，得到所述操作結果。

3.根據權利要求2所述的方法，其特征在于，當所述待處理數據的所述處理策略為所述同步處理策略時，基于所述同步處理策略執行處理所述待處理數據，得到所述操作結果，包括：

根據所述同步處理策略執行處理所述待處理數據，并在得到所述操作結果時，將所述操作結果發送至用戶終端。

4.根據權利要求2所述的方法，其特征在于，當所述待處理數據的所述處理策略為所述異步處理策略時，基于所述異步處理策略執行處理所述待處理數據，得到所述操作結果，包括：

根據所述異步處理策略執行處理所述待處理數據；

輪詢查找是否得到所述操作結果，并在得到所述操作結果時，將所述操作結果發送至用戶終端。

5.根據權利要求1所述的方法，其特征在于，通過所述執行引擎中的解析執行模塊對所述待處理數據進行執行處理，得到所述待處理數據的操作結果，包括：

通過所述解析執行模塊判斷是否存在與所述待處理數據對應的三方插件；

當存在所述三方插件，且所述三方插件為前置操作插件時，熱加載所述前置操作插件，當所述前置操作插件運行第一預設時長后，通過所述解析執行模塊對所述待處理數據進行執行處理，得到所述操作結果；

當存在所述三方插件，且所述三方插件為后置操作插件時，通過所述解析執行模塊對所述待處理數據進行執行處理，得到所述操作結果，并熱加載所述后置操作插件并運行第二預設時長。

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

在接收到查詢指令時，基于所述查詢指令中的第一參數變量，從所有所述操作結果中確定與所述第一參數變量匹配的結果數據，其中，當所述操作結果中的第二參數變量與所述第一參數變量相同時，確定所述操作結果為所述結果數據；

將所述結果數據發送至用戶終端。

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

基于統一數據接口、語言轉換模塊、解析執行模塊及創建策略，創建所述執行引擎。