exec_batch
2018-03-22 10:36:59 0 举报登录查看完整内容
ETL批次调度流程图
作者其他创作
大纲/内容
开始
是
此段与exec_batch.py脚本的main（）函数对应
notsync_job_count == 0
获取notsync_job_count
设置批次状态为0（执行完毕），end_time为当前时间，并设置下一次执行时间
单个主机running_job=10
获取batch_info
否
设置批次状态为1(正在执行)，start_time为当前时间
结束
此段与exec_batch.py脚本的runjob（）函数对应
for jobname in joblist
后台执行ctlrunjob()
当前批次执行是否成功
设置批次状态为3（有job尚未完成同步），end_time为当前时间，并设置下一次执行时间
设置批次状态为2（执行失败），end_time为当前时间，并设置下一次执行时间
此判断与exec_batch.py脚本的if_run（）函数对应
获取joblist
获取sysdate、etldate
for batch in batch_info
sysdateetldate
收藏
0 条评论
回复 删除
下一页
