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

在審

• 申請號: 202010621795.3
• 申請日: 2020-06-30
• 公開（公告）號: CN111737005A
• 公開（公告）日: 2020-10-02
• 發明（設計）人: 賴臣天;楊松青;尹釧
• 申請（專利權）人: 中國平安財產保險股份有限公司
• 主分類號: G06F9/50
• 分類號: G06F9/50;G06F9/48
• 代理公司: 深圳市明日今典知識產權代理事務所(普通合伙) 44343
• 代理人: 王杰輝

本申請涉及分布式部署領域，提供任務處理方法、裝置、計算機設備和存儲介質，包括：獲取新增任務的目標任務類型；獲取當前處理目標任務類型的任務的主機數量，并判斷是否達到預設的第一閾值；若達到，則獲取當前每臺主機的第一CPU使用率和第一內存使用率，以及獲取當前處理其他每一種任務類型的任務的第一平均處理時長，并判斷每臺主機的第一CPU使用率以及第一內存使用率是否均小于對應的閾值；若均小于，則依次調大所述第一閾值，以使得當前處理所述目標任務類型的任務的主機數量小于調大后的所述第一閾值，并將所述新增任務分配至一臺所述主機進行處理。本申請在對新增任務進行處理時，無需手動去配置也可以讓服務器主動調整任務處理能力。

技術領域

本申請涉及分布式部署的技術領域，特別涉及一種任務處理方法、裝置、計算機設備和存儲介質。

背景技術

目前，在任務平臺中，為了保障對任務的處理能力不受影響，通常需要在任務處理時進行限流，即限制同時處理任務的數量。現行的限流方案通常是通過信號量和線程池的方式對提供的服務和對外調用進行限流操作，而這些方案中通常是對單臺主機進行配置和限流，缺少一個動態的分布式的動態限流方案。同時，在新增任務時，無法在保障其他任務的正常處理前提下，及時將新增任務分配處理。

發明內容

本申請的主要目的為提供一種任務處理方法、裝置、計算機設備和存儲介質，旨在克服目前任務處理時無法動態限流的缺陷。

為實現上述目的，本申請提供了一種任務處理方法，包括以下步驟：

獲取新增任務的目標任務類型；

獲取當前處理所述目標任務類型的任務的主機數量，并判斷所述主機數量是否達到預設的第一閾值；

若達到，則獲取當前每臺主機的第一CPU使用率和第一內存使用率，以及獲取當前處理其他每一種任務類型的任務的第一平均處理時長，并判斷每臺所述主機的第一CPU使用率以及第一內存使用率是否均小于對應的閾值；

若均小于對應的閾值，則依次調大所述第一閾值，以使得當前處理所述目標任務類型的任務的主機數量小于調大后的所述第一閾值，并將所述新增任務分配至一臺所述主機進行處理；

再次獲取每臺所述主機的第二CPU使用率和第二內存使用率，以及再次獲取處理其他每一種任務類型的任務的第二平均處理時長；

若任一臺所述主機的第二CPU使用率或者第二內存使用率達到對應的閾值，或者其他任一種任務類型的任務的第二平均處理時長大于第一平均處理時長時，停止調大所述第一閾值。

進一步地，所述獲取新增任務的目標任務類型的步驟，包括：

獲取所述新增任務的屬性表達式，根據所述屬性表達式獲取所述新增任務的的屬性編碼，所述屬性編碼包括任務部門編碼、任務處理事項編碼、任務重要度編碼以及任務處理時間編碼；

將所述任務部門編碼、任務處理事項編碼、任務重要度編碼以及任務處理時間編碼分別輸入至映射腳本中，輸出所述任務部門編碼、任務處理事項編碼、任務重要度編碼、任務處理時間編碼分別對應的第一打分、第二打分、第三打分以及第四打分；其中，所述映射腳本中存儲有屬性編碼-打分的對應關系；

對所述第一打分、第二打分、第三打分以及第四打分進行加權求和計算，得到所述新增任務的總分值；

根據總分值與目標任務類型的映射關系，得到所述新增任務的目標任務類型。

進一步地，所述獲取新增任務的目標任務類型的步驟之后，包括：

獲取所述新增任務的數據量，并將所述數據量與預設數據量進行對比；

若所述新增任務的數據量小于預設數據量，則將所述新增任務存儲至第一文件夾中；若所述新增任務的數據量不小于預設數據量，則將所述新增任務存儲至第二文件夾中；