[發明專利]數據處理方法及系統

在審

• 申請號: 201911418966.6
• 申請日: 2019-12-31
• 公開（公告）號: CN113127061A
• 公開（公告）日: 2021-07-16
• 發明（設計）人: 劉曉輝;李振博;李欣杰
• 申請（專利權）人: 奇安信科技集團股份有限公司;網神信息技術（北京）股份有限公司
• 主分類號: G06F9/30
• 分類號: G06F9/30;G06F9/48
• 代理公司: 北京英特普羅知識產權代理有限公司 11015
• 代理人: 鄧應山

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

獲取數據處理指令對應的處理工作流，所述處理工作流包括多個工作任務節點，所述工作任務節點包括至少一個數據輸入節點、至少一個數據中間節點和至少一個數據輸出節點；

根據所述處理工作流的所述工作任務節點生成拓撲圖；

獲取待處理數據，基于所述拓撲圖執行所述工作任務節點對應的工作任務，以對所述待處理數據進行處理。

2.根據權利要求1所述的數據處理方法，其特征在于，所述方法還包括：

預設數據處理指令的觸發時間；

在滿足所述觸發時間時觸發所述數據處理指令。

3.根據權利要求2所述的數據處理方法，其特征在于：配置所述數據處理指令與所述處理工作流的映射關系；

對應的，所述獲取數據處理指令對應的處理工作流具體包括：

根據所述映射關系獲取所述數據處理指令對應的處理工作流。

4.根據權利要求1或2所述的數據處理方法，其特征在于，所述數據處理方法還包括：

接收新的數據處理指令；

獲取所述新的數據處理指令的新處理工作流；

對比所述新處理工作流的工作任務節點與所述處理工作流的所述工作任務節點，以對所述拓撲圖進行第一更新，生成新的拓撲圖。

5.根據權利要求4所述的數據處理方法，其特征在于，所述對比新處理工作流與所述處理工作流的所述工作任務節點，以對所述拓撲圖進行第一更新，生成新的拓撲圖包括：

根據所述新處理工作流的工作任務節點與所述處理工作流的所述工作任務節點，確定所述拓撲圖中待處理的目標工作任務節點；

通過所述新處理工作流對所述目標工作任務節點進行修改操作，確定所述目標工作任務節點之間的連接關系，以生成新的拓撲圖。

6.根據權利要求5所述的數據處理方法，其特征在于，所述獲取待處理數據，基于所述拓撲圖執行所述工作任務節點對應的工作任務，以對所述待處理數據進行處理包括：

接收所述工作任務節點在執行對應的工作任務過程中產生的業務數據；

根據所述業務數據，獲取所述工作任務節點的執行狀態；

根據所述工作任務節點的執行狀態對所述拓撲圖進行第二更新。

7.根據權利要求1所述的數據處理方法，其特征在于，所述根據所述處理工作流的所述工作任務節點生成拓撲圖包括：

基于所述工作任務節點之間的數據處理邏輯關系生成所述拓撲圖；

將所述拓撲圖展示在工作任務節點管理界面上。

8.一種數據處理系統，其特征在于，包括：

工作流獲取模塊，用于獲取數據處理指令對應的處理工作流，所述處理工作流包括多個工作任務節點，所述工作任務節點至少一個數據輸入節點、至少一個數據中間節點和至少一個數據輸出節點；

拓撲圖生成模塊，用于根據所述處理工作流的所述工作任務節點生成拓撲圖；

工作任務節點執行模塊，用于獲取待處理數據，基于所述拓撲圖執行所述工作任務節點對應的工作任務，以對所述待處理數據進行處理。

9.一種計算機設備，所述計算機設備包括存儲器、處理器以及存儲在所述存儲器上并可在所述處理器上運行的計算機程序，其特征在于，所述處理器執行所述計算機程序時實現如權利要求1至7任一項所述的數據處理方法的步驟。

10.一種計算機可讀存儲介質，其特征在于，所述計算機可讀存儲介質內存儲有計算機程序，所述計算機程序可被至少一個處理器所執行，以使所述至少一個處理器執行如權利要求1至7中任一項所述的數據處理方法的步驟。