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

在審

• 申請號: 202011566763.4
• 申請日: 2020-12-25
• 公開（公告）號: CN112612588A
• 公開（公告）日: 2021-04-06
• 發明（設計）人: 任亮;傅雨梅;李孟
• 申請（專利權）人: 北京知因智慧科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 北京超凡宏宇專利代理事務所(特殊普通合伙) 11463
• 代理人: 鐘揚飛

本申請實施例提供一種任務處理方法、裝置、設備及存儲介質，所述任務處理方法包括：接收來自用戶端的任務處理請求；根據所述任務處理請求，申請并鎖定對應的目標資源；啟動對應于所述任務處理請求的引擎實例，以使所述引擎實例執行所述任務處理請求中攜帶的任務語句，得到執行結果；將所述執行結果發送至所述用戶端。本申請實現了不同引擎計算任務的統一協調處理，降低開發成本。

技術領域

本申請涉及計算機技術領域，具體而言，涉及一種任務處理方法、裝置、設備及存儲介質。

背景技術

隨著大數據時代的到來，越來越多的企業開始使用并逐漸依賴大數據技術處理相關業務。由于企業業務類型的多樣性和業務流程的復雜性，為了實現各項業務，一般需要在產品服務端運行多種用于存儲的數據庫，以及多種用于執行大數據計算任務的引擎，中間程序流轉需要大量的方法和資源去支撐。在現有技術中，開發人員使用大數據平臺進行產品開發時，一般需要針對不同的數據庫組件和引擎組件進行編程，通過不同腳本實現數據流轉，兼容性差，開發和維護成本高。

發明內容

本申請實施例的目的在于提供一種任務處理方法、裝置、設備及存儲介質，用以實現不同引擎計算任務的統一協調處理，降低開發成本。

本申請實施例第一方面提供了一種任務處理方法，包括：接收來自用戶端的任務處理請求；根據所述任務處理請求，申請并鎖定對應的目標資源；啟動對應于所述任務處理請求的引擎實例，以使所述引擎實例執行所述任務處理請求中攜帶的任務語句，得到執行結果；將所述執行結果發送至所述用戶端。

于一實施例中，所述接收來自用戶端的任務處理請求，包括：通過網關接收所述任務處理請求，所述任務處理請求包括用戶信息；對所述用戶信息進行驗證；根據驗證結果，將所述任務處理請求通過統一入口轉發至引擎管理模塊。

于一實施例中，所述根據所述任務處理請求，申請并鎖定對應的目標資源，包括：判斷所述用戶端是否滿足資源申請條件；當所述用戶端滿足資源申請條件時，申請并鎖定對應于所述任務處理請求的目標資源。

于一實施例中，所述根據所述任務處理請求，申請并鎖定對應的目標資源，還包括：當所述用戶端不滿足資源申請條件時，將所述任務處理請求添加到任務隊列，等待預設時長后，繼續執行判斷所述用戶端是否滿足資源申請條件，直至所述用戶端滿足資源申請條件。

于一實施例中，在啟動對應于所述任務處理請求的引擎實例之后，還包括：對所述引擎實例進行注冊；發送所述引擎實例的執行信息至所述用戶端。

本申請實施例第二方面提供了一種任務處理裝置，包括：接收模塊，用于接收來自用戶端的任務處理請求；申請模塊，用于根據所述任務處理請求，申請并鎖定對應的目標資源；執行模塊，用于啟動對應于所述任務處理請求的引擎實例，以使所述引擎實例執行所述任務處理請求中攜帶的任務語句，得到執行結果；第一發送模塊，用于將所述執行結果發送至所述用戶端。

于一實施例中，所述接收模塊包括：接收單元，用于通過網關接收所述任務處理請求，所述任務處理請求包括用戶信息；驗證單元，用于對所述用戶信息進行驗證；轉發單元，用于根據驗證結果，將所述任務處理請求通過統一入口轉發至引擎管理模塊。

于一實施例中，所述申請模塊具體用于：判斷所述用戶端是否滿足資源申請條件；當所述用戶端滿足資源申請條件時，申請并鎖定對應于所述任務處理請求的目標資源。

于一實施例中，所述申請模塊具體還用于：當所述用戶端不滿足資源申請條件時，將所述任務處理請求添加到任務隊列，等待預設時長后，繼續執行判斷所述用戶端是否滿足資源申請條件，直至所述用戶端滿足資源申請條件。

于一實施例中，還包括：注冊模塊，用于對所述引擎實例進行注冊；第二發送模塊，用于發送所述引擎實例的執行信息至所述用戶端。