基于KAFKA技术的分布式大气污染监测方法及系统
摘要文本
本发明公开了基于KAFKA技术的分布式大气污染监测方法及系统，涉及污染监测技术领域，该方法包括：设置用于污染监测的多个站点，获取分布式监测区块；利用分布式消息平台接收分布式监测区块中的多个污染监测数据，以时序消息队列将多个污染监测数据存储至对应的子区块中；确定异常污染数据以及对应的第一异常子区块；按照时序顺序输出标识子区块；根据第一异常子区块和标识子区块进行扩散度识别，得到污染扩散度，若污染扩散度大于预设污染扩散度，生成预警提醒信息。本发明解决了现有技术中大气污染监测数据分析时序性差，监测结果可靠性低的技术问题，达到了有序高效的进行监测分析，提升监测质量的技术效果。
申请人信息
- 申请人:唐山华洋自动化有限公司
- 申请人地址:063000 河北省唐山市高新技术开发区一号路南侧、卫国路西侧
- 发明人: 唐山华洋自动化有限公司
专利详细信息
| 项目 | 内容 |
|---|---|
| 专利名称 | 基于KAFKA技术的分布式大气污染监测方法及系统 |
| 专利类型 | 发明授权 |
| 申请号 | CN202311685986.6 |
| 申请日 | 2023/12/11 |
| 公告号 | CN117390464B |
| 公开日 | 2024/3/8 |
| IPC主分类号 | G06F18/22 |
| 权利人 | 唐山华洋自动化有限公司 |
| 发明人 | 张雪; 张美 |
| 地址 | 河北省唐山市高新技术开发区一号路南侧、卫国路西侧 |
专利主权项内容
1.基于KAFKA技术的分布式大气污染监测方法，其特征在于，所述方法包括：设置用于污染监测的多个站点，获取分布式监测区块，所述分布式监测区块中的每个子区块对应存储一个站点的污染监测数据，每个站点监测多个指标；利用分布式消息平台接收所述分布式监测区块中的多个污染监测数据，以时序消息队列将所述多个污染监测数据存储至对应的子区块中，其中，所述分布式消息平台是基于KAFKA技术构建的高吞吐量的消息平台，用于使所述分布式监测区块中的每个子区块进行并发处理；通过分析当前时序下中心子区块的污染监测数据，确定异常污染数据以及对应的第一异常子区块；根据所述时序消息队列对剩余子区块中污染监测数据与所述第一异常子区块的异常相似程度进行分析，若剩余子区块中任一子区块的异常相似度达到预设相似度时进行标识，按照时序顺序输出标识子区块；根据所述第一异常子区块和所述标识子区块进行扩散度识别，得到污染扩散度，若所述污染扩散度大于预设污染扩散度，生成预警提醒信息；其中，通过分析当前时序下中心子区块的污染监测数据，确定异常污染数据以及对应的第一异常子区块，包括：获取中心监测站点对应的中心子区块；根据所述中心子区块中的污染监测数据进行指标变化率分析，获取第一动态变化率；当所述第一动态变化率大于预设动态变化率，确定异常污染数据，其中，所述异常污染数据包括多个特征指标，所述特征指标为第一动态变化率大于预设动态变化率的指标；将所述中心子区块标识为第一异常子区块。