平台监测
2022-01-05 18:15:36 2 举报
描述
作者其他创作
大纲/内容
否
结束
判断redis中是否记录上次超速时间
匹配规则区域
循环所有规则
判断redis中是否记录上次报警时间
提交kafka偏移量
判断超速持续时间是否超过规则时间
是
将本次报警时间记录在redis里
超时逻辑判断
调用线程池来批量处理本地线程里的所累计的kafka数据
夜间驾驶超时判断
删除redis里记录的上次超速时间
接收到kafka数据
线程开始处理
匹配规则车辆类型
将本次超速时间记录在redis里
数据封装，并存入本地线程
匹配规则监测时间
超速逻辑判断
当前时间减去上次时间大于10秒
推送报警到风险中心
查询当前时间生效的所有规则
线程结束
判断规则是否超速
当前车辆是否为空
判断报警间隔时间是否超过规则规定的报警间隔时间
0 条评论
回复 删除
下一页
