[發(fā)明專利]一種作業(yè)調(diào)度方法及系統(tǒng)

有效

• 申請(qǐng)?zhí)枺?/td>: 201410004083.1
• 申請(qǐng)日: 2014-01-02
• 公開(kāi)（公告）號(hào): CN104765641B
• 公開(kāi)（公告）日: 2019-04-12
• 發(fā)明（設(shè)計(jì)）人: 張來(lái)勇;汪玨斌
• 申請(qǐng)（專利權(quán)）人: 中國(guó)移動(dòng)通信集團(tuán)安徽有限公司
• 主分類號(hào): G06F9/50
• 分類號(hào): G06F9/50;H04L12/24
• 代理公司: 北京派特恩知識(shí)產(chǎn)權(quán)代理有限公司 11270
• 代理人: 張穎玲;王黎延

本發(fā)明公開(kāi)了一種作業(yè)調(diào)度方法及系統(tǒng)，包括：建立存儲(chǔ)作業(yè)配置信息的作業(yè)庫(kù)和存儲(chǔ)作業(yè)間邏輯規(guī)則信息的邏輯規(guī)則配置庫(kù)；接收到作業(yè)啟動(dòng)指示后，讀取所述作業(yè)庫(kù)中的作業(yè)配置信息；根據(jù)所述作業(yè)配置信息調(diào)度所述作業(yè)，并將攜帶所述作業(yè)配置信息的作業(yè)執(zhí)行指示發(fā)送給目標(biāo)終端；接收到所述目標(biāo)終端執(zhí)行所述作業(yè)后發(fā)送的作業(yè)處理信息后，根據(jù)所述作業(yè)處理信息以及所述邏輯規(guī)則信息確定是否存在與所述作業(yè)邏輯關(guān)聯(lián)的作業(yè)；確定存在與所述作業(yè)邏輯關(guān)聯(lián)的作業(yè)時(shí)，調(diào)度與所述作業(yè)邏輯關(guān)聯(lián)的作業(yè)，達(dá)到實(shí)現(xiàn)分布式架構(gòu)下同構(gòu)、異構(gòu)作業(yè)的協(xié)同運(yùn)作的目的。

技術(shù)領(lǐng)域

本發(fā)明涉及計(jì)算機(jī)與通信領(lǐng)域的調(diào)度管理技術(shù)，尤其涉及一種作業(yè)調(diào)度方法及系統(tǒng)。

背景技術(shù)

現(xiàn)有大型計(jì)算機(jī)系統(tǒng)中，對(duì)遠(yuǎn)程計(jì)算機(jī)或者設(shè)備的訪問(wèn)和控制，如采集數(shù)據(jù)或者執(zhí)行操作，可以稱之為作業(yè)。作業(yè)可分為很多種類型，例如：操作遠(yuǎn)程主機(jī)的進(jìn)程可以視為進(jìn)程作業(yè)，需要通過(guò)Telnet遠(yuǎn)程登錄協(xié)議或者SSH安全協(xié)議等協(xié)議進(jìn)行登陸操作；操作遠(yuǎn)程數(shù)據(jù)庫(kù)的數(shù)據(jù)可視為數(shù)據(jù)庫(kù)作業(yè)，數(shù)據(jù)庫(kù)作業(yè)可進(jìn)一步分為按照數(shù)據(jù)庫(kù)類型的作業(yè)，如Oracle、Sybase、mySQL、MSSQL server等數(shù)據(jù)庫(kù)類型的作業(yè)；或者，按照數(shù)據(jù)定義的作業(yè)，如數(shù)據(jù)庫(kù)模式定義語(yǔ)言（Data Definition Language，DDL）作業(yè)；或者，按照數(shù)據(jù)操作的作業(yè)，如數(shù)據(jù)媒體實(shí)驗(yàn)室（Data Media Laboratory，DML）作業(yè)等。不同種類的作業(yè)，由于其目標(biāo)或者操作方式的區(qū)別，稱為異構(gòu)作業(yè)。

現(xiàn)有的作業(yè)調(diào)度技術(shù)方案主要包括以下兩種：

一種是，現(xiàn)有技術(shù)公開(kāi)有一種計(jì)算機(jī)機(jī)群作業(yè)調(diào)度系統(tǒng)，包括：至少一個(gè)計(jì)算單元塊，每一個(gè)計(jì)算單元塊均與核心交換機(jī)連接，用于完成作業(yè)和/或傳輸數(shù)據(jù)的任務(wù)；核心交換機(jī)，與計(jì)算單元塊連接，用于采集計(jì)算單元塊的工作參數(shù)，對(duì)每一個(gè)工作參數(shù)設(shè)置一個(gè)權(quán)值，根據(jù)工作參數(shù)以及對(duì)應(yīng)的權(quán)值編制各個(gè)計(jì)算單元塊對(duì)應(yīng)的負(fù)載平衡指數(shù)；按照預(yù)定策略，根據(jù)負(fù)載平衡指數(shù)為計(jì)算單元塊分配作業(yè)和/或傳輸數(shù)據(jù)的任務(wù)，從而避免了某個(gè)端口過(guò)于繁忙或空閑而導(dǎo)致的跨交換機(jī)端口數(shù)據(jù)交互的堵塞性，使分配策略更加合理。

另一種是，現(xiàn)有技術(shù)公開(kāi)有一種使用有向無(wú)環(huán)圖解決作業(yè)調(diào)度的方法，判斷作業(yè)在預(yù)設(shè)的作業(yè)依賴關(guān)系中的所有父作業(yè)是否均成功執(zhí)行；當(dāng)所述作業(yè)的所有父作業(yè)均成功執(zhí)行時(shí)，則觸發(fā)執(zhí)行所述作業(yè)，從而將一個(gè)高性能計(jì)算應(yīng)用分解為一組存在數(shù)據(jù)輸入輸出關(guān)系的計(jì)算子作業(yè)，并采用有向無(wú)循環(huán)圖表示一個(gè)高性能計(jì)算應(yīng)用中各個(gè)子作業(yè)之間的數(shù)據(jù)相關(guān)性。

發(fā)明人在實(shí)現(xiàn)本發(fā)明的過(guò)程中，發(fā)現(xiàn)現(xiàn)有作業(yè)調(diào)度技術(shù)方案至少存在以下缺陷：

第一種方案僅針對(duì)同構(gòu)作業(yè)進(jìn)行調(diào)度，未對(duì)不同類型的異構(gòu)作業(yè)做出調(diào)度；而第二種方案，未對(duì)作業(yè)之間的邏輯關(guān)系和分支判斷進(jìn)行描述，且無(wú)法解決實(shí)際運(yùn)維操作中存在的有環(huán)流程，即：在一次業(yè)務(wù)流程中，無(wú)法實(shí)現(xiàn)多次使用同一個(gè)作業(yè)的情況。

發(fā)明內(nèi)容

有鑒于此，本發(fā)明實(shí)施例提供一種作業(yè)調(diào)度方法及系統(tǒng)，能屏蔽不同類型作業(yè)的差異，實(shí)現(xiàn)同構(gòu)作業(yè)、異構(gòu)作業(yè)統(tǒng)一配置與協(xié)同工作。

為達(dá)到上述目的，本發(fā)明的技術(shù)方案是這樣實(shí)現(xiàn)的：

本發(fā)明實(shí)施例提供了一種作業(yè)調(diào)度方法，該方法包括：

建立存儲(chǔ)作業(yè)配置信息的作業(yè)庫(kù)和存儲(chǔ)作業(yè)間邏輯規(guī)則信息的邏輯規(guī)則配置庫(kù)；

接收到作業(yè)啟動(dòng)指示后，讀取所述作業(yè)庫(kù)中的作業(yè)配置信息；根據(jù)所述作業(yè)配置信息調(diào)度所述作業(yè)，并將攜帶所述作業(yè)配置信息的作業(yè)執(zhí)行指示發(fā)送給目標(biāo)終端；

接收到所述目標(biāo)終端執(zhí)行所述作業(yè)后發(fā)送的作業(yè)處理信息后，根據(jù)所述作業(yè)處理信息以及所述邏輯規(guī)則信息確定是否存在與所述作業(yè)邏輯關(guān)聯(lián)的作業(yè)；確定存在與所述作業(yè)邏輯關(guān)聯(lián)的作業(yè)時(shí)，調(diào)度與所述作業(yè)邏輯關(guān)聯(lián)的作業(yè)。

上述方案中，所述根據(jù)所述作業(yè)處理信息以及所述邏輯規(guī)則信息確定是否存在與所述作業(yè)邏輯關(guān)聯(lián)的作業(yè)，包括：