[發(fā)明專利]一種基于具象狀態(tài)傳輸服務(wù)進(jìn)行作業(yè)管理的方法和裝置

在審

• 申請(qǐng)?zhí)枺?/td>: 202011494824.0
• 申請(qǐng)日: 2020-12-17
• 公開（公告）號(hào): CN112486709A
• 公開（公告）日: 2021-03-12
• 發(fā)明（設(shè)計(jì)）人: 周健;李志偉;徐圣杰
• 申請(qǐng)（專利權(quán)）人: 中國(guó)農(nóng)業(yè)銀行股份有限公司
• 主分類號(hào): G06F9/54
• 分類號(hào): G06F9/54;H04L29/08
• 代理公司: 北京集佳知識(shí)產(chǎn)權(quán)代理有限公司 11227
• 代理人: 王寶筠

1.一種基于具象狀態(tài)傳輸服務(wù)進(jìn)行作業(yè)管理的方法，其特征在于，作業(yè)為基于弗林克Flink框架開發(fā)的應(yīng)用程序，所述方法包括：

Flink具象狀態(tài)傳輸服務(wù)接口接收Flink作業(yè)對(duì)應(yīng)的超文本傳輸協(xié)議請(qǐng)求，所述超文本傳輸協(xié)議請(qǐng)求中包含用戶身份信息和請(qǐng)求信息，所述請(qǐng)求信息為包括待上傳作業(yè)的上傳請(qǐng)求、啟動(dòng)作業(yè)參數(shù)、作業(yè)列表查詢請(qǐng)求、查看運(yùn)行中作業(yè)請(qǐng)求、查看作業(yè)檢查點(diǎn)請(qǐng)求或取消作業(yè)請(qǐng)求，所述用戶身份信息用于登錄所述Flink具象狀態(tài)傳輸服務(wù)接口；

Flink具象狀態(tài)傳輸服務(wù)接口對(duì)所述請(qǐng)求信息自動(dòng)進(jìn)行解析，以便將所述請(qǐng)求信息轉(zhuǎn)化成符合Flink集群執(zhí)行格式的命令；

Flink具象狀態(tài)傳輸服務(wù)接口向Flink集群發(fā)送所述命令，以便所述Flink集群執(zhí)行所述命令。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，在所述Flink具象狀態(tài)傳輸服務(wù)接口接收Flink作業(yè)對(duì)應(yīng)的超文本傳輸協(xié)議請(qǐng)求之后，所述Flink具象狀態(tài)傳輸服務(wù)接口對(duì)所述請(qǐng)求信息自動(dòng)進(jìn)行解析之前，所述方法還包括：

當(dāng)所述請(qǐng)求信息為包括待上傳作業(yè)的上傳請(qǐng)求、作業(yè)列表查詢請(qǐng)求、查看運(yùn)行中作業(yè)請(qǐng)求或查看作業(yè)檢查點(diǎn)請(qǐng)求時(shí)，F(xiàn)link具象狀態(tài)傳輸服務(wù)接口判斷所述請(qǐng)求信息中所述作業(yè)的啟動(dòng)作業(yè)參數(shù)是否在Flink作業(yè)信息庫(kù)中存在，若存在，則加載所述信息庫(kù)中所述作業(yè)的啟動(dòng)作業(yè)參數(shù)補(bǔ)充所述請(qǐng)求信息。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，在所述Flink具象狀態(tài)傳輸服務(wù)接口向Flink集群發(fā)送所述命令后，所述方法還包括：

Flink具象狀態(tài)傳輸服務(wù)接口接收所述命令執(zhí)行結(jié)果；

Flink具象狀態(tài)傳輸服務(wù)接口將所述執(zhí)行結(jié)果發(fā)送給用戶。

4.根據(jù)權(quán)利要求3所述的方法，其特征在于，在將所述執(zhí)行結(jié)果發(fā)送給用戶后，所述方法還包括：

Flink具象狀態(tài)傳輸服務(wù)接口將作業(yè)基本信息、日志信息和作業(yè)執(zhí)行結(jié)果信息發(fā)送到Flink作業(yè)信息庫(kù)保存。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，所述作業(yè)基本信息包括：

作業(yè)名、作業(yè)啟動(dòng)參數(shù)、作業(yè)描述和作業(yè)編號(hào)。

6.一種基于具象狀態(tài)傳輸服務(wù)進(jìn)行作業(yè)管理的裝置，其特征在于，作業(yè)為基于弗林克Flink框架開發(fā)的應(yīng)用程序，所述裝置包括：

超文本傳輸協(xié)議請(qǐng)求接收單元，用于接收Flink作業(yè)對(duì)應(yīng)的超文本傳輸協(xié)議請(qǐng)求，所述超文本傳輸協(xié)議請(qǐng)求中包含用戶身份信息和請(qǐng)求信息，所述請(qǐng)求信息為包括待上傳作業(yè)的上傳請(qǐng)求、啟動(dòng)作業(yè)參數(shù)、作業(yè)列表查詢請(qǐng)求、查看運(yùn)行中作業(yè)請(qǐng)求、查看作業(yè)檢查點(diǎn)請(qǐng)求或取消作業(yè)請(qǐng)求，所述用戶身份信息用于登錄所述Flink具象狀態(tài)傳輸服務(wù)接口；

請(qǐng)求信息自動(dòng)解析單元，用于對(duì)所述請(qǐng)求信息自動(dòng)進(jìn)行解析，以便將所述請(qǐng)求信息轉(zhuǎn)化成符合Flink集群執(zhí)行格式的命令；

命令發(fā)送單元，用于向Flink集群發(fā)送所述命令，以便所述Flink集群執(zhí)行所述命令。

7.根據(jù)權(quán)利要求6所述的裝置，其特征在于，所述裝置還包括：

啟動(dòng)作業(yè)參數(shù)加載單元，用于在所述接收Flink作業(yè)對(duì)應(yīng)的超文本傳輸協(xié)議請(qǐng)求之后，所述對(duì)所述請(qǐng)求信息自動(dòng)進(jìn)行解析之前，當(dāng)所述請(qǐng)求信息為包括待上傳作業(yè)的上傳請(qǐng)求、作業(yè)列表查詢請(qǐng)求、查看運(yùn)行中作業(yè)請(qǐng)求或查看作業(yè)檢查點(diǎn)請(qǐng)求時(shí)，判斷所述請(qǐng)求信息中所述作業(yè)的啟動(dòng)作業(yè)參數(shù)是否在Flink作業(yè)信息庫(kù)中存在，若存在，則加載所述信息庫(kù)中所述作業(yè)的啟動(dòng)作業(yè)參數(shù)補(bǔ)充所述請(qǐng)求信息。

8.根據(jù)權(quán)利要求6所述的裝置，其特征在于，所述裝置還包括：

結(jié)果接收單元，用于在所述向Flink集群發(fā)送所述命令后，接收所述命令執(zhí)行結(jié)果；

結(jié)果發(fā)送單元，用于將所述執(zhí)行結(jié)果發(fā)送給用戶。

9.根據(jù)權(quán)利要求8所述的裝置，其特征在于，所述裝置還包括：

信息發(fā)送單元，用于在將所述執(zhí)行結(jié)果發(fā)送給用戶后，將作業(yè)基本信息、日志信息和作業(yè)執(zhí)行結(jié)果信息發(fā)送到Flink作業(yè)信息庫(kù)保存。

10.根據(jù)權(quán)利要求9所述的裝置，其特征在于，所述作業(yè)基本信息包括：

作業(yè)名、作業(yè)啟動(dòng)參數(shù)、作業(yè)描述和作業(yè)編號(hào)。