//获取变量,以下为python语法(option)
P_DAYS = 12
MSG = '------------------------------------------------------------'
report_time = datetime.datetime.now()- datetime.timedelta(days=int(P_DAYS))
P_START_ZYM= report_time.strftime('%Y%m')

//以下为JOB专署语法
#link  lastdag 30 3600        --每30秒轮询前置任务,超时1小时
#impala_sql  sqlfile1         --执行impala
#hive_sql    sqlfile2         --执行hive
#dataset     checkinfo  321   --数据查询,校验              --
#sp  sp1   report_time,MSG    --执行SP,传入参数
#ktr myktr   P_START_ZYM      --执行kettle ktr, 传入参数
#kjb mykjb   P_START_ZYM
#/kjb abc                     --当此job暂时不要时,可/注释

-- 分层标记,可折叠   //:
    #datax   jobabc   --备注
    #datax   jobabc   --备注

--以下为python语法(option)
//////////////
lastdag >> sqlfile1 >>  \
validate >> sp1 >> [myktr, mykjb]
lastdag >> sqlfile2