[發(fā)明專利]批量數(shù)據(jù)處理方法、裝置、系統(tǒng)、計算機設備及計算機可讀存儲介質

在審

• 申請?zhí)枺?/td>: 202010123547.6
• 申請日: 2020-02-27
• 公開（公告）號: CN111414241A
• 公開（公告）日: 2020-07-14
• 發(fā)明（設計）人: 陳其強
• 申請（專利權）人: 平安銀行股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50;G06F9/52
• 代理公司: 深圳市精英專利事務所 44242
• 代理人: 武志峰

1.一種批量數(shù)據(jù)處理方法，其特征在于，所述方法應用于調度控制中心，所述調度控制中心控制若干個調度節(jié)點，每個所述調度節(jié)點調度若干個處理節(jié)點，所述方法包括：

接收外部數(shù)據(jù)源發(fā)送的第一數(shù)據(jù)；

獲取預先被標記為生效狀態(tài)的調度節(jié)點作為第一類調度節(jié)點；

按照第一預設發(fā)送方式發(fā)送所述第一數(shù)據(jù)至所述第一類調度節(jié)點，以使所述第一類調度節(jié)點按照第一預設分配算法分配所述第一數(shù)據(jù)至自身所調度的處理節(jié)點，以使所述處理節(jié)點根據(jù)所述第一數(shù)據(jù)所對應的第一預設處理方式對所述第一數(shù)據(jù)進行處理。

2.根據(jù)權利要求1所述批量數(shù)據(jù)處理方法，其特征在于，所述獲取預先被標記為生效狀態(tài)的調度節(jié)點作為第一類調度節(jié)點的步驟之前，還包括：

接收所述調度節(jié)點對互斥鎖的訪問請求，所述互斥鎖用于保證在同一時間只有一個所述調度節(jié)點處于生效狀態(tài)；

將取得所述互斥鎖的調度節(jié)點標記為處于生效狀態(tài)的調度節(jié)點。

3.根據(jù)權利要求1或者2所述批量數(shù)據(jù)處理方法，其特征在于，所述按照第一預設發(fā)送方式發(fā)送所述第一數(shù)據(jù)至所述第一類調度節(jié)點的步驟之前，還包括：

接收所述第一類調度節(jié)點按照第一預設周期發(fā)送的節(jié)點狀態(tài)，所述節(jié)點狀態(tài)包括所述第一類調度節(jié)點的繁忙程度信息；

所述按照第一預設發(fā)送方式發(fā)送所述第一數(shù)據(jù)至所述第一類調度節(jié)點的步驟包括：

判斷所述第一類調度節(jié)點所被調度的所述調度節(jié)點的數(shù)量；

若所述第一類調度節(jié)點所被調度的所述調度節(jié)點為一個，根據(jù)所述節(jié)點狀態(tài)，按照第二預設發(fā)送方式發(fā)送所述第一數(shù)據(jù)至所述第一類調度節(jié)點所被調度的所述調度節(jié)點；

若所述第一類調度節(jié)點所被調度的所述調度節(jié)點為兩個或者兩個以上，在第三預設發(fā)送方式的基礎上，根據(jù)每個所述節(jié)點狀態(tài)，按照所述第二預設發(fā)送方式將所述第一數(shù)據(jù)發(fā)送至所述第一類調度節(jié)點所被調度的每個所述調度節(jié)點。

4.根據(jù)權利要求2所述批量數(shù)據(jù)處理方法，其特征在于，所述接收所述調度節(jié)點對互斥鎖的訪問請求的步驟包括：

接收所述調度節(jié)點按照預設周期對互斥鎖的訪問請求。

5.一種批量數(shù)據(jù)處理方法，其特征在于，所述方法應用于調度節(jié)點，所述調度節(jié)點受控于調度控制中心，所述調度控制中心控制若干個調度節(jié)點，每個所述調度節(jié)點調度若干個處理節(jié)點，所述方法包括：

發(fā)送訪問請求至所述調度控制中心所包含的互斥鎖，所述互斥鎖用于保證在同一時間只有一個所述調度節(jié)點處于生效狀態(tài)；

判斷是否取得所述互斥鎖；

若取得所述互斥鎖，接收所述調度控制中心發(fā)送的第二數(shù)據(jù)；

按照第二預設分配算法分配所述第二數(shù)據(jù)至自身所調度的處理節(jié)點，以使所述處理節(jié)點根據(jù)所述第二數(shù)據(jù)所對應的第二預設處理方式對所述第二數(shù)據(jù)進行處理。

6.根據(jù)權利要求5所述批量數(shù)據(jù)處理方法，其特征在于，所述按照第二預設分配算法分配所述第二數(shù)據(jù)至自身所調度的處理節(jié)點的步驟之前，還包括：

接收對所調度的處理節(jié)點的修改指令，所述修改指令包括刪除處理節(jié)點、添加處理節(jié)點及更改處理節(jié)點的狀態(tài)；

根據(jù)所述修改指令，對所調度的所述處理節(jié)點進行修改。

7.一種批量數(shù)據(jù)處理裝置，其特征在于，包括用于執(zhí)行如權利要求1-4任一項所述方法的單元，或者是包括用于執(zhí)行如權利要求5-6任一項所述方法的單元。

8.一種批量數(shù)據(jù)處理系統(tǒng)，其特征在于，所述系統(tǒng)包括調度控制中心，所述調度控制中心控制若干個調度節(jié)點，每個所述調度節(jié)點調度若干個處理節(jié)點；

其中，所述調度控制中心用于執(zhí)行如權利要求1-4任一項所述方法的步驟，所述調度節(jié)點用于執(zhí)行如權利要求5-6任一項所述方法的步驟，所述處理節(jié)點用于執(zhí)行根據(jù)所接收到的分配數(shù)據(jù)所對應的預設處理方式對所述分配數(shù)據(jù)進行處理的步驟。