[發明專利]一種基于具象狀態傳輸服務進行作業管理的方法和裝置

在審

• 申請號: 202011494824.0
• 申請日: 2020-12-17
• 公開（公告）號: CN112486709A
• 公開（公告）日: 2021-03-12
• 發明（設計）人: 周健;李志偉;徐圣杰
• 申請（專利權）人: 中國農業銀行股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54;H04L29/08
• 代理公司: 北京集佳知識產權代理有限公司 11227
• 代理人: 王寶筠

本申請實施例公開了一種基于具象狀態傳輸服務進行作業管理的方法和裝置，該方法包括：Flink具象狀態傳輸服務接口接收Flink作業對應的超文本傳輸協議請求，所述超文本傳輸協議請求中包含用戶身份信息和請求信息，所述用戶身份信息用于登錄所述Flink具象狀態傳輸服務接口，Flink具象狀態傳輸服務接口對所述請求信息自動進行解析，Flink具象狀態傳輸服務接口向Flink集群發送所述命令。由此可見，本申請實施例中，可以提供統一的對外接口，用戶不需要額外遠程登錄，提高了進行Flink作業管理的效率，滿足了用戶高效進行Flink作業管理的需求。

技術領域

本申請涉及大數據領域，特別是涉及一種基于具象狀態傳輸服務進行作業管理的方法和裝置。

背景技術

近年來，Flink在大數據實時流計算領域發展迅猛，已成為業界在該領域的第一選擇。基于Flink框架開發的應用程序也稱為作業，這些作業需要提交到安裝了Flink處理引擎的分布式集群環境運行，用于針對實時流式數據實現不同的業務邏輯處理。

而在現有技術中，傳統的基于命令行的Flink作業管理方法中，無法提供統一的對外接口，技術人員需額外登錄遠程服務器進行操作。

因此，傳統的Flink作業管理方法中，作業管理效率低下，難以滿足用戶高效進行Flink作業管理的需求。

發明內容

為了解決上述技術問題，本申請提供了一種基于具象狀態傳輸服務進行Flink作業管理的方法和裝置，可以提供統一的對外接口，用戶不需要額外遠程登錄，提高了進行Flink作業管理的效率。

本申請實施例公開了如下技術方案：

第一方面，本申請實施例提供了一種基于具象狀態傳輸服務進行Flink作業管理的方法，包括：

Flink具象狀態傳輸服務接口接收Flink作業對應的超文本傳輸協議請求，所述超文本傳輸協議請求中包含用戶身份信息和請求信息，所述請求信息為包括待上傳作業的上傳請求、啟動作業參數、作業列表查詢請求、查看運行中作業請求、查看作業檢查點請求或取消作業請求，所述用戶身份信息用于登錄所述Flink具象狀態傳輸服務接口；

Flink具象狀態傳輸服務接口對所述請求信息自動進行解析，以便將所述請求信息轉化成符合Flink集群執行格式的命令；

Flink具象狀態傳輸服務接口向Flink集群發送所述命令，以便所述Flink集群執行所述命令。

可選的，在所述Flink具象狀態傳輸服務接口接收Flink作業對應的超文本傳輸協議請求之后，所述Flink具象狀態傳輸服務接口對所述請求信息自動進行解析之前，所述方法還包括：

當所述請求信息為包括待上傳作業的上傳請求、作業列表查詢請求、查看運行中作業請求或查看作業檢查點請求時，Flink具象狀態傳輸服務接口判斷所述請求信息中所述作業的啟動作業參數是否在Flink作業信息庫中存在，若存在，則加載所述信息庫中所述作業的啟動作業參數補充所述請求信息。

可選的，在所述Flink具象狀態傳輸服務接口向Flink集群發送所述命令后，所述方法還包括：

Flink具象狀態傳輸服務接口接收所述命令執行結果；

Flink具象狀態傳輸服務接口將所述執行結果發送給用戶。

可選的，在將所述執行結果發送給用戶后，所述方法還包括：

Flink具象狀態傳輸服務接口將作業基本信息、日志信息和作業執行結果信息發送到Flink作業信息庫保存。

可選的，所述作業基本信息包括：

作業名、作業啟動參數、作業描述和作業編號。