本文针对卷烟工业网络中出现的故障现象,采用大数据分析手段,基于Spark streaming框架的实时检测,通过消息订阅读取上层Kafka组件中的实时数据流,并加载离线构建的检测模型,对经过预处理后的规范数据流进行实时检测,具有高效的计算能力和并发处理能力。通过某卷烟厂实验证明了方法的有效性。