[發(fā)明專利]一種任務(wù)分發(fā)管理方法、裝置、設(shè)備及介質(zhì)

在審

• 申請?zhí)枺?/td>: 202010522290.1
• 申請日: 2020-06-10
• 公開（公告）號: CN111694666A
• 公開（公告）日: 2020-09-22
• 發(fā)明（設(shè)計）人: 丁瑩
• 申請（專利權(quán)）人: 中國建設(shè)銀行股份有限公司;建信金融科技有限責(zé)任公司
• 主分類號: G06F9/50
• 分類號: G06F9/50
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

1.一種任務(wù)分發(fā)管理方法，其特征在于，由Broadcast Job資源對象執(zhí)行，包括：

獲取與待執(zhí)行任務(wù)匹配的至少一項(xiàng)任務(wù)配置信息，所述任務(wù)配置信息包括：定時銷毀時間；

在Kubernetes系統(tǒng)中的至少一個節(jié)點(diǎn)中創(chuàng)建容器組副本，并將所述待執(zhí)行任務(wù)分發(fā)至各所述容器組副本中執(zhí)行；

當(dāng)獲取到各所述容器組副本反饋的任務(wù)結(jié)束響應(yīng)時，開始為各所述容器組副本計時，并在計時至所述定時銷毀時間時，銷毀相應(yīng)的容器組副本。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述Broadcast Job資源對象為通過自定義資源類型CRD初始化創(chuàng)建后，在初始化Broadcast Job資源對象中定義資源集合后得到的；

所述資源集合中包括：至少一項(xiàng)資源字段名，以及與各所述資源字段名分別對應(yīng)的待填充數(shù)據(jù)項(xiàng)；

所述待填充數(shù)據(jù)項(xiàng)與所述Broadcast Job資源對象中的任務(wù)配置信息關(guān)聯(lián)。

3.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，所述任務(wù)配置信息中還包括：容器組副本的模板信息；

在Kubernetes系統(tǒng)中的至少一個節(jié)點(diǎn)中創(chuàng)建容器組副本，具體包括：

在Kubernetes系統(tǒng)中的至少一個節(jié)點(diǎn)中，按照所述容器組副本的模板信息創(chuàng)建所述容器組副本。

4.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，所述任務(wù)配置信息中還包括：同時運(yùn)行的容器組副本的最大數(shù)量；

在Kubernetes系統(tǒng)中的至少一個節(jié)點(diǎn)中創(chuàng)建容器組副本，具體包括：

根據(jù)所述待執(zhí)行任務(wù)的任務(wù)量，計算容器組副本的理想數(shù)量；

如果所述理想數(shù)量未超過所述最大數(shù)量，則在Kubernetes系統(tǒng)中的理想數(shù)量個節(jié)點(diǎn)中各創(chuàng)建一個容器組副本；

如果所述理想數(shù)量超過所述最大數(shù)量，則在Kubernetes系統(tǒng)中的最大數(shù)量個節(jié)點(diǎn)中各創(chuàng)建一個容器組副本。

5.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，所述任務(wù)配置信息中還包括：暫停控制信息，所述暫停控制信息包括暫停使能，或者暫停禁止；

在將所述待執(zhí)行任務(wù)分發(fā)至各所述容器組副本中執(zhí)行之后，還包括：

根據(jù)檢測到的與第一目標(biāo)容器組副本匹配的暫停指令，查詢暫停使能信息；

如果所述暫停使能信息為暫停使能，則指示所述第一目標(biāo)容器組副本對所分發(fā)的任務(wù)進(jìn)行暫停處理；

如果所述暫停使能信息為暫停禁止，則忽略所述暫停指令。

6.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，所述任務(wù)配置信息中還包括：任務(wù)失敗時響應(yīng)類型；

在將所述待執(zhí)行任務(wù)分發(fā)至各所述容器組副本中執(zhí)行之后，還包括：

在檢測到第二目標(biāo)容器組副本任務(wù)執(zhí)行失敗時，執(zhí)行與所述任務(wù)失敗時響應(yīng)類型匹配的失敗響應(yīng)機(jī)制。

7.根據(jù)權(quán)利要求1或2所述的方法，其特征在于，所述任務(wù)配置信息中還包括：容器組標(biāo)簽；

在Kubernetes系統(tǒng)中的至少一個節(jié)點(diǎn)中創(chuàng)建容器組副本，具體包括：

在Kubernetes系統(tǒng)中的至少一個節(jié)點(diǎn)中，創(chuàng)建與所述容器組標(biāo)簽匹配的容器組副本。

8.一種任務(wù)分發(fā)管理裝置，其特征在于，包括：

任務(wù)配置信息獲取模塊，用于獲取與待執(zhí)行任務(wù)匹配的至少一項(xiàng)任務(wù)配置信息，所述任務(wù)配置信息包括：定時銷毀時間；

待執(zhí)行任務(wù)分發(fā)模塊，用于在Kubernetes系統(tǒng)中的至少一個節(jié)點(diǎn)中創(chuàng)建容器組副本，并將所述待執(zhí)行任務(wù)分發(fā)至各所述容器組副本中執(zhí)行；

容器組副本銷毀模塊，用于當(dāng)獲取到各所述容器組副本反饋的任務(wù)結(jié)束響應(yīng)時，開始為各所述容器組副本計時，并在計時至所述定時銷毀時間時，銷毀相應(yīng)的容器組副本。

9.一種電子設(shè)備，其特征在于，所述設(shè)備包括：

一個或多個處理器；

存儲器，用于存儲一個或多個程序；

當(dāng)所述一個或多個程序被所述一個或多個處理器執(zhí)行，使得所述一個或多個處理器實(shí)現(xiàn)如權(quán)利要求1-7中任一所述的任務(wù)分發(fā)管理方法。

10.一種計算機(jī)可讀存儲介質(zhì)，其上存儲有計算機(jī)程序，其特征在于，該程序被處理器執(zhí)行時實(shí)現(xiàn)如權(quán)利要求1-7中任一所述任務(wù)分發(fā)管理方法。