Abstract:In view of the flaw found in the existing industrial controlling network which fails to effectively receive and deal with mass sensor data from the industrial field, an industrial data processing and storage system for blowers, based on the Hadoop framework, has thus been designed and implemented. This system uses the message queue telemetry transport (MQTT) as the data access agreement, with EMQ message queue server as the subscription and publishing interface, with Flink as flow computing platform, and with Kafka as message queue buffer shunt and OpenTSDB database as data storage. Experimental results show that the new system helps to eliminate the large amount of data and information islands generated in the process of industrial manufacturing, thus realizing the dynamic state monitoring and real-time warning of production equipment.