[發(fā)明專利]用于實(shí)時(shí)計(jì)算中的代碼升級(jí)的方法及裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 202010092831.1
• 申請(qǐng)日: 2020-02-14
• 公開（公告）號(hào): CN111338668B
• 公開（公告）日: 2022-05-10
• 發(fā)明（設(shè)計(jì)）人: 李飛飛
• 申請(qǐng)（專利權(quán)）人: 支付寶（杭州）信息技術(shù)有限公司
• 主分類號(hào): G06F8/65
• 分類號(hào): G06F8/65;G06F8/71;G06F11/14;G06F16/21
• 代理公司: 北京永新同創(chuàng)知識(shí)產(chǎn)權(quán)代理有限公司 11376
• 代理人: 林錦輝;劉景峰

1.一種用于實(shí)時(shí)計(jì)算中的代碼升級(jí)的方法，包括：

在接收到當(dāng)前運(yùn)行代碼的代碼升級(jí)指令后，獲取所述當(dāng)前運(yùn)行代碼的升級(jí)代碼，所述當(dāng)前運(yùn)行代碼的主任務(wù)用于對(duì)數(shù)據(jù)庫(kù)進(jìn)行實(shí)時(shí)計(jì)算，所述數(shù)據(jù)庫(kù)具有多版本數(shù)據(jù)存儲(chǔ)能力，所述主任務(wù)調(diào)用所述數(shù)據(jù)庫(kù)中的對(duì)應(yīng)版本數(shù)據(jù)來(lái)進(jìn)行處理；

觸發(fā)處理內(nèi)核運(yùn)行所述升級(jí)代碼，以啟動(dòng)備份任務(wù)來(lái)按照版本順序調(diào)用所述數(shù)據(jù)庫(kù)中的數(shù)據(jù)進(jìn)行處理，所述備份任務(wù)所調(diào)用的數(shù)據(jù)的起始版本被設(shè)置為不晚于所述主任務(wù)在接收到所述代碼升級(jí)指令時(shí)所處理的數(shù)據(jù)版本，所述備份任務(wù)的處理能力比所述主任務(wù)的處理能力強(qiáng)；

監(jiān)測(cè)所述主任務(wù)和所述備份任務(wù)的當(dāng)前處理數(shù)據(jù)版本是否相同；以及

在所述主任務(wù)和所述備份任務(wù)的當(dāng)前處理數(shù)據(jù)版本相同時(shí)，使得所述處理內(nèi)核停止所述主任務(wù)，并使得所述處理內(nèi)核將所述備份任務(wù)作為新的主任務(wù)來(lái)繼續(xù)針對(duì)所述數(shù)據(jù)庫(kù)進(jìn)行實(shí)時(shí)計(jì)算。

2.如權(quán)利要求1所述的方法，還包括：

監(jiān)測(cè)所述主任務(wù)和所述備份任務(wù)的當(dāng)前數(shù)據(jù)處理進(jìn)度是否相同；以及

在所述主任務(wù)和所述備份任務(wù)的當(dāng)前處理數(shù)據(jù)版本相同時(shí)，使得所述處理內(nèi)核停止所述主任務(wù)，并使得所述處理內(nèi)核將所述備份任務(wù)作為新的主任務(wù)來(lái)繼續(xù)針對(duì)所述數(shù)據(jù)庫(kù)進(jìn)行實(shí)時(shí)計(jì)算包括：

在所述主任務(wù)和所述備份任務(wù)的當(dāng)前處理數(shù)據(jù)版本和當(dāng)前數(shù)據(jù)處理進(jìn)度都相同時(shí)，使得所述處理內(nèi)核停止所述主任務(wù)，并使得所述處理內(nèi)核將所述備份任務(wù)作為新的主任務(wù)來(lái)繼續(xù)針對(duì)所述數(shù)據(jù)庫(kù)進(jìn)行實(shí)時(shí)計(jì)算。

3.如權(quán)利要求2所述的方法，其中，根據(jù)以下方式中的至少一種來(lái)確定所述主任務(wù)和所述備份任務(wù)的數(shù)據(jù)處理進(jìn)度相同：

針對(duì)屬于相同的處理數(shù)據(jù)版本的相同數(shù)據(jù)，所述備份任務(wù)的結(jié)束處理時(shí)間點(diǎn)與所述主任務(wù)的結(jié)束處理時(shí)間點(diǎn)之間的時(shí)間差在第一數(shù)值范圍內(nèi)；和

針對(duì)屬于相同的處理數(shù)據(jù)版本的相同數(shù)據(jù)，在處理該相同數(shù)據(jù)的過(guò)程中，所述備份任務(wù)和所述主任務(wù)所處的處理階段相同。

4.如權(quán)利要求1至3任一項(xiàng)所述的方法，其中，根據(jù)以下方式來(lái)確定所述主任務(wù)和所述備份任務(wù)的當(dāng)前處理數(shù)據(jù)版本相同：

所述備份任務(wù)針對(duì)已處理數(shù)據(jù)版本所對(duì)應(yīng)數(shù)據(jù)的結(jié)束處理時(shí)間點(diǎn)與所述主任務(wù)針對(duì)該已處理數(shù)據(jù)版本所對(duì)應(yīng)數(shù)據(jù)的結(jié)束處理時(shí)間點(diǎn)的時(shí)間差值在第二數(shù)值范圍內(nèi)。

5.如權(quán)利要求1或2所述的方法，其中，觸發(fā)處理內(nèi)核運(yùn)行所述升級(jí)代碼包括：

安裝所述升級(jí)代碼，將安裝后的升級(jí)代碼加載至所述處理內(nèi)核的執(zhí)行環(huán)境中，并觸發(fā)所述處理內(nèi)核來(lái)運(yùn)行所述升級(jí)代碼；或者

觸發(fā)代碼安裝裝置來(lái)安裝所述升級(jí)代碼并將安裝后的升級(jí)代碼加載至所述處理內(nèi)核的執(zhí)行環(huán)境中，并使得所述處理內(nèi)核運(yùn)行所述升級(jí)代碼。

6.如權(quán)利要求1或2所述的方法，其中，所述數(shù)據(jù)庫(kù)包括HBase或者Kudu。

7.如權(quán)利要求1或2所述的方法，還包括：

將所述主任務(wù)和所述備份任務(wù)的處理結(jié)果同步至搜索引擎。

8.如權(quán)利要求7所述的方法，其中，所述搜索引擎對(duì)所述主任務(wù)和所述備份任務(wù)的處理結(jié)果進(jìn)行去重處理。