DatastageRoutine示例提取JOB錯(cuò)誤信息錄入到數(shù)據(jù)庫

1、datastage routine示例使用routine提取job錯(cuò)誤信息錄入數(shù)據(jù)庫環(huán)境：red hat linux as 4 + datastage ee + oracle 10g#在此感謝一下金證科技的li bin和wang jun，是他們帶我學(xué)習(xí)datastage的！目標(biāo)：使用routine將job運(yùn)行后的錯(cuò)誤信息錄入數(shù)據(jù)庫（暫時(shí)忽略警告信息）方案：server routine調(diào)用shell腳本，shell腳本調(diào)用存儲(chǔ)過程，存儲(chǔ)過程把傳遞的參數(shù)信息寫入數(shù)據(jù)庫表實(shí)現(xiàn)過程：1.創(chuàng)建server routine，命名dsjoblog，系統(tǒng)默認(rèn)dsj開頭的routine為內(nèi)置(built-in)

2、routine,類型為before/after subroutine2.編寫routine的code，代碼及注釋如下：*routine名稱：dsjoblog*routine類型：server subroutine *routine功能：提取job運(yùn)行后的錯(cuò)誤日志并寫入數(shù)據(jù)庫*routine輸入?yún)?shù)1：inputarg *routine返回參數(shù)1：errorcode*routine作者：wangfei ()*routine日期： *$include dsinclude *設(shè)定返回值errorcode = 0*設(shè)定當(dāng)前運(yùn)行的jobjobhandle = *設(shè)定變量cmdstr,存儲(chǔ)shell命令及

3、參數(shù)cmdstr= sh /home/dsadm/edcetl/sh/para/ * 如果狀態(tài)為失敗，則產(chǎn)生錯(cuò)誤日志*設(shè)定變量loglist并初始化，存儲(chǔ)joblog信息 loglist =*判斷運(yùn)行subroutine前job的執(zhí)行狀態(tài)*如果產(chǎn)生錯(cuò)誤(代碼為3)，則將error信息存儲(chǔ)于動(dòng)態(tài)數(shù)組summary中(1為info,2為warn,3為fatal) if dsgetjobinfo(jobhandle, = 3 then summary=dsgetlogsummary(jobhandle , , dsgetjobinfo(jobhandle, dsgetjobinfo(jobhandl

4、e, 10)*通過循環(huán)先取到錯(cuò)誤事件的id(evtid),然后依據(jù)evtid獲得錯(cuò)誤信息 *循環(huán)開始 for i=1 to 10 evtid = field(summary,1) if evtid = then exit end loglist =loglist : dsgetlogentry(jobhandle ,evtid):zhongtu next i *循環(huán)結(jié)束 end*如果狀態(tài)為失敗，則產(chǎn)生錯(cuò)誤日志*開始拼接shell命令的參數(shù)*char(34)在vb中是雙引號(hào)，這里必須添加雙引號(hào)以便shell腳本能夠正確的把帶單引號(hào)的參數(shù)傳遞給存儲(chǔ)過程cmdstr=cmdstr:char(34)

5、:dsgetjobinfo(jobhandle,:char(34): cmdstr=cmdstr:char(34) :dsgetjobinfo(jobhandle,:char(34): cmdstr=cmdstr:char(34) :dsgetjobinfo(jobhandle,:char(34): cmdstr=cmdstr:char(34) :dsgetjobinfo(jobhandle,:char(34): cmdstr=cmdstr:1: cmdstr=cmdstr:char(34) :loglist:char(34)*結(jié)束拼接shell命令的參數(shù)*執(zhí)行shell腳本call dsex

6、ecute(unix, cmdstr, ans, systemreturncode)3.其他標(biāo)簽頁的內(nèi)容默認(rèn)即可，保存并編譯！4.在job中調(diào)用該routine，打開一個(gè)job，在job屬性中選擇routine即可。系統(tǒng)下編寫shell腳本，命名，腳本代碼如下：#*# 程序名： # 執(zhí)行環(huán)境： /home/dsadm/edcetl/sh目錄下# 程序描述： 調(diào)用存儲(chǔ)過程將job日志信息寫到數(shù)據(jù)庫中# 輸入?yún)?shù)： # 輸出參數(shù)： # 編寫人員： wangfei()# 創(chuàng)建日期： # 代碼版本： #*if $# -ne 6 then exit 2fi#參數(shù)文件、日志文件、臨時(shí)文件存放路徑parap

7、ath=/home/dsadm/edcetl/sh/para#參數(shù)文件etlcfg=$parapath/#獲取控制etl運(yùn)行的數(shù)據(jù)庫服務(wù)器信息dbname=$(awk -f= /dbname_ctl/print $2 $etlcfg)dbusr=$(awk -f= /dbusr_ctl/print $2 $etlcfg)dbpwd=$(awk -f= /dbpwd_ctl/print $2 $etlcfg)value=sqlplus -s end set pagesize 0 feedback off verify off heading off echo off call sp_gen_etl_