分布式实时数据融合系统

摘要

本发明公开了一种分布式实时数据融合系统，其包括决策信息分发模块以及依次运行在Storm引擎的五个工作节点上的数据采集模块、预处理模块、对准模块、状态估计模块和威胁估计模块。本发明采用Storm实时流式计算引擎作为系统的基础设施，使数据采集模块、预处理模块、对准模块、状态估计模块和威胁估计模块分别运行在Storm集群环境中的五个工作节点上，能够充分利用Storm分布式集群的高性能并行处理能力，大大提高了分布式实时数据融合系统的数据实时处理能力、容错性和稳定性，增强了分布式实时数据融合系统的并发性和扩展性，克服了传统的集中式数据融合系统存在的在并发性和扩展性上将受到限制的技术缺陷。

主权项

一种分布式实时数据融合系统，其特征在于，包括：数据采集模块，设置为获取并解析多个数据源发送的感知数据；预处理模块，设置为依次对各个数据源对应的解析后的感知数据进行滤波；对准模块，设置为将各个数据源对应的滤波后的感知数据对齐到同一采样时间点或时间片上；状态估计模块，设置为利用各个数据源对应的对准后的感知数据生成并更新曲线拟合方程，并根据更新后的曲线拟合方程预估目标特征数据；威胁估计模块，设置为根据预设的决策策略和预估的目标特征数据，得到决策信息；以及决策信息分发模块，设置为将决策信息分发给订阅用户；依次运行在Storm引擎的五个工作节点上的数据采集模块、预处理模块、对准模块、状态估计模块和威胁估计模块均受控于Storm引擎的Zookeeper节点。