[發(fā)明專利]業(yè)務(wù)處理方法、裝置、設(shè)備和計算機(jī)存儲介質(zhì)

在審

• 申請?zhí)枺?/td>: 202110519593.2
• 申請日: 2021-05-12
• 公開（公告）號: CN113342542A
• 公開（公告）日: 2021-09-03
• 發(fā)明（設(shè)計）人: 劉桐仁;劉偉
• 申請（專利權(quán)）人: 北京百度網(wǎng)訊科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;G06F9/455
• 代理公司: 北京鴻德海業(yè)知識產(chǎn)權(quán)代理有限公司 11412
• 代理人: 田宏賓

1.一種業(yè)務(wù)處理方法，包括：

獲取用戶輸入的業(yè)務(wù)邏輯信息，所述業(yè)務(wù)邏輯包括一個以上的算子，至少部分算子之間插入有檢查點；

配置檢查點前后算子與數(shù)據(jù)隊列的綁定關(guān)系；

在容器中執(zhí)行所述業(yè)務(wù)邏輯的過程中，檢查點前算子將計算得到的數(shù)據(jù)寫入綁定的數(shù)據(jù)隊列，針對所述數(shù)據(jù)隊列執(zhí)行所述檢查點，所述檢查點后算子從綁定的數(shù)據(jù)隊列中讀取數(shù)據(jù)進(jìn)行計算。

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

面向用戶提供公共算子的信息，并存儲有所述公共算子的代碼；

若所述業(yè)務(wù)邏輯中包含所述公共算子，則在所述容器中加載并執(zhí)行所述公共算子的代碼。

3.根據(jù)權(quán)利要求1所述的方法，還包括：

預(yù)先存儲預(yù)設(shè)功能算子的軟件開發(fā)工具包SDK；

若所述業(yè)務(wù)邏輯中包含所述預(yù)設(shè)功能算子，則在執(zhí)行所述業(yè)務(wù)邏輯的過程中調(diào)用所述預(yù)設(shè)功能算子的SDK。

4.根據(jù)權(quán)利要求1所述的方法，還包括：

若所述業(yè)務(wù)邏輯中包含與公共數(shù)據(jù)流相關(guān)聯(lián)的算子，則在執(zhí)行所述業(yè)務(wù)邏輯的過程中，將所述公共數(shù)據(jù)流發(fā)送至所述與所述公共數(shù)據(jù)流相關(guān)聯(lián)的算子。

5.根據(jù)權(quán)利要求1所述的方法，其中，所述數(shù)據(jù)隊列包括kafka隊列。

6.根據(jù)權(quán)利要求1至5中任一項所述的方法，其中，所述檢查點包括指令信息和參數(shù)信息；

針對所述數(shù)據(jù)隊列執(zhí)行所述檢查點包括：

若所述指令信息為監(jiān)測指令，則所述檢查點后算子的旁路算子從所述數(shù)據(jù)隊列讀取數(shù)據(jù)并輸出；或者，

若所述指令信息為回灌指令，則所述檢查點后算子的旁路算子從所述數(shù)據(jù)隊列中讀取所述參數(shù)信息指定的歷史數(shù)據(jù)，并重新寫入所述數(shù)據(jù)隊列；或者，

若所述指令信息為干預(yù)指令，則攔截所述檢查點前算子計算得到的數(shù)據(jù)，并依據(jù)所述參數(shù)信息對攔截得到的數(shù)據(jù)進(jìn)行干預(yù)處理后寫入所述數(shù)據(jù)隊列；或者，

若所述指令信息為切換指令，則所述檢查點前算子將計算得到的數(shù)據(jù)在送入綁定的數(shù)據(jù)隊列時，依據(jù)所述參數(shù)信息同時將計算得到的數(shù)據(jù)寫入另一數(shù)據(jù)隊列。

7.一種業(yè)務(wù)處理裝置，包括：

邏輯獲取單元，用于獲取用戶輸入的業(yè)務(wù)邏輯信息，所述業(yè)務(wù)邏輯包括一個以上的算子，至少部分算子之間插入有檢查點；

配置生成單元，用于配置檢查點前后算子與數(shù)據(jù)隊列的綁定關(guān)系；

邏輯執(zhí)行單元，用于在容器中執(zhí)行所述業(yè)務(wù)邏輯的過程中，檢查點前算子將計算得到的數(shù)據(jù)寫入綁定的數(shù)據(jù)隊列，針對所述數(shù)據(jù)隊列執(zhí)行所述檢查點，所述檢查點后算子從綁定的數(shù)據(jù)隊列中讀取數(shù)據(jù)進(jìn)行計算。

8.根據(jù)權(quán)利要求7所述的裝置，還包括：

信息提供單元，用于面向用戶提供公共算子的信息；

第一存儲單元，用于存儲所述公共算子的代碼；

所述邏輯執(zhí)行單元，還用于若所述業(yè)務(wù)邏輯中包含所述公共算子，則在所述容器中加載并執(zhí)行所述公共算子的代碼。

9.根據(jù)權(quán)利要求7所述的裝置，還包括：

第二存儲單元，用于存儲預(yù)設(shè)功能算子的SDK；

所述邏輯執(zhí)行單元，還用于若所述業(yè)務(wù)邏輯中包含所述預(yù)設(shè)功能算子，則在執(zhí)行所述業(yè)務(wù)邏輯的過程中調(diào)用所述預(yù)設(shè)功能算子的SDK。

10.根據(jù)權(quán)利要求7所述的裝置，還包括：

所述邏輯執(zhí)行單元，還用于若所述業(yè)務(wù)邏輯中包含與公共數(shù)據(jù)流相關(guān)聯(lián)的算子，則在執(zhí)行所述業(yè)務(wù)邏輯的過程中，將所述公共數(shù)據(jù)流發(fā)送至所述與所述公共數(shù)據(jù)流相關(guān)聯(lián)的算子。

11.根據(jù)權(quán)利要求7所述的裝置，其中，所述數(shù)據(jù)隊列包括kafka隊列。