本发明提供一种基于流式处理的工业传感器数据处理方法。本发明通过获取传感器数据到数据采集层；在数据采集层通过建立协议转换层适配多种型号，多种协议的传感器；在数据处理层通过kafka消息队列接受数据，并且转发至数据处理引擎；在数据处理引擎根据相关设计的数据模型计算并且实时返回结果，同时会把原数据保存在时序数据库；数据处理引擎根据实时处理后的数据直接发送到时序数据库存储，同时把数据发回消息队列集群，用于其他系统二次消费使用；将配置信息保存在关系型数据库。本发明进行数据流处理时，能够持续稳定的支撑巨大的数据流量，不降低整个系统的性能，提高运行效率，满足传感器数据处理的实时性的要求，降低成本。