公开(公告)号：CN115168659A

公开(公告)日：2022-10-11

申请号：CN202210845900.0

申请日：2022-07-19

Applicant: 公安部交通管理科学研究所

Inventor： 蔡岗 ,  赵磊 ,  黄淑兵 ,  魏亚宽 ,  孔晨晨 ,  张森 ,  施一珑

IPC: G06F16/901 ,  G06F16/9537 ,  G06F16/2455 ,  G06F16/25 ,  G06F9/46 ,  G08G1/01

Abstract: 本发明提供的一种基于Spark Streaming的快速实时预警方法，将待处理车辆轨迹数据按照车牌号码分别存储到不同的存储分区中，将所有实时监测事件分别建立一个实时比对线程thread，每次将待处理车辆轨迹数据同时送入到所有的实时比对线程thread中并行计算；同时，因为待处理车辆轨迹数据是按照车牌号码存储的，每次计算时，车缓存队列消费线程将数据送入存储分区对应的过车数据缓存队列中，在每个实时比对线程thread中，因为是按照需要比对的待处理车辆轨迹数据对应的车牌范围从基础数据库和嫌疑车辆黑名单中提取对应车牌号码范围的数据，所以数据对比查找的命中率会提高，极大的提高了系统的计算效率，同时每个thread中每次需要计算的数据量有限，进一步的提高了计算速度。

公开(公告)号：CN115063977B

公开(公告)日：2023-05-26

申请号：CN202210694906.2

申请日：2022-06-20

Applicant: 公安部交通管理科学研究所

Inventor： 姜鉴铎 ,  张森 ,  吴哲群 ,  魏亚宽 ,  施一珑 ,  孙瀚 ,  周云龙

IPC: G08G1/01 ,  G08G1/017

Abstract: 本发明提供的一种从单个出发地到多个目的地的车辆流向分析方法，根据设定的采集时间段、出发地、待分析区域，基于卡口监控设备获取车辆通行记录数据集；根据卡口备案信息中的卡口所在地区信息，将车辆通行记录数据集分为：出发地通行记录数据集和出发地外通行记录数据集，使用目标车辆在各地区最后一次被抓拍的时间进行比较，将时间早于出发地的通行记录数据删除，再删除异常数据，得到从单个出发地到多个目的地的目标车辆途经地通行记录，并以此获取通行详情数据，最后根据目的地对通行详情数据分组，得到从单个出发地到多个目的地的车辆流向分析结果。

公开(公告)号：CN115063977A

公开(公告)日：2022-09-16

申请号：CN202210694906.2

申请日：2022-06-20

Applicant: 公安部交通管理科学研究所

Inventor： 姜鉴铎 ,  张森 ,  吴哲群 ,  魏亚宽 ,  施一珑 ,  孙瀚 ,  周云龙

IPC: G08G1/01 ,  G08G1/017

Abstract: 本发明提供的一种从单个出发地到多个目的地的车辆流向分析方法，根据设定的采集时间段、出发地、待分析区域，基于卡口监控设备获取车辆通行记录数据集；根据卡口备案信息中的卡口所在地区信息，将车辆通行记录数据集分为：出发地通行记录数据集和出发地外通行记录数据集，使用目标车辆在各地区最后一次被抓拍的时间进行比较，将时间早于出发地的通行记录数据删除，再删除异常数据，得到从单个出发地到多个目的地的目标车辆途经地通行记录，并以此获取通行详情数据，最后根据目的地对通行详情数据分组，得到从单个出发地到多个目的地的车辆流向分析结果。