[發明專利]數據處理方法、裝置、調度服務器及介質

在審

• 申請號: 202010161333.8
• 申請日: 2020-03-10
• 公開（公告）號: CN111459659A
• 公開（公告）日: 2020-07-28
• 發明（設計）人: 蔡高年
• 申請（專利權）人: 中國平安人壽保險股份有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F9/48
• 代理公司: 廣州三環專利商標代理有限公司 44202
• 代理人: 熊永強;彭程

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

接收終端發送的待處理任務；

若所述待處理任務滿足預設拆分條件，則根據目標拆分策略對所述待處理任務進行拆分處理，得到至少一個子任務，所述目標拆分策略用于確定針對所述待處理任務的目標拆分節點以及拆分處理得到的每個子任務與用于任務處理的執行服務器之間的對應關系；

為所述每個子任務添加標識，并將添加標識后的所述每個子任務發送至對應的執行服務器，以使得所述每個子任務對應的執行服務器對所述各個子任務進行處理；

接收所述每個子任務對應的執行服務器返回的處理結果，所述每個子任務對應的執行服務器返回的處理結果中含有所述標識；

根據所述標識對所述每個子任務對應的執行服務器返回的處理結果進行合并處理，得到針對所述待處理任務的目標處理結果。

2.根據權利要求1所述的方法，其特征在于，所述接收終端發送的待處理任務之后，所述方法還包括：

獲取所述待處理任務中的可拆分節點以及用于任務處理的執行服務器的信息，所述信息包括數量和剩余負載量，所述可拆分節點包括所述待處理任務中不同處理模塊之間的連接點；

根據所述可拆分節點和所述執行服務器的信息確定所述目標拆分策略。

3.根據權利要求2所述的方法，其特征在于，所述可拆分節點的數量為K，所述用于任務處理的執行服務器的數量為M，所述K和M為正整數，所述根據所述可拆分節點和所述執行服務器的信息確定所述目標拆分策略，包括：

若所述執行服務器的數量M大于或等于所述可拆分節點的數量K，則將所述K個可拆分節點確定為針對所述待處理任務的目標拆分節點，所述K個可拆分節點用于將所述待處理任務拆分為K個子任務；

從所述M個執行服務器中選取出剩余負載量最大的K個執行服務器作為目標執行服務器；

根據任務量與剩余負載量匹配的原則建立所述K個子任務與所述K個目標執行服務器之間的對應關系。

4.根據權利要求3所述的方法，其特征在于，所述根據任務量與剩余負載量匹配的原則建立所述K個子任務與所述K個目標執行服務器之間的對應關系，包括：

獲取所述K個子任務中每個子任務的任務量以及所述K個目標執行服務器中每個執行服務器的剩余負載量；

按照任務量由大到小順序對所述K個子任務進行排序，得到第一序列集；

按照剩余負載量由大到小順序對所述K個目標執行服務器進行排序，得到第二序列集；

將所述第一序列集中排序為第I位的子任務與所述第二序列集中排序為第I位的執行服務器相對應，所述I為正整數。

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

若所述執行服務器的數量M小于所述可拆分節點的數量K，則從所述K個可拆分節點中選取M個可拆分節點作為目標拆分節點，所述M個可拆分節點用于將所述待處理任務拆分為M個子任務；

確定所述M個可拆分節點中每個可拆分節點對應的子任務的任務量以及所述M個執行服務器中每個執行服務器的剩余負載量；

根據任務量與剩余負載量匹配的原則建立所述M個子任務與所述M個執行服務器之間的對應關系。

6.根據權利要求1所述的方法，其特征在于，所述接收所述每個子任務對應的執行服務器返回的處理結果之前，所述方法還包括：

監控目標執行服務器對目標子任務的處理狀態，所述目標子任務為所述至少一個子任務中的任意一個，所述目標執行服務器為所述目標子任務對應的執行服務器，所述目標子任務中存在可拆分節點，所述可拆分節點用于將所述目標子任務拆分為第一目標子任務和第二目標子任務；

若檢測到所述目標子任務的處理狀態滿足二次拆分條件，則對所述目標子任務進行二次拆分處理，得到第一子目標任務和第二目標子任務，所述二次拆分條件包括所述目標服務器對于所述目標子任務中的第二目標子任務的處理狀態為未處理，且當前存在空閑執行服務器；

向所述目標執行服務器發送暫停處理所述目標子任務中的第二目標子任務的指令，并向所述空閑執行服務器發送所述第二目標子任務，以使得所述空閑執行服務器對所述第二目標子任務進行處理。