发明公开
- 专利标题: 一种基于Flink的区域布控方法和设备
-
申请号: CN202311256788.8申请日: 2023-09-27
-
公开(公告)号: CN117216167A公开(公告)日: 2023-12-12
- 发明人: 杨玲 , 杨光
- 申请人: 武汉众智数字技术有限公司
- 申请人地址: 湖北省武汉市东湖新技术开发区珞喻路546号
- 专利权人: 武汉众智数字技术有限公司
- 当前专利权人: 武汉众智数字技术有限公司
- 当前专利权人地址: 湖北省武汉市东湖新技术开发区珞喻路546号
- 代理机构: 北京汇泽知识产权代理有限公司
- 代理商 吴俣
- 主分类号: G06F16/27
- IPC分类号: G06F16/27 ; G06F16/2458 ; G06F16/22 ; G06F16/23
摘要:
本发明公开了一种基于Flink的区域布控方法和设备,所述方法包括:通过Flink cdc创建第一同步虚拟表,获取业务端下发的至Mysql中的布控信息,并对第一同步虚拟表中的布控信息进行同步变更;通过Flink cdc创建第二同步虚拟表,从用于实时传输抓拍数据信息的第一Kafka中读取抓拍数据信息;将第一同步虚拟表中的布控信息与第二同步虚拟表中的抓拍数据信息进行比对,得到符合要求的预警数据;将预警数据同步输出至第一数据库,用于供业务端详细结果查询,将预警数据同步写入第二Kafka,将第二Kafka数据导入Doris中,在Doris分别创建Aggregate模型表和Duplicate模型表,用于存储目标在不同采集设备的统计信息、目标在不同时间的详细记录数据。