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

在審

• 申請號: 202110752934.0
• 申請日: 2021-07-02
• 公開（公告）號: CN113485806A
• 公開（公告）日: 2021-10-08
• 發明（設計）人: 唐成山;卞嘉駿;陳軍;趙立才
• 申請（專利權）人: 中國建設銀行股份有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 中原信達知識產權代理有限責任公司 11219
• 代理人: 郭晗;趙迪

本發明公開了處理任務的方法、裝置、設備和計算機可讀介質，涉及自動程序設計技術領域。該方法的一具體實施方式包括：按照主任務的處理狀態，定時篩選出滿足子任務分片的主任務；依據所述主任務的類型，將所述主任務拆分為一個或多個子任務，并將所述子任務的信息存在子任務信息表中；在所述子任務信息表中，通過主任務下屬子任務的執行狀態，周期性確定發送至分布式集群的子任務；在分布式集群中，執行所述發送至分布式集群的子任務。該實施方式能夠在子任務的處理過程中，動態獲知其他實例機器當前資源處理能力，提高資源使用效率。

技術領域

本發明涉及自動程序設計技術領域，尤其涉及一種處理任務的方法、裝置、設備和計算機可讀介質。

背景技術

全球IT市場正在發生巨大的變化，云計算、大數據、物聯網和人工智能等新技術正在改寫游戲規則。主機一直以其高可用性、高吞吐率而備受大型銀行的青睞，但主機設備依賴單一，不利于自主可用，核心業務量快速增長，主機面臨著日益嚴峻的挑戰。

隨著分布式架構的崛起，銀行都在積極探索主機下移的解決方案，可以通過適用于分布式架構的批處理框架，來支持原先主機的批處理功能。基于高頻框架建立子任務分片處理機制，提供子任務分片功能，提供分片分發、分片認領、分片執行等功能以滿足高效執行批處理的要求。

在實現本發明過程中，發明人發現現有技術中至少存在如下問題：在子任務的處理過程中，無法動態獲知其他實例機器當前資源處理能力，造成資源使用效率較低。

發明內容

有鑒于此，本發明實施例提供一種處理任務的方法、裝置、設備和計算機可讀介質，能夠在子任務的處理過程中，動態獲知其他實例機器當前資源處理能力，提高資源使用效率。

為實現上述目的，根據本發明實施例的一個方面，提供了一種處理任務的方法，包括：

按照主任務的處理狀態，定時篩選出滿足子任務分片的主任務；

依據所述主任務的類型，將所述主任務拆分為一個或多個子任務，并將所述子任務的信息存在子任務信息表中；

在所述子任務信息表中，通過主任務下屬子任務的執行狀態，周期性確定發送至分布式集群的子任務；

在分布式集群中，執行所述發送至分布式集群的子任務。

所述按照主任務的處理狀態，定時篩選出滿足子任務分片的主任務，包括：

按照主任務的處理狀態，定時篩選出主任務預處理已完成且分布式消息未下發的主任務。

所述主任務的處理狀態是通過主任務的狀態代碼獲知的。

所述依據所述主任務的類型，將所述主任務拆分為一個或多個子任務，包括：

依據所述主任務的類型的標志，將所述主任務拆分為一個串行子任務，或多個并行子任務。

所述主任務的類型的標識是串行標識；

所述依據所述主任務的類型，將所述主任務拆分為一個或多個子任務，并將所述子任務的信息存在子任務信息表中，包括：

依據所述主任務的類型，將所述主任務拆分為一個串行子任務，并將所述串行子任務的信息存儲在子任務信息表中。

所述主任務的類型的標識是并行標識；

所述依據所述主任務的類型，將所述主任務拆分為一個或多個子任務，并將所述子任務的信息存在子任務信息表中，包括：

依據所述主任務的類型，將所述主任務拆分為多個并行子任務，并將所述并行子任務的信息存儲在子任務信息表中。

所述將所述主任務拆分為多個并行子任務，包括：