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

在審

• 申請號: 202010711615.0
• 申請日: 2020-07-22
• 公開（公告）號: CN111857804A
• 公開（公告）日: 2020-10-30
• 發明（設計）人: 栗垚;朱方興
• 申請（專利權）人: 北京達佳互聯信息技術有限公司
• 主分類號: G06F8/71
• 分類號: G06F8/71
• 代理公司: 廣州華進聯合專利商標代理有限公司 44224
• 代理人: 方高明

1.一種離線任務的處理方法，其特征在于，所述方法包括：

獲取目標業務，所述目標業務包括對應的任務需求和配置參數；

根據所述任務需求，從預設的離線任務集中獲取與所述任務需求對應的至少一個離線任務；其中，所述離線任務的類型包括可調用離線任務和可配置離線任務，所述可調用離線任務為預先配置完成的離線任務，所述可配置離線任務為需要進行配置的離線任務；

根據所述配置參數，對所述至少一個離線任務進行配置，生成離線任務消息；

通過所述離線任務對應的應用程序接口發送所述離線任務消息。

2.根據權利要求1所述的方法，其特征在于，所述可調用離線任務的確定方式包括：

獲取預設需求；

按照預設需求配置任務，得到所述可調用離線任務；

為所述可調用離線任務設置對應的根節點，按照所述根節點設置所述可調用離線任務。

3.根據權利要求2所述的方法，其特征在于，所述為所述可調用離線任務設置對應的根節點，按照所述根節點設置所述可調用離線任務，包括：

若需上線新的可調用離線任務，則對所述可配置離線任務進行配置，并對應增加新的根節點，按照所述新的根節點設置配置后的可配置離線任務，得到新的可調用離線任務；

若需下線所述可調用離線任務，則下線對應的根節點，以下線所述可調用離線任務。

4.根據權利要求1所述的方法，其特征在于，所述目標業務對應的任務需求存儲于配置中心，所述目標業務對應的配置參數存儲于Hive集群。

5.根據權利要求1所述的方法，其特征在于，所述可調用離線任務至少包括私信任務、第一資源分配任務、第二資源分配任務，所述私信任務對應的應用程序接口為私信服務接口，第一資源分配任務對應的應用程序接口為第一資源分配服務接口，第二資源分配任務對應的應用程序接口為第二資源分配服務接口。

6.根據權利要求1所述的方法，其特征在于，所述配置參數中包括執行所述至少一個離線任務的任務標識、所述至少一個離線任務的執行順序和所述至少一個離線任務對應的任務配置參數；

所述根據所述配置參數，對所述至少一個離線任務進行配置，生成離線任務消息，包括：

按照所述任務配置參數，對相應的離線任務進行配置，得到對應的離線任務數據流；其中，所述離線任務數據流包括預設的Hive數據和所述離線任務的前置任務的配置結果；

按照所述執行順序和每一離線任務對應的任務標識，調用所述離線任務和對應的離線任務數據流，并生成所述離線任務消息。

7.根據權利要求6所述的方法，其特征在于，所述執行順序對應的首個離線任務為Hive讀取任務，所述Hive讀取任務用于生成初始離線任務數據流。

8.一種離線任務的處理裝置，其特征在于，所述裝置包括：

目標業務獲取單元，被配置為執行獲取目標業務，所述目標業務包括對應的任務需求和配置參數；

離線任務確定單元，被配置為執行根據所述任務需求，從預設的離線任務集中獲取與所述任務需求對應的至少一個離線任務；其中，所述離線任務的類型包括可調用離線任務和可配置離線任務，所述可調用離線任務為預先配置完成的離線任務，所述可配置離線任務為需要進行配置的離線任務；

離線任務配置單元，被配置為執行根據所述配置參數，對所述至少一個離線任務進行配置，生成離線任務消息；

離線任務發送單元，被配置為執行通過所述離線任務對應的應用程序接口發送所述離線任務消息。

9.一種電子設備，其特征在于，包括：

處理器；

用于存儲所述處理器可執行指令的存儲器；

其中，所述處理器被配置為執行所述指令，以實現如權利要求1至7中任一項所述的離線任務的處理方法。

10.一種存儲介質，當所述存儲介質中的指令由電子設備的處理器執行時，使得所述電子設備能夠執行如權利要求1至7中任一項所述的離線任務的處理方法。