一种基于Flink的区域布控方法和设备
摘要:
本发明公开了一种基于Flink的区域布控方法和设备,所述方法包括:通过Flink cdc创建第一同步虚拟表,获取业务端下发的至Mysql中的布控信息,并对第一同步虚拟表中的布控信息进行同步变更;通过Flink cdc创建第二同步虚拟表,从用于实时传输抓拍数据信息的第一Kafka中读取抓拍数据信息;将第一同步虚拟表中的布控信息与第二同步虚拟表中的抓拍数据信息进行比对,得到符合要求的预警数据;将预警数据同步输出至第一数据库,用于供业务端详细结果查询,将预警数据同步写入第二Kafka,将第二Kafka数据导入Doris中,在Doris分别创建Aggregate模型表和Duplicate模型表,用于存储目标在不同采集设备的统计信息、目标在不同时间的详细记录数据。
0/0