[發(fā)明專利]一種數(shù)據(jù)的處理方法、裝置及電子設備

有效

• 申請?zhí)枺?/td>: 201911372918.8
• 申請日: 2019-12-27
• 公開（公告）號: CN113051103B
• 公開（公告）日: 2023-09-05
• 發(fā)明（設計）人: 宋迎春
• 申請（專利權(quán)）人: 中國移動通信集團湖南有限公司;中國移動通信集團有限公司
• 主分類號: G06F11/14
• 分類號: G06F11/14
• 代理公司: 北京國昊天誠知識產(chǎn)權(quán)代理有限公司 11315
• 代理人: 朱文杰

本發(fā)明實施例提供了一種數(shù)據(jù)的處理方法、裝置及電子設備，所述方法應用于目標數(shù)據(jù)處理節(jié)點，所述方法包括：在接收到分布式協(xié)調(diào)服務器發(fā)送的數(shù)據(jù)處理節(jié)點的節(jié)點變化信息的情況下，基于所述節(jié)點變化信息，對待處理的目標數(shù)據(jù)進行分片處理，得到第一分片結(jié)果，所述第一數(shù)據(jù)處理節(jié)點與所述目標數(shù)據(jù)處理節(jié)點不同，接收所述第一數(shù)據(jù)處理節(jié)點發(fā)送的第二分片結(jié)果，所述第二分片結(jié)果為所述第一數(shù)據(jù)處理節(jié)點基于所述節(jié)點變化信息，對所述目標數(shù)據(jù)進行分片處理的結(jié)果，在所述第一分片結(jié)果與所述第二分片結(jié)果相匹配的情況下，對所述第一數(shù)據(jù)進行處理。通過本方法，可以避免對目標數(shù)據(jù)的重復處理或遺漏處理，提高數(shù)據(jù)處理的效率。

技術領域

本發(fā)明涉及計算機技術領域，尤其涉及一種數(shù)據(jù)的處理方法、裝置及電子設備。

背景技術

隨著移動通信技術的不斷發(fā)展，移動通信業(yè)務量日益劇增，為保證業(yè)務處理的效率，運營商通常采用異步調(diào)度機制來進行業(yè)務的處理，即通過分布式協(xié)調(diào)服務器對待處理的數(shù)據(jù)進行分配調(diào)度。

目前，在通過分布式協(xié)調(diào)服務器進行分配調(diào)度時，可以采用熱備份機制，保證數(shù)據(jù)處理的持續(xù)性。例如，可以基于分布式協(xié)調(diào)服務器，將待處理的業(yè)務數(shù)據(jù)，發(fā)送至多個主設備進行處理，同時，針對每一個主設備，還可以有一個備份設備，在主設備發(fā)生故障時，分布式協(xié)調(diào)服務器可以啟動備份設備替代主設備進行數(shù)據(jù)的處理。

但是，通過上述熱備份機制對業(yè)務數(shù)據(jù)進行處理時，存在以下問題：由于每一個主設備都需要配置一個備份設備，所以存在較大的資源浪費問題，其次，如果主設備與分布式協(xié)調(diào)服務器之間信號發(fā)生斷連，分布式協(xié)調(diào)服務器可以啟動備份設備繼續(xù)對數(shù)據(jù)進行處理，但是主設備此時可能并未發(fā)生故障，仍在繼續(xù)對數(shù)據(jù)進行處理，所以采用熱備份機制對業(yè)務數(shù)據(jù)進行處理時，存在數(shù)據(jù)重復處理的風險高、數(shù)據(jù)處理效率低的問題。

發(fā)明內(nèi)容

本發(fā)明實施例的目的是提供一種數(shù)據(jù)的處理方法、裝置及電子設備，以解決現(xiàn)有技術中采用熱備份機制對業(yè)務數(shù)據(jù)進行處理時，存在數(shù)據(jù)重復處理的風險高，數(shù)據(jù)處理效率低的問題。

為解決上述技術問題，本發(fā)明實施例是這樣實現(xiàn)的：

第一方面，本發(fā)明實施例提供的一種數(shù)據(jù)的處理方法，所述方法應用于目標數(shù)據(jù)處理節(jié)點，所述方法包括：

在接收到分布式協(xié)調(diào)服務器發(fā)送的數(shù)據(jù)處理節(jié)點的節(jié)點變化信息的情況下，基于所述節(jié)點變化信息，對待處理的目標數(shù)據(jù)進行分片處理，得到第一分片結(jié)果，所述第一分片結(jié)果包括本地待處理的第一數(shù)據(jù)，以及第一數(shù)據(jù)處理節(jié)點待處理的第二數(shù)據(jù)，所述第一數(shù)據(jù)處理節(jié)點與所述目標數(shù)據(jù)處理節(jié)點不同；

接收所述第一數(shù)據(jù)處理節(jié)點發(fā)送的第二分片結(jié)果，所述第二分片結(jié)果為所述第一數(shù)據(jù)處理節(jié)點基于所述節(jié)點變化信息，對所述目標數(shù)據(jù)進行分片處理的結(jié)果，所述第二分片結(jié)果包括所述第一數(shù)據(jù)處理節(jié)點待處理的第三數(shù)據(jù)，以及所述目標數(shù)據(jù)處理節(jié)點待處理的第四數(shù)據(jù)；

在所述第一分片結(jié)果與所述第二分片結(jié)果相匹配的情況下，對所述第一數(shù)據(jù)進行處理。

可選地，所述基于所述節(jié)點變化信息，對待處理的目標數(shù)據(jù)進行分片處理，得到第一分片結(jié)果，包括：

基于所述節(jié)點變化信息，確定當前用于處理所述目標數(shù)據(jù)的第二數(shù)據(jù)處理節(jié)點；

將所述第二數(shù)據(jù)處理節(jié)點中，除所述目標數(shù)據(jù)處理節(jié)點外的數(shù)據(jù)處理節(jié)點，確定為所述第一數(shù)據(jù)處理節(jié)點；

確定所述目標數(shù)據(jù)處理節(jié)點在所述第二數(shù)據(jù)處理節(jié)點中的第一位置信息，以及所述第一數(shù)據(jù)處理節(jié)點在所述第二數(shù)據(jù)處理節(jié)點中的第二位置信息；

基于所述第一位置信息，以及所述第二位置信息，對所述待處理的目標數(shù)據(jù)進行分片處理，得到所述第一分片結(jié)果。

可選地，所述在所述第一分片結(jié)果與所述第二分片結(jié)果相匹配的情況下，對所述第一數(shù)據(jù)進行處理，包括：