The invention provides a streaming
processing calculation method and
system for industrial data. The method comprises the steps: carrying out the data collection of equipment, obtaining a
bit array generated by the equipment, recognizing an equipment field, converting the equipment field into a
JSON character string, and transmitting the
JSON character string to message-oriented
middleware in realtime; analyzing the
data information of the message-oriented
middleware by using an Flink computing engine, and carrying out asynchronous matching on corresponding dimension information; performing windowing calculation on the
data information according to different dimensions, writing a first calculation result into an analysis layer of the message-oriented
middleware, performing index calculation, and packaging and storing a second calculation result into a column-type storage
database. Data calculation is achieved through a
big data flow calculation engine Flink, data storage is completedthrough a
big data distributed
file storage system Hadoop, and
data access is safe through a
kerberos network
authorization protocol; the problems of data timeliness calculation, automatic analysis report and data storage safety of a current industrial enterprise are solved.