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 条评论
下一页