下发任务接口增加队列方式实现
2022-03-04 14:28:17 4 举报增加队列
作者其他创作
大纲/内容
doris创建临时表，根据BitMap SQL，insert into table，得到圈取的人数明细；生成对应的taskId，初始化任务状态，入表portrait_task_instance
Yes
接口正常返回任务，此时任务为初始化状态
下发人群包任务，生成对应的taskId（接口：/portrait/instance/callPPackTransmitTask表：portrait_task_instance）
No
队列表结构：create table portrait_request_queue ( uuid VARCHAR(50) PRIMARY KEY NOT NULL COMMENT \"uuid\
ppackId
下发任务，更新portrait_task_instance 表，状态置为已提交，接口正常返回
判断ppackId是否冻结
创建人群包策略，生成ppackId 和BitMap SQL（接口：/portrait/strategy/createPPackStrategy表：portrait_task_strategy）
任务不提交，进行排队等待（后续定时任务刷新任务是否成功或者最终失败，是则释放占用的队列量，即刷新current_queue_num，根据人群包数量降低值）
(当前的队列数量)current_queue_num <= max_queue_num（最大队列数量，默认10）
无法下发任务，接口返回异常
收藏
0 条评论
下一页
