[發明專利]一種數據處理系統、方法及存儲介質

有效

• 申請號: 201911189231.0
• 申請日: 2019-11-28
• 公開（公告）號: CN111078770B
• 公開（公告）日: 2023-07-21
• 發明（設計）人: 王路;郭慶;謝瑩瑩;于宏亮
• 申請（專利權）人: 曙光信息產業股份有限公司;曙光信息產業江蘇有限公司
• 主分類號: G06F16/25
• 分類號: G06F16/25;H04L69/08;H04L67/12
• 代理公司: 北京超凡宏宇專利代理事務所(特殊普通合伙) 11463
• 代理人: 胡蓉

1.一種數據處理系統，其特征在于，第一平臺經所述系統向第二平臺發送一種數據流的數據，所述系統包括：處理調度模塊、以及多個處理模塊；

所述處理調度模塊用于從所述多個處理模塊確定出匹配所述數據的處理流程的處理模塊，其中，確定出的處理模塊中的每個處理模塊用于執行所述處理流程中對應的一個最小處理動作；

所述處理調度模塊還用于將所述確定出的處理模塊按所述處理流程中所有最小處理動作的先后順序連接；

所述系統還包括：

處理控制模塊，所述處理控制模塊與所述每個處理模塊連接；所述處理控制模塊，用于根據所述處理流程，依次判斷所述每個處理模塊對所述數據對應執行的一個最小處理動作是否執行成功，若否，調整所述每個處理模塊的配置，直至所述每個處理模塊對所述數據成功執行該處理模塊對應執行的一個最小處理動作。

2.根據權利要求1所述的數據處理系統，其特征在于，

所述處理調度模塊用于通過解析所述處理流程而確定出構成所述處理流程的最小處理動作，從所述多個處理模塊中確定出執行構成所述處理流程的最小處理動作的處理模塊。

3.根據權利要求1所述的數據處理系統，其特征在于，

所述處理調度模塊用于響應用戶針對所述處理流程執行的處理模塊選擇操作，從所述多個處理模塊中確定出匹配所述處理流程的處理模塊。

4.根據權利要求1所述的數據處理系統，其特征在于，

在按所述先后順序連接后，所述確定出的處理模塊用于對所述數據依次執行所述處理流程中的所有最小處理動作，以將所述數據的格式轉換成所述第二平臺所需格式，并將處理后的數據發送到所述第二平臺。

5.根據權利要求4所述的數據處理系統，其特征在于，針對所述每個處理模塊，該處理模塊包括：存儲單元和處理單元；

所述存儲單元用于存儲該處理模塊執行所述處理流程中對應的一個最小處理動作所需的配置程序；

在按所述先后順序連接后，所述處理單元用于調用并運行所述配置程序，以對所述數據執行所述對應的一個最小處理動作。

6.根據權利要求5所述的數據處理系統，其特征在于，

所述處理單元還用于調用并運行所述配置程序，以將所述數據中的屬性修改為所述對應的一個最小處理動作對應的屬性。

7.根據權利要求4所述的數據處理系統，其特征在于，針對所述每個處理模塊，該處理模塊還包括：

執行單元，所述執行單元預設了所述對應的一個最小處理動作的執行時間；

在按所述先后順序連接后，所述執行單元用于確定當前時間為所述執行時間，并觸發所述處理單元對所述數據執行所述對應的一個最小處理動作。

8.根據權利要求1所述的數據處理系統，其特征在于，所述系統還包括：緩存模塊；

所述處理調度模塊，還用于根據所述處理流程，將所述緩存模塊與所述確定出的處理模塊中相鄰的兩個處理模塊連接；所述緩存模塊用于將所述相鄰的兩個處理模塊中上一個處理模塊輸出的所述數據按預設的輸入輸出順序緩存，以使所述相鄰的兩個處理模塊中下一個處理模塊按所述輸入輸出順序從所述緩存模塊獲取的所述數據；或者

所述處理調度模塊，還用于根據所述處理流程，將所述緩存模塊與所述第一平臺以及所述確定出的處理模塊中與所述第一平臺相鄰的一個處理模塊連接；所述緩存模塊用于將所述第一平臺輸出的所述數據按所述輸入輸出順序緩存，以使所述與所述第一平臺相鄰的一個處理模塊按所述輸入輸出順序從所述緩存模塊獲取的所述數據；或者

所述處理調度模塊，還用于根據所述處理流程，將所述緩存模塊與所述第二平臺以及所述確定出的處理模塊中與所述第二平臺相鄰的一個處理模塊連接；所述緩存模塊用于將所述與所述第二平臺相鄰的一個處理模塊輸出的所述數據按所述輸入輸出順序緩存，以使所述第二平臺按所述輸入輸出順序從所述緩存模塊獲取的所述數據。