[發明專利]任務處理方法、裝置、設備及存儲介質

在審

• 申請號: 202011048304.7
• 申請日: 2020-09-29
• 公開（公告）號: CN112231098A
• 公開（公告）日: 2021-01-15
• 發明（設計）人: 趙澤恩;李汶昊
• 申請（專利權）人: 北京三快在線科技有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 北京三高永信知識產權代理有限責任公司 11138
• 代理人: 唐述燦

本申請公開了一種任務處理方法、裝置、設備及存儲介質，應用于包括多個任務處理節點的任務處理集群中，所述方法應用于所述任務處理集群中的第一任務處理節點，屬于互聯網技術領域。所述方法包括：獲取待處理的第一任務；基于任務鏈確定第一任務的關聯任務；響應于關聯任務處理完成，生成多個第一任務分片；向任務處理集群中的目標任務處理節點發送第一任務分片。本申請提供的方案，避免相關技術中定時處理待處理任務的局限性，使得待處理任務的處理條件設置更加靈活；且任務處理集群中的各個任務處理節點相同，不需要配置額外的節點向任務處理節點發送任務分片，由任務處理節點向其它任務處理節點發送任務分片，減少多余節點的設置開銷。

技術領域

本申請涉及互聯網技術領域，特別涉及一種任務處理方法、裝置、設備及存儲介質。

背景技術

目前，業務系統中往往包含各種處理數據和計算規模都很大的任務。在相關技術中，針對大規模的任務，可以采用分布式的任務處理節點對該大規模的任務(如訂單數據統計任務)進行處理。

發明內容

本申請實施例提供了一種任務處理方法、裝置、設備及存儲介質，能夠使得待處理任務的處理條件設置更加靈活。所述技術方案如下：

根據本申請實施例的一個方面，提供了一種任務處理方法，應用于包括多個任務處理節點的任務處理集群中，所述方法應用于所述任務處理集群中的第一任務處理節點，所述方法包括：

獲取待處理的第一任務；

基于任務鏈確定所述第一任務的關聯任務，所述任務鏈用于描述不同任務之間的依賴關系，所述關聯任務包括所述第一任務所依賴的任務；

響應于所述關聯任務處理完成，生成多個第一任務分片，所述第一任務分片是對所述第一任務進行劃分得到的；

向所述任務處理集群中的目標任務處理節點發送所述第一任務分片。

根據本申請實施例的一個方面，提供了一種任務處理裝置，應用于包括多個任務處理節點的任務處理集群中，所述裝置應用于所述任務處理集群中的第一任務處理節點，所述裝置包括：

任務獲取模塊，用于獲取待處理的第一任務；

任務確定模塊，用于基于任務鏈確定所述第一任務的關聯任務，所述任務鏈用于描述不同任務之間的依賴關系，所述關聯任務包括所述第一任務所依賴的任務；

分片生成模塊，用于響應于所述關聯任務處理完成，生成多個第一任務分片，所述第一任務分片是對所述第一任務進行劃分得到的；

分片發送模塊，用于向所述任務處理集群中的目標任務處理節點發送所述第一任務分片。

根據本申請實施例的一個方面，提供了一種計算機設備，所述計算機設備包括處理器和存儲器，所述存儲器中存儲有計算機程序，所述計算機程序由所述處理器加載并執行以實現上述任務處理方法。

根據本申請實施例的一個方面，提供了一種非臨時性計算機可讀存儲介質，其上存儲有計算機程序，所述計算機程序被處理器執行時實現上述任務處理方法。

根據本申請實施例的一個方面，提供了一種計算機程序產品，當所述計算機程序產品運行時，使得計算機設備執行上述任務處理方法。

本申請實施例提供的技術方案可以帶來如下有益效果：