[發(fā)明專利]一種job控制方法及裝置

有效

• 申請?zhí)枺?/td>: 201611265980.3
• 申請日: 2016-12-31
• 公開（公告）號: CN106775989B
• 公開（公告）日: 2019-07-02
• 發(fā)明（設(shè)計(jì)）人: 何彪;鄭鈞元
• 申請（專利權(quán)）人: 北京神州綠盟信息安全科技股份有限公司;北京神州綠盟科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/54
• 代理公司: 北京同達(dá)信恒知識產(chǎn)權(quán)代理有限公司 11291
• 代理人: 黃志華

1.一種作業(yè)job控制方法，其特征在于，所述方法包括：

針對接入大數(shù)據(jù)平臺的每個(gè)數(shù)據(jù)源，根據(jù)kafka消息隊(duì)列中保存的每個(gè)數(shù)據(jù)源的狀態(tài)信息，識別是否每個(gè)數(shù)據(jù)源都處于停止?fàn)顟B(tài)；

如果是，關(guān)閉解析job和/或入庫job。

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

根據(jù)kafka消息隊(duì)列中保存的每個(gè)數(shù)據(jù)源的狀態(tài)信息，識別是否存在處于啟動(dòng)狀態(tài)的數(shù)據(jù)源；

如果是，開啟解析job和/或入庫job。

3.如權(quán)利要求1所述的方法，其特征在于，如果當(dāng)前存在處于啟動(dòng)狀態(tài)的數(shù)據(jù)源，所述方法還包括：

判斷解析job和/或入庫job是否針對該數(shù)據(jù)源發(fā)送的數(shù)據(jù)進(jìn)行解析和/或入庫操作；

如果否，控制解析job和/或入庫job對該數(shù)據(jù)源發(fā)送的數(shù)據(jù)進(jìn)行解析和/或入庫操作。

4.如權(quán)利要求3所述的方法，其特征在于，所述控制解析job和/或入庫job對該數(shù)據(jù)源發(fā)送的數(shù)據(jù)進(jìn)行解析和/或入庫操作包括：

重啟所述解析job和/或入庫job，采用重啟后的解析job和/或入庫job對處于啟動(dòng)狀態(tài)的數(shù)據(jù)源發(fā)送的數(shù)據(jù)進(jìn)行解析和/或入庫操作。

5.如權(quán)利要求1所述的方法，其特征在于，所述根據(jù)kafka消息隊(duì)列中保存的每個(gè)數(shù)據(jù)源的狀態(tài)信息，識別是否每個(gè)數(shù)據(jù)源都處于停止?fàn)顟B(tài)之前，所述方法還包括：

根據(jù)用戶對每個(gè)數(shù)據(jù)源啟動(dòng)或停止的設(shè)置指令，生成每個(gè)數(shù)據(jù)源對應(yīng)的狀態(tài)信息保存到所述kafka消息隊(duì)列中。

6.一種作業(yè)job控制裝置，其特征在于，所述裝置包括：

識別模塊，用于針對接入大數(shù)據(jù)平臺的每個(gè)數(shù)據(jù)源，根據(jù)kafka消息隊(duì)列中保存的每個(gè)數(shù)據(jù)源的狀態(tài)信息，識別是否每個(gè)數(shù)據(jù)源都處于停止?fàn)顟B(tài)；

關(guān)閉模塊，用于如果識別模塊識別到每個(gè)數(shù)據(jù)源都處于停止?fàn)顟B(tài)，關(guān)閉解析job和/或入庫job。

7.如權(quán)利要求6所述的裝置，其特征在于，所述識別模塊，還用于根據(jù)kafka消息隊(duì)列中保存的每個(gè)數(shù)據(jù)源的狀態(tài)信息，識別是否存在處于啟動(dòng)狀態(tài)的數(shù)據(jù)源；

所述裝置還包括：

開啟模塊，用于如果所述識別模塊識別到當(dāng)前存在處于啟動(dòng)狀態(tài)的數(shù)據(jù)源，開啟解析job和/或入庫job。

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

判斷模塊，用于如果當(dāng)前存在處于啟動(dòng)狀態(tài)的數(shù)據(jù)源，判斷解析job和/或入庫job是否針對該數(shù)據(jù)源發(fā)送的數(shù)據(jù)進(jìn)行解析和/或入庫操作；

控制模塊，用于如果判斷模塊的判斷結(jié)果為否，控制解析job和/或入庫job對該數(shù)據(jù)源發(fā)送的數(shù)據(jù)進(jìn)行解析和/或入庫操作。

9.如權(quán)利要求8所述的裝置，其特征在于，所述控制模塊，具體用于重啟所述解析job和/或入庫job，采用重啟后的解析job和/或入庫job對處于啟動(dòng)狀態(tài)的數(shù)據(jù)源發(fā)送的數(shù)據(jù)進(jìn)行解析和/或入庫操作。

10.如權(quán)利要求6所述的裝置，其特征在于，所述裝置還包括：

生成模塊，用于根據(jù)用戶對每個(gè)數(shù)據(jù)源啟動(dòng)或停止的設(shè)置指令，生成每個(gè)數(shù)據(jù)源對應(yīng)的狀態(tài)信息保存到所述kafka消息隊(duì)列中。