应急数据贯通上报流程
2022-04-25 18:34:04 1 举报数据贯通
作者其他创作
大纲/内容
数据集类型是否是SQL
是
获取所有未执行作业
否
更新发布侧操作日志表
任务结束
服务数据上报任务启动
pi600 task任务调度
创建异步线程，提交线城池
遍历发送报文
获取作业关联的所有步骤
记录异常信息且重试次数+1
是否发送成功
发送报文
20条一批捞取异常报文，状态未处理且重试测试小于3此
PI6000 TASK
步骤是否为空
开始
是否推送成功
应急数据上报任务
是否更新抢占成功
根据SQL和变量名替换生成抽取SQL
是否遍历完所有步骤
异常报文补发任务
是否取到报文
步骤处理异步线程
更新表最大值
保存报文发送异常表
遍历获取一条步骤
异步线城结束
是否能查询到数据
线程池执行
更新作业状态已经TASK字段
数据上报任务主线程
报文补发任务启动
500一批分页查询数据
遍历获取一条作业
按照作业更新时间升序，未执行的优先强张
根据表、过滤条件、字段名称生成抽取SQL
生成报文
同步阻塞，所有异步线城处理完，还原作业任务信息
0 条评论
下一页
