鬼佬大哥大
  • / 15
  • 下載費用:30 金幣  

批處理調度方法、裝置和系統.pdf

摘要
申請專利號:

CN201510763249.2

申請日:

2015.11.10

公開號:

CN105204929A

公開日:

2015.12.30

當前法律狀態:

授權

有效性:

有權

法律詳情: 授權|||實質審查的生效IPC(主分類):G06F 9/46申請日:20151110|||公開
IPC分類號: G06F9/46 主分類號: G06F9/46
申請人: 中國建設銀行股份有限公司
發明人: 楊代兵; 方紅濤; 李桂林; 王爾剛
地址: 100033 北京市西城區金融大街25號
優先權:
專利代理機構: 北京集佳知識產權代理有限公司 11227 代理人: 王寶筠
PDF完整版下載: PDF下載
法律狀態
申請(專利)號:

CN201510763249.2

授權公告號:

||||||

法律狀態公告日:

2018.10.19|||2016.01.27|||2015.12.30

法律狀態類型:

授權|||實質審查的生效|||公開

摘要

本發明公開一種批處理調度方法、裝置和系統。所述方法包括:在批處理過程中,如果某個批處理作業執行失敗,即發生錯誤,會自動執行錯誤處理作業用以排除錯誤,錯誤排除后,自動從該批處理作業發生錯誤的步驟繼續執行該批處理作業,直至該批處理作業執行成功,然后再開始執行下一個批處理作業,直至全部批處理作業成功執行完成。應用本發明提供的批處理調度方法、裝置和系統,在作業執行失敗時,能夠自動執行錯誤處理作業來排除錯誤,響應時間很快,因此效率很高,從而有效的保障批處理工作及時、順利的完成。

權利要求書

權利要求書
1.  一種批處理調度方法,其特征在于,包括:
執行第一技術方案,所述第一技術方案包括:
在批量作業參數信息中,查找當前待作業任務對應的機器地址和執行用戶;
遠程登錄到待作業機器,執行所述當前待作業任務的啟動腳本,控制所述當前待作業任務開始執行;所述待作業機器與所述機器地址和所述執行用戶相對應;
接收狀態碼;所述狀態碼由與所述待作業機器發送,表征所述當前待作業任務執行成功或者執行所述當前待作業任務時發生錯誤的步驟;
判斷所述狀態碼是否表征所述當前待作業任務未執行成功,如果是,執行第二技術方案,如果否,執行第三技術方案;
所述第二技術方案包括:
在所述批量作業參數信息中,查找與所述狀態碼相對應的錯誤處理作業任務;控制所述待作業機器執行所述錯誤處理作業任務;控制所述待作業機器從所述當前待作業任務中的預設步驟重新開始執行,所述預設步驟是與所述狀態碼相對應的步驟;依據重新接收到的狀態碼判斷所述當前待作業任務是否執行成功,如果是,執行所述第三技術方案,如果否,繼續執行所述第二技術方案;
所述第三技術方案包括:
在所述批量作業參數信息中,查找所述當前待作業任務之后的相鄰的作業任務,將所述當前待作業任務之后相鄰的作業任務確定為新的當前待作業任務,重新執行所述第一技術方案,直至所述當前待作業任務為最后一個作業任務。

2.  根據權利要求1所述的方法,其特征在于,所述在批量作業參數信息中,查找當前待作業任務對應的機器地址和執行用戶之前,還包括:
獲取并存儲工作人員輸入的所述批量作業參數信息。

3.  根據權利要求1所述的方法,其特征在于,所述批量作業參數信息包括:
作業任務名稱、作業任務執行的機器地址、作業任務執行的用戶、作業任務開始執行的時間、前置作業任務、后置作業任務、作業任務啟動腳本、狀態碼和錯誤處理作業任務。

4.  根據權利要求3所述的方法,其特征在于,所述批量作業參數信息以批量作業參數表的形式存儲。

5.  根據權利要求4所述的方法,其特征在于,所述作業任務名稱、所述狀態碼和所述錯誤處理作業任務以狀態碼子表的方式存儲。

6.  根據權利要求1所述的方法,其特征在于,所述當前待作業任務執行成功時對應的所述狀態碼為唯一的狀態碼;執行所述當前待作業任務時,若發生錯誤,發生錯誤的步驟不同,對應的狀態碼不同。

7.  一種批處理調度裝置,其特征在于,包括:
第一查找模塊,用于在批量作業參數信息中,查找當前待作業任務對應的機器地址和執行用戶;
第一控制模塊,用于遠程登錄到待作業機器,執行所述當前待作業任務的啟動腳本,控制所述當前待作業任務開始執行;所述待作業機器與所述機器地址和所述執行用戶相對應;
接收模塊,用于接收狀態碼;所述狀態碼由與所述待作業機器發送,表征所述當前待作業任務執行成功或者執行所述當前待作業任務時發生錯誤的步驟;
判斷模塊,用于判斷所述狀態碼是否表征所述當前待作業任務未執行成功,如果是,觸發第二控制模塊,如果否,觸發第三控制模塊;
第二控制模塊,用于:在所述批量作業參數信息中,查找與所述狀態碼相對應的錯誤處理作業任務;控制所述待作業機器執行所述錯誤處理作業任務;控制所述待作業機器從所述當前待作業任務中的預設步驟重新開始執行,所述預設步驟是與所述狀態碼相對應的步驟;依據重新接收到的狀態碼判斷所述當前待作業任務是否執行成功,如果是,觸發第三控制模塊,否則,繼執行本模塊功能;
第三控制模塊,用于在所述批量作業參數信息中,查找所述當前待作業任務之后的相鄰的作業任務,將所述當前待作業任務之后相鄰的作業任務確 定為新的當前待作業任務,觸發所述第一查找模塊,直至所述新的當前待作業任務為最后一個作業任務。

8.  根據權利要求7所述的裝置,其特征在于,還包括:
獲取模塊,用于獲取并存儲工作人員輸入的所述批量作業參數信息。

9.  根據權利要求7所述的裝置,其特征在于,所述批量作業參數信息包括:
作業任務名稱、作業任務執行的機器地址、作業任務執行的用戶、作業任務開始執行的時間、前置作業任務、后置作業任務、作業任務啟動腳本、狀態碼和錯誤處理作業任務。

10.  根據權利要求9所述的裝置,其特征在于,所述批量作業參數信息以批量作業參數表的形式存儲。

11.  根據權利要求10所述的裝置,其特征在于,所述作業任務名稱、所述狀態碼和所述錯誤處理作業任務以狀態碼子表的方式存儲。

12.  根據權利要求7所述的裝置,其特征在于,所述當前待作業任務執行成功時,所述接收模塊接收到的狀態碼為唯一的狀態碼;所述當前待作業任務執行過程中發生錯誤時,所述接收模塊接收到的狀態碼隨發生錯誤的步驟不同而不同。

13.  一種批處理調度系統,其特征在于,包括:
服務器和作業機器;
所述服務器用于,執行第一技術方案,所述第一技術方案包括:
在批量作業參數信息中,查找當前待作業任務對應的機器地址和執行用戶;
遠程登錄到待作業機器,執行所述當前待作業任務的啟動腳本,控制所述當前待作業任務開始執行;所述待作業機器與所述機器地址和所述執行用戶相對應;
接收狀態碼;所述狀態碼由與所述待作業機器發送,表征所述當前待作業任務執行成功或者執行所述當前待作業任務時發生錯誤的步驟;
判斷所述狀態碼是否表征所述當前待作業任務未執行成功,如果是,執行第二技術方案,如果否,執行第三技術方案;
所述第二技術方案包括:
在所述批量作業參數信息中,查找與所述狀態碼相對應的錯誤處理作業任務;控制所述待作業機器執行所述錯誤處理作業任務;控制所述待作業機器從所述當前待作業任務中的預設步驟重新開始執行,所述預設步驟是與所述狀態碼相對應的步驟;依據重新接收到的狀態碼判斷所述當前待作業任務是否執行成功,如果是,執行所述第三技術方案,如果否,繼續執行所述第二技術方案;
所述第三技術方案包括:
在所述批量作業參數信息中,查找所述當前待作業任務之后的相鄰的作業任務,將所述當前待作業任務之后相鄰的作業任務確定為新的當前待作業任務,重新執行所述第一技術方案,直至所述當前待作業任務為最后一個作業任務。

說明書

說明書批處理調度方法、裝置和系統
技術領域
本發明涉及計算機技術領域,尤其涉及一種批處理調度方法、裝置和系統。
背景技術
在信息系統中,日終批處理是很多系統必不可少的一個環節,并且批處理的準確性和時效性要求非常高。為了不影響次日的正常營業,每天必須在有限的時間里處理完系統的所有批處理作業。并且對于復雜的系統,上百個批處理作業之間有著很強的邏輯關聯,相互依賴,前置作業執行完成,后繼作業才能開始執行。
現有的日終批處理調度方法比較簡單,比如作業1和作業2存在著依賴關系,只有作業1成功結束,返回成功狀態后,作業2才能正常調起。如果作業1執行過程中發生異常并且執行失敗了,調度就會停止,需要通過人工介入來解決錯誤,然后重新調起作業1,待作業1返回成功狀態,作業2被調起開始執行。
但是,現有的批處理調度方法存在的一個最大的問題就是:當作業出現異常,執行失敗后,必須人工干預。首先,對時效性要求較高的系統來說,為保證次日正常營業,留給工作人員分析解決錯誤,并重新調起作業的時間是有限的,另外,受限于值班人員對功能的熟悉程度,不一定能很快地解決錯誤,這樣,便可能造成人工干預無法及時解決作業執行過程中出現的錯誤,從而影響信息系統后續(比如次日)的正常運行,使得信息系統的安全性以及信息系統用戶的經濟效益都可能隨之受到不良影響。
發明內容
有鑒于此,本發明提供了一種批處理調度方法、裝置和系統,在作業執行失敗時,能夠自動執行錯誤處理作業來排除錯誤,響應時間很快,因此效率很高,從而有效的保障批處理工作及時、順利的完成。
為實現上述目的,本發明提供如下技術方案:
一種批處理調度方法,包括:
執行第一技術方案,所述第一技術方案包括:
在批量作業參數信息中,查找當前待作業任務對應的機器地址和執行用戶;
遠程登錄到待作業機器,執行所述當前待作業任務的啟動腳本,控制所述當前待作業任務開始執行;所述待作業機器與所述機器地址和所述執行用戶相對應;
接收狀態碼;所述狀態碼由與所述待作業機器發送,表征所述當前待作業任務執行成功或者執行所述當前待作業任務時發生錯誤的步驟;
判斷所述狀態碼是否表征所述當前待作業任務未執行成功,如果是,執行第二技術方案,如果否,執行第三技術方案;
所述第二技術方案包括:
在所述批量作業參數信息中,查找與所述狀態碼相對應的錯誤處理作業任務;控制所述待作業機器執行所述錯誤處理作業任務;控制所述待作業機器從所述當前待作業任務中的預設步驟重新開始執行,所述預設步驟是與所述狀態碼相對應的步驟;依據重新接收到的狀態碼判斷所述當前待作業任務是否執行成功,如果是,執行所述第三技術方案,如果否,繼續執行所述第二技術方案;
所述第三技術方案包括:
在所述批量作業參數信息中,查找所述當前待作業任務之后的相鄰的作業任務,將所述當前待作業任務之后相鄰的作業任務確定為新的當前待作業任務,重新執行所述第一技術方案,直至所述當前待作業任務為最后一個作業任務。
優選的,所述在批量作業參數信息中,查找當前待作業任務對應的機器地址和執行用戶之前,還包括:
獲取并存儲工作人員輸入的所述批量作業參數信息。
優選的,所述批量作業參數信息包括:
作業任務名稱、作業任務執行的機器地址、作業任務執行的用戶、作業任務開始執行的時間、前置作業任務、后置作業任務、作業任務啟動腳本、狀態碼和錯誤處理作業任務。
優選的,所述批量作業參數信息以批量作業參數表的形式存儲。
優選的,所述作業任務名稱、所述狀態碼和所述錯誤處理作業任務以狀態碼子表的方式存儲。
優選的,所述當前待作業任務執行成功時對應的所述狀態碼為唯一的狀態碼;執行所述當前待作業任務時,若發生錯誤,發生錯誤的步驟不同,對應的狀態碼不同。
一種批處理調度裝置,包括:
第一查找模塊,用于在批量作業參數信息中,查找當前待作業任務對應的機器地址和執行用戶;
第一控制模塊,用于遠程登錄到待作業機器,執行所述當前待作業任務的啟動腳本,控制所述當前待作業任務開始執行;所述待作業機器與所述機器地址和所述執行用戶相對應;
接收模塊,用于接收狀態碼;所述狀態碼由與所述待作業機器發送,表征所述當前待作業任務執行成功或者執行所述當前待作業任務時發生錯誤的步驟;
判斷模塊,用于判斷所述狀態碼是否表征所述當前待作業任務未執行成功,如果是,觸發第二控制模塊,如果否,觸發第三控制模塊;
第二控制模塊,用于:在所述批量作業參數信息中,查找與所述狀態碼相對應的錯誤處理作業任務;控制所述待作業機器執行所述錯誤處理作業任務;控制所述待作業機器從所述當前待作業任務中的預設步驟重新開始執行,所述預設步驟是與所述狀態碼相對應的步驟;依據重新接收到的狀態碼判斷所述當前待作業任務是否執行成功,如果是,觸發第三控制模塊,否則,繼執行本模塊功能;
第三控制模塊,用于在所述批量作業參數信息中,查找所述當前待作業任務之后的相鄰的作業任務,將所述當前待作業任務之后相鄰的作業任務確定為新的當前待作業任務,觸發所述第一查找模塊,直至所述新的當前待作業任務為最后一個作業任務。
優選的,還包括:
獲取模塊,用于獲取并存儲工作人員輸入的所述批量作業參數信息。
優選的,所述批量作業參數信息包括:
作業任務名稱、作業任務執行的機器地址、作業任務執行的用戶、作業任務開始執行的時間、前置作業任務、后置作業任務、作業任務啟動腳本、狀態碼和錯誤處理作業任務。
優選的,所述批量作業參數信息以批量作業參數表的形式存儲。
優選的,所述作業任務名稱、所述狀態碼和所述錯誤處理作業任務以狀態碼子表的方式存儲。
優選的,所述當前待作業任務執行成功時,所述接收模塊接收到的狀態碼為唯一的狀態碼;所述當前待作業任務執行過程中發生錯誤時,所述接收模塊接收到的狀態碼隨發生錯誤的步驟不同而不同。
一種批處理調度系統,包括:
服務器和作業機器;
所述服務器用于,執行第一技術方案,所述第一技術方案包括:
在批量作業參數信息中,查找當前待作業任務對應的機器地址和執行用戶;
遠程登錄到待作業機器,執行所述當前待作業任務的啟動腳本,控制所述當前待作業任務開始執行;所述待作業機器與所述機器地址和所述執行用戶相對應;
接收狀態碼;所述狀態碼由與所述待作業機器發送,表征所述當前待作業任務執行成功或者執行所述當前待作業任務時發生錯誤的步驟;
判斷所述狀態碼是否表征所述當前待作業任務未執行成功,如果是,執行第二技術方案,如果否,執行第三技術方案;
所述第二技術方案包括:
在所述批量作業參數信息中,查找與所述狀態碼相對應的錯誤處理作業任務;控制所述待作業機器執行所述錯誤處理作業任務;控制所述待作業機器從所述當前待作業任務中的預設步驟重新開始執行,所述預設步驟是與所述狀態碼相對應的步驟;依據重新接收到的狀態碼判斷所述當前待作業任務是否執行成功,如果是,執行所述第三技術方案,如果否,繼續執行所述第二技術方案;
所述第三技術方案包括:
在所述批量作業參數信息中,查找所述當前待作業任務之后的相鄰的作業任務,將所述當前待作業任務之后相鄰的作業任務確定為新的當前待作業任務,重新執行所述第一技術方案,直至所述當前待作業任務為最后一個作業任務。
經由上述的技術方案可知,與現有技術相比,本發明提供了一種批處理調度方法、裝置和系統。本發明提供的批處理調度方法,包括:執行第一技術方案,所述第一技術方案包括:在批量作業參數信息中,查找當前待作業任務對應的機器地址和執行用戶;遠程登錄到待作業機器,執行所述當前待作業任務的啟動腳本,控制所述當前待作業任務開始執行;所述待作業機器與所述機器地址和所述執行用戶相對應;接收狀態碼;所述狀態碼由與所述待作業機器發送,表征所述當前待作業任務執行成功或者執行所述當前待作業任務時發生錯誤的步驟;判斷所述狀態碼是否表征所述當前待作業任務未執行成功,如果是,執行第二技術方案,如果否,執行第三技術方案;所述第二技術方案包括:在所述批量作業參數信息中,查找與所述狀態碼相對應的錯誤處理作業任務;控制所述待作業機器執行所述錯誤處理作業任務;控制所述待作業機器從所述當前待作業任務中的預設步驟重新開始執行,所述預設步驟是與所述狀態碼相對應的步驟;依據重新接收到的狀態碼判斷所述當前待作業任務是否執行成功,如果是,執行所述第三技術方案,如果否,繼續執行所述第二技術方案;所述第三技術方案包括:在所述批量作業參數信息中,查找所述當前待作業任務之后的相鄰的作業任務,將所述當前待作業任務之后相鄰的作業任務確定為新的當前待作業任務,重新執行所述第一技術方案,直至所述當前待作業任務為最后一個作業任務。即,本發明提供 的技術方案,在批處理過程中,如果某個批處理作業執行失敗,即發生錯誤,會自動執行錯誤處理作業用以排除錯誤,錯誤排除后,自動從該批處理作業發生錯誤的步驟繼續執行該批處理作業,直至該批處理作業執行成功,然后再開始執行下一個批處理作業,直至全部批處理作業成功執行完成。因此,本發明提供的技術方案,在作業執行失敗時,一般不再需要人工干預來分析和解決錯誤,能夠執行錯誤處理作業來自動排除錯誤,響應時間很快,因此效率很高,從而有效的保障批處理工作及時、順利的完成,從而保障信息系統后續(比如次日)的正常運行,使得信息系統的安全性以及信息系統用戶的經濟效益避免因人工干預不力(即人工干預未能及時、有效地解決作業執行時出現的錯誤)所造成的不良影響。
附圖說明
為了更清楚地說明本發明實施例或現有技術中的技術方案,下面將對實施例或現有技術描述中所需要使用的附圖作簡單地介紹,顯而易見地,下面描述中的附圖僅僅是本發明的實施例,對于本領域普通技術人員來講,在不付出創造性勞動的前提下,還可以根據提供的附圖獲得其他的附圖。
圖1為本發明實施例提供的一種批處理調度方法的流程圖;
圖2為本發明實施例提供的一種批處理調度裝置的結構圖;
圖3為本發明實施例提供的一種批處理調度系統的結構圖。
具體實施方式
下面將結合本發明實施例中的附圖,對本發明實施例中的技術方案進行清楚、完整地描述,顯然,所描述的實施例僅僅是本發明一部分實施例,而不是全部的實施例。基于本發明中的實施例,本領域普通技術人員在沒有做出創造性勞動前提下所獲得的所有其他實施例,都屬于本發明保護的范圍。
為使本發明的上述目的、特征和優點能夠更加明顯易懂,下面結合附圖和具體實施方式對本發明作進一步詳細的說明。
實施例
請參閱圖1,圖1為本發明實施例提供的一種批處理調度方法的流程圖。如圖1所示,該方法包括:
步驟S101,在批量作業參數信息中,查找當前待作業任務對應的機器地址和執行用戶;
可選的,所述批量作業參數信息,包括:
作業任務名稱、作業任務執行的機器地址、作業任務執行的用戶、作業任務開始執行的時間、前置作業任務、后置作業任務、作業任務啟動腳本、狀態碼和錯誤處理作業任務。
可選的,所述批量作業參數信息以批量作業參數表的形式存儲,其中,所述作業任務名稱、所述狀態碼和所述錯誤處理作業任務以狀態碼子表的方式存儲。
步驟S102,遠程登錄到待作業機器,執行所述當前待作業任務的啟動腳本,控制所述當前待作業任務開始執行;
具體的,所述待作業機器與所述機器地址和所述執行用戶相對應,即,所述待作業機器是與所述機器地址和所述執行用戶相對應的作業機器。
步驟S103,接收狀態碼;
具體的,所述狀態碼由與所述待作業機器發送,表征所述當前待作業任務執行成功或者執行所述當前待作業任務時發生錯誤的步驟。也就是說,所述批量作業參數信息中的狀態碼,包括所述當前待作業任務執行成功時對應的狀態碼,以及執行所述當前待作業任務過程中每個步驟發生錯誤時對應的狀態碼。可選的,各作業任務包括多個步驟;每個步驟為獨立的最小步驟,包括具有相關性和先后順序的指令。
具體的,所述當前待作業任務執行成功時對應的所述狀態碼為唯一的狀態碼;執行所述當前待作業任務時,若發生錯誤,發生錯誤的步驟不同,發生錯誤的步驟所對應的狀態碼也相應的不同。
步驟S104,判斷所述狀態碼是否表征所述當前待作業任務未執行成功,如果是,執行步驟S105~S107,如果否,執行步驟S108;
步驟S105,在所述批量作業參數信息中,查找與所述狀態碼相對應的錯誤處理作業任務;
步驟S106,控制所述待作業機器執行所述錯誤處理作業任務,控制所述待作業機器從所述當前待作業任務中的預設步驟重新開始執行;
具體的,所述錯誤處理作業任務完成后,控制所述待作業機器從所述當前待作業任務中的預設步驟開始執行。所述預設步驟是與所述狀態碼相對應的步驟,也就是說,所述預設步驟是所述狀態碼所對應的、執行所述當前待作業任務時出現錯誤的步驟。
步驟S107,依據重新接收到的狀態碼判斷所述當前待作業任務是否執行成功;若所述當前待作業任務執行成功,執行步驟S108,否則,重新執行所述步驟S105~所述步驟S107。
具體的,重新執行步驟S105和步驟S106時,步驟S105和步驟S106中涉及到的所述狀態碼變更為所述步驟S107重新接收到的狀態碼。
步驟S108,在所述批量作業參數信息中,查找所述當前待作業任務之后的相鄰的作業任務,將所述當前待作業任務之后相鄰的作業任務確定為新的當前待作業任務,重新執行所述步驟S101~所述步驟S107,直至所述當前待作業任務為最后一個作業任務。
具體的,查找的是所述當前待作業任務之后,與所述當前待作業任務相鄰的作業任務。比如,按照邏輯需要依次執行A作業任務、B作業任務、C作業任務和D作業任務,若所述當前待作業任務為A作業任務,那么查找到的所述當前待作業任務(即A作業任務)之后的相鄰的作業任務,為B作業任務。
本發明實施例提供的批處理調度方法,包括:執行第一技術方案,所述第一技術方案包括:在批量作業參數信息中,查找當前待作業任務對應的機器地址和執行用戶;遠程登錄到待作業機器,執行所述當前待作業任務的啟動腳本,控制所述當前待作業任務開始執行;所述待作業機器與所述機器地址和所述執行用戶相對應;接收狀態碼;所述狀態碼由與所述待作業機器發送,表征所述當前待作業任務執行成功或者執行所述當前待作業任務時發生錯誤的步驟;判斷所述狀態碼是否表征所述當前待作業任務未執行成功,如果是,執行第二技術方案,如果否,執行第三技術方案;所述第二技術方案包括:在所述批量作業參數信息中,查找與所述狀態碼相對應的錯誤處理作業任務;控制所述待作業機器執行所述錯誤處理作業任務;控制所述待作業 機器從所述當前待作業任務中的預設步驟重新開始執行,所述預設步驟是與所述狀態碼相對應的步驟;依據重新接收到的狀態碼判斷所述當前待作業任務是否執行成功,如果是,執行所述第三技術方案,如果否,繼續執行所述第二技術方案;所述第三技術方案包括:在所述批量作業參數信息中,查找所述當前待作業任務之后的相鄰的作業任務,將所述當前待作業任務之后相鄰的作業任務確定為新的當前待作業任務,重新執行所述第一技術方案,直至所述當前待作業任務為最后一個作業任務。即,本發明提供的技術方案,在批處理過程中,如果某個批處理作業執行失敗,即發生錯誤,會自動執行錯誤處理作業用以排除錯誤,錯誤排除后,自動從該批處理作業發生錯誤的步驟繼續執行該批處理作業,直至該批處理作業執行成功,然后再開始執行下一個批處理作業,直至全部批處理作業成功執行完成。因此,本發明提供的技術方案,在作業執行失敗時,一般不再需要人工干預來分析和解決錯誤,能夠執行錯誤處理作業來自動排除錯誤,響應時間很快,因此效率很高,從而有效的保障批處理工作及時、順利的完成,從而保障信息系統后續(比如次日)的正常運行,使得信息系統的安全性以及信息系統用戶的經濟效益避免因人工干預不力(即人工干預未能及時、有效地解決作業執行時出現的錯誤)所造成的不良影響。
另外,現有的人工干預排除錯誤的方式,由于不同運維人員對錯誤的認知程度和解決問題的思路都是不一樣的,處理錯誤的過程中都可能給系統帶來風險。即,對錯誤的處理沒有固定的模式,不同的運維人員有不同的方案,而且這些方案在信息系統設計開發的周期中一般都不會考慮,缺少足夠的驗證,因此,一個信息系統上線運行后,應該是穩定的運行,盡可能的減少人工干預的可能性。鑒于批處理的特殊性,作業任務執行時出現錯誤是難以避免的,但每個批處理作業可能出現的錯誤或異常的地方都是可以通過分析代碼羅列出來的。因此,本發明的目的就是減少人工干預的可能性,本發明實施例提供的技術方案,充分考慮可能出現的錯誤或異常,并對每種錯誤或異常設置對應的錯誤處理作業任務(即解決方案),在系統測試過程中,可以對這些錯誤處理作業任務進行充分的測試,保證可靠性。通過上述論述可以確定,本發明實施例提供的技術方案,在作業執行出現錯誤時,一般可自動 進行錯誤處理,不需要人工干預,也就能夠避免現有技術中通過人工干預來處理錯誤的方式給信息系統帶來的風險。
另外,可以理解的是,本發明實施例提供的技術方案,由于在作業執行出現錯誤時,一般可自動進行錯誤處理,不需要人工干預,因此,可以降低人力成本。
另外,本發明實施例提供的技術方案,每個作業任務具體細化為多個最小步驟,在執行作業任務過程中若出現錯誤,執行錯誤處理,然后從出現錯誤的最小步驟重新開始執行,不需要再執行之前的其它步驟,因此,能夠縮短該作業任務執行成功的時間,最終能夠縮短整個批處理執行完成所需要的時間,效率比較高。另外,由于每個最小步驟執行的功能較少,本發明針對每個最小步驟執行時發生錯誤的解決方案(即錯誤處理任務)也更具有針對性,使得準確性更高,最終使得本發明實施例提供的技術方案,可靠性比較高。
此外,在本發明另一實施例中,所述步驟S101之前,還包括:
獲取并存儲工作人員輸入的所述批量作業參數信息。
可以理解的是,需要提前獲取到工作人員輸入的所述批量作業參數信息,以備后續步驟使用。
為了更加全面地闡述本發明提供的技術方案,對應于本發明實施例提供的批處理調度方法,本發明公開一種批處理調度裝置。
請參閱圖2,圖2為本發明實施例提供的一種批處理調度裝置的結構圖。如圖2所示,該裝置包括:
第一查找模塊201,用于在批量作業參數信息中,查找當前待作業任務對應的機器地址和執行用戶;
第一控制模塊202,用于遠程登錄到待作業機器,執行所述當前待作業任務的啟動腳本,控制所述當前待作業任務開始執行;所述待作業機器與所述機器地址和所述執行用戶相對應;
接收模塊203,用于接收狀態碼;所述狀態碼由與所述待作業機器發送,表征所述當前待作業任務執行成功或者執行所述當前待作業任務時發生錯誤的步驟;
判斷模塊204,用于判斷所述狀態碼是否表征所述當前待作業任務未執行成功,如果是,觸發第二控制模塊,如果否,觸發第三控制模塊;
第二控制模塊205,用于:在所述批量作業參數信息中,查找與所述狀態碼相對應的錯誤處理作業任務;控制所述待作業機器執行所述錯誤處理作業任務;控制所述待作業機器從所述當前待作業任務中的預設步驟重新開始執行,所述預設步驟是與所述狀態碼相對應的步驟;依據重新接收到的狀態碼判斷所述當前待作業任務是否執行成功,如果是,觸發第三控制模塊,否則,繼執行本模塊功能;
第三控制模塊206,用于在所述批量作業參數信息中,查找所述當前待作業任務之后的相鄰的作業任務,將所述當前待作業任務之后相鄰的作業任務確定為新的當前待作業任務,觸發所述第一查找模塊,直至所述新的當前待作業任務為最后一個作業任務。
具體的,所述批量作業參數信息包括:
作業任務名稱、作業任務執行的機器地址、作業任務執行的用戶、作業任務開始執行的時間、前置作業任務、后置作業任務、作業任務啟動腳本、狀態碼和錯誤處理作業任務。
可選的,所述批量作業參數信息以批量作業參數表的形式存儲,其中,所述作業任務名稱、所述狀態碼和所述錯誤處理作業任務以狀態碼子表的方式存儲。
具體的,所述當前待作業任務執行成功時,所述接收模塊接收到的狀態碼為唯一的狀態碼;所述當前待作業任務執行過程中發生錯誤時,所述接收模塊接收到的狀態碼隨發生錯誤的步驟不同而不同。
本發明實施例提供的批處理調度裝置,在批處理過程中,如果某個批處理作業執行失敗,即發生錯誤,會自動執行錯誤處理作業用以排除錯誤,錯誤排除后,自動從該批處理作業發生錯誤的步驟繼續執行該批處理作業,直至該批處理作業執行成功,然后再開始執行下一個批處理作業,直至全部批處理作業成功執行完成。因此,本發明提供的批處理調度裝置,在作業執行 失敗時,一般不再需要人工干預來分析和解決錯誤,能夠執行錯誤處理作業來自動排除錯誤,響應時間很快,因此效率很高,從而有效的保障批處理工作及時、順利的完成,從而保障信息系統后續(比如次日)的正常運行,使得信息系統的安全性以及信息系統用戶的經濟效益避免因人工干預不力(即人工干預未能及時、有效地解決作業執行時出現的錯誤)所造成的不良影響。
可選的,本發明另外一個實施例公開的批處理調度裝置,還包括:
獲取模塊,用于獲取并存儲工作人員輸入的所述批量作業參數信息。
對應于本發明實施例提供的批處理調度方法,本發明公開一種批處理調度系統。
請參閱圖3,圖3為本發明實施例提供的一種批處理調度系統的結構圖。如圖3所示,該系統包括:
服務器301和作業機器302;
所述服務器301用于,執行第一技術方案,所述第一技術方案包括:
在批量作業參數信息中,查找當前待作業任務對應的機器地址和執行用戶;
遠程登錄到待作業機器,執行所述當前待作業任務的啟動腳本,控制所述當前待作業任務開始執行;所述待作業機器與所述機器地址和所述執行用戶相對應;
接收狀態碼;所述狀態碼由與所述待作業機器發送,表征所述當前待作業任務執行成功或者執行所述當前待作業任務時發生錯誤的步驟;
判斷所述狀態碼是否表征所述當前待作業任務未執行成功,如果是,執行第二技術方案,如果否,執行第三技術方案;
所述第二技術方案包括:
在所述批量作業參數信息中,查找與所述狀態碼相對應的錯誤處理作業任務;控制所述待作業機器執行所述錯誤處理作業任務;控制所述待作業機器從所述當前待作業任務中的預設步驟重新開始執行,所述預設步驟是與所述狀態碼相對應的步驟;依據重新接收到的狀態碼判斷所述當前待作業任務 是否執行成功,如果是,執行所述第三技術方案,如果否,繼續執行所述第二技術方案;
所述第三技術方案包括:
在所述批量作業參數信息中,查找所述當前待作業任務之后的相鄰的作業任務,將所述當前待作業任務之后相鄰的作業任務確定為新的當前待作業任務,重新執行所述第一技術方案,直至所述當前待作業任務為最后一個作業任務。
可選的,所述服務器301和作業機器302為計算機。
需要說明的是,本發明實施例提供的技術方案,可以應用在需要批處理作業的信息系統中,比如銀行的信息系統。
經由上述的技術方案可知,與現有技術相比,本發明提供了一種批處理調度方法、裝置和系統。本發明提供的批處理調度方法,包括:執行第一技術方案,所述第一技術方案包括:在批量作業參數信息中,查找當前待作業任務對應的機器地址和執行用戶;遠程登錄到待作業機器,執行所述當前待作業任務的啟動腳本,控制所述當前待作業任務開始執行;所述待作業機器與所述機器地址和所述執行用戶相對應;接收狀態碼;所述狀態碼由與所述待作業機器發送,表征所述當前待作業任務執行成功或者執行所述當前待作業任務時發生錯誤的步驟;判斷所述狀態碼是否表征所述當前待作業任務未執行成功,如果是,執行第二技術方案,如果否,執行第三技術方案;所述第二技術方案包括:在所述批量作業參數信息中,查找與所述狀態碼相對應的錯誤處理作業任務;控制所述待作業機器執行所述錯誤處理作業任務;控制所述待作業機器從所述當前待作業任務中的預設步驟重新開始執行,所述預設步驟是與所述狀態碼相對應的步驟;依據重新接收到的狀態碼判斷所述當前待作業任務是否執行成功,如果是,執行所述第三技術方案,如果否,繼續執行所述第二技術方案;所述第三技術方案包括:在所述批量作業參數信息中,查找所述當前待作業任務之后的相鄰的作業任務,將所述當前待作業任務之后相鄰的作業任務確定為新的當前待作業任務,重新執行所述第一技術方案,直至所述當前待作業任務為最后一個作業任務。即,本發明提供的技術方案,在批處理過程中,如果某個批處理作業執行失敗,即發生錯誤, 會自動執行錯誤處理作業用以排除錯誤,錯誤排除后,自動從該批處理作業發生錯誤的步驟繼續執行該批處理作業,直至該批處理作業執行成功,然后再開始執行下一個批處理作業,直至全部批處理作業成功執行完成。因此,本發明提供的技術方案,在作業執行失敗時,一般不再需要人工干預來分析和解決錯誤,能夠執行錯誤處理作業來自動排除錯誤,響應時間很快,因此效率很高,從而有效的保障批處理工作及時、順利的完成,從而保障信息系統后續(比如次日)的正常運行,使得信息系統的安全性以及信息系統用戶的經濟效益避免因人工干預不力(即人工干預未能及時、有效地解決作業執行時出現的錯誤)所造成的不良影響。
最后,還需要說明的是,在本文中,諸如第一和第二等之類的關系術語僅僅用來將一個實體或者操作與另一個實體或操作區分開來,而不一定要求或者暗示這些實體或操作之間存在任何這種實際的關系或者順序。而且,術語“包括”、“包含”或者其任何其他變體意在涵蓋非排他性的包含,從而使得包括一系列要素的過程、方法、物品或者設備不僅包括那些要素,而且還包括沒有明確列出的其他要素,或者是還包括為這種過程、方法、物品或者設備所固有的要素。在沒有更多限制的情況下,由語句“包括一個……”限定的要素,并不排除在包括所述要素的過程、方法、物品或者設備中還存在另外的相同要素。
本說明書中各個實施例采用遞進的方式描述,每個實施例重點說明的都是與其他實施例的不同之處,各個實施例之間相同相似部分互相參見即可。對于實施例公開的批處理調度裝置和系統而言,由于其與實施例公開的批處理調度方法相對應,所以描述的比較簡單,相關之處參見方法部分說明即可。
結合本文中所公開的實施例描述的方法或算法的步驟可以直接用硬件、處理器執行的軟件模塊,或者二者的結合來實施。軟件模塊可以置于隨機存儲器(RAM)、內存、只讀存儲器(ROM)、電可編程ROM、電可擦除可編程ROM、寄存器、硬盤、可移動磁盤、CD-ROM、或技術領域內所公知的任意其它形式的存儲介質中。
對所公開的實施例的上述說明,使本領域專業技術人員能夠實現或使用 本發明。對這些實施例的多種修改對本領域的專業技術人員來說將是顯而易見的,本文中所定義的一般原理可以在不脫離本發明的精神或范圍的情況下,在其它實施例中實現。因此,本發明將不會被限制于本文所示的這些實施例,而是要符合與本文所公開的原理和新穎特點相一致的最寬的范圍。

關 鍵 詞:
批處理 調度 方法 裝置 系統
  專利查詢網所有資源均是用戶自行上傳分享,僅供網友學習交流,未經上傳用戶書面授權,請勿作他用。
關于本文
本文標題:批處理調度方法、裝置和系統.pdf
鏈接地址:http://www.wwszu.club/p-6405595.html
關于我們 - 網站聲明 - 網站地圖 - 資源地圖 - 友情鏈接 - 網站客服客服 - 聯系我們

[email protected] 2017-2018 zhuanlichaxun.net網站版權所有
經營許可證編號:粵ICP備17046363號-1 
 


收起
展開
鬼佬大哥大