[發明專利]批量數據處理方法、裝置、系統、計算機設備及計算機可讀存儲介質

在審

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

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

接收外部數據源發送的第一數據；

獲取預先被標記為生效狀態的調度節點作為第一類調度節點；

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

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

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

將取得所述互斥鎖的調度節點標記為處于生效狀態的調度節點。

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

接收所述第一類調度節點按照第一預設周期發送的節點狀態，所述節點狀態包括所述第一類調度節點的繁忙程度信息；

所述按照第一預設發送方式發送所述第一數據至所述第一類調度節點的步驟包括：

判斷所述第一類調度節點所被調度的所述調度節點的數量；

若所述第一類調度節點所被調度的所述調度節點為一個，根據所述節點狀態，按照第二預設發送方式發送所述第一數據至所述第一類調度節點所被調度的所述調度節點；

若所述第一類調度節點所被調度的所述調度節點為兩個或者兩個以上，在第三預設發送方式的基礎上，根據每個所述節點狀態，按照所述第二預設發送方式將所述第一數據發送至所述第一類調度節點所被調度的每個所述調度節點。

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

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

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

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

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

若取得所述互斥鎖，接收所述調度控制中心發送的第二數據；

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

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

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

根據所述修改指令，對所調度的所述處理節點進行修改。

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

8.一種批量數據處理系統，其特征在于，所述系統包括調度控制中心，所述調度控制中心控制若干個調度節點，每個所述調度節點調度若干個處理節點；

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