Disclosure of Invention
The invention aims to solve the defects in the prior art, and provides a coal-fired boiler heating surface depth fault early warning system based on an industrial internet.
In order to achieve the purpose, the invention adopts the following technical scheme:
a coal-fired boiler heating surface depth fault early warning system based on an industrial internet comprises data acquisition, data conversion and transmission, big data fusion storage, data management, data objects, data calculation, intelligent analysis and intelligent application;
the data acquisition acquires various data of the power plant equipment through a DCS/SIS/KDM interface;
the data conversion and transmission module transmits various equipment data acquired by the data acquisition to a data storage module, a service module, a display module and the like of a monitoring platform;
the big data fusion storage stores structured and unstructured data;
the data management classifies different data into different databases for effective management according to the service of monitoring data of different equipment;
the data object records and displays process parameters, equipment states, working condition information and knowledge items;
the data calculation is carried out on the equipment diagnosis health prediction through a big data engine, and the data are calculated and combed through different calculation modules according to the intelligent analysis requirements of the business;
the intelligent analysis uses various artificial intelligence and machine learning algorithms to carry out intelligent analysis on services such as intelligent monitoring platform equipment diagnosis and the like;
the intelligent application main functions comprise measuring point abnormity detection, overrun statistics, operation assessment and degradation trend analysis.
Preferably, the data acquisition is mainly responsible for acquiring various types of data of equipment from a KDM system.
Preferably, the data conversion and transmission is performed by filtering and cleaning the device state information and the working condition information through a TCP/IP protocol, and then performing high-speed transmission on the network.
Preferably, the data management stores data such as real-time data, model analysis results, historical hotspot data, models and knowledge, and the data management comprises a real-time database and a historical database;
the real-time database stores data of each measuring point transmitted in real time; and the historical database stores historical data of each measuring point.
Preferably, the intelligent analysis adopts different intelligent analysis algorithms to provide intelligent analysis capability for fault monitoring, diagnosis, prediction and the like, the algorithm of the intelligent analysis can be used by other programs after being initialized, and the initialization stage is divided into four steps: data preprocessing, feature extraction, model training and algorithm deployment.
Preferably, the historical database stores historical data in the historical database by adopting hot spot data caching and pre-reading technologies according to the current data storage situation and by combining the characteristics of equipment data, and only keeps the historical data of the recent period of time and other historical hot spot data;
the hot spot data caching stores the hot spot data into a cache, stores the hot spot data into a Redis distributed database, a calculation or application server obtains the hot spot data from the hot spot database, and directly obtains the data through a KDM data center data sharing API for the data which is not in the database;
the pre-reading technology is used for pre-judging data required by a computer program or an application in the future, and reading and caching the data in advance.
Preferably, the data preprocessing is to meet the requirements of the algorithm of intelligent analysis by processing the data into the required format and distribution type;
the feature extraction is to process the preprocessed data, extract the data needed by intelligent analysis from the preprocessed data, and simultaneously smooth the data;
the algorithm training generates a data database query condition according to a data driving model to be trained, a database server is queried so as to read equipment state data stored in a data warehouse, data calculation tasks such as data conversion and feature extraction are generated, the result of the data calculation task calculation is used as training data of the data driving model and input into an intelligent calculation server, and the intelligent calculation server calls various intelligent algorithms to perform data driving modeling on the equipment state;
the algorithm deployment obtains a trained data driving model stored in a database from the database, the intelligent analysis server loads the data driving model and performs necessary initialization work on the model, and the intelligent analysis server calls an interface provided by a WebService server and externally releases functions provided by the data driving model into a restful WebService form.
Preferably, unsupervised learning is carried out by the intelligent analysis and the data object, a boiler wall temperature intelligent analysis model is established, new data are classified by using the model after the new data arrive, and the abnormal fluctuation of the furnace tube temperature measuring points in time and the change of temperature correlation with the surrounding furnace tube measuring points are captured by the intelligent application depth, so that a deteriorated furnace tube evaluation standard model is established.
Preferably, the algorithm of the boiler wall temperature intelligent analysis model is as follows:
the calculation formula of the metal temperature of the pipe wall is as follows:
the calculation formula of the outer wall temperature is as follows:
in the formula: t is tqCalculating the temperature in the point pipe; beta is the ratio of the outer diameter to the inner diameter of the tube; mu is a heat dissipation coefficient; delta is the thickness of the tube wall; q is a meterCalculating the point at which the tube absorbs the thermal load; lambda is the heat conductivity coefficient of the metal of the tube wall; alpha is alpha2Heat release coefficient for the vapor side;
the calculation formula of the heat absorption load of the pipe is as follows:
in the formula: theta is the calculated point flue gas temperature; alpha is alpha1Calculating the convection heat release coefficient of the smoke side of the point; alpha is alpha3Calculating the radiation heat release coefficient of the ignition smoke; ε is the contamination coefficient of the tube at the point of calculation.
Preferably, the flow of the deterioration furnace tube evaluation standard model is as follows: reading a measuring point information file, acquiring a measuring point list needing to be calculated and detected, and grouping the measuring points; extracting historical data from kdm for each group of measuring points, and extracting data of the current time period; and asynchronously calling the main function of the algorithm program.
Compared with the prior art, the invention has the beneficial effects that:
1. according to the invention, an incidence relation data model of the furnace tube temperature and the boiler working condition and a data model of the temperature and the position between the furnace tubes are established through an intelligent algorithm, so that the temperature of the furnace tubes is analyzed in real time and historical change is analyzed, the cause of the problem and early warning are given, the operation mode can be adjusted in time during operation, the fault development trend is improved or delayed, the wall temperature historical data is analyzed through comparison and analysis of the wall temperature data of adjacent tube panels, a data model for evaluating the safety of the furnace tube temperature and the heating surface operation working condition is established, the safety of the tube walls is evaluated in sequence, the potential risks can be eliminated in the set dispatching and maintenance, the leakage risks of four tubes of the boiler are greatly reduced, and the safe and continuous operation capability of the set is improved.
2. According to the invention, a time series machine learning-based furnace tube degradation targeted algorithm model is developed through comprehensive analysis of working conditions and furnace tube temperatures in a power plant generator set; the working state of the unit can be identified, the condition of false alarm of a furnace tube degradation model caused by data fluctuation of start and stop of the unit is eliminated, a big data mining technology is applied, abnormal fluctuation of furnace tube temperature data in time and change of correlation with surrounding furnace tube temperature are deeply captured, a degradation furnace tube evaluation standard model is established, and full life cycle state monitoring of the furnace tube heating state is realized; the model is automatically updated on line along with the operation, and is free from maintenance; the workload of starting the machine and the pressure of safety accidents are reduced.
Detailed Description
The technical solutions in the embodiments of the present invention will be clearly and completely described below with reference to the drawings in the embodiments of the present invention, and it is obvious that the described embodiments are only a part of the embodiments of the present invention, and not all of the embodiments.
Referring to fig. 1-2, a coal-fired boiler heating surface deep fault early warning system based on an industrial internet comprises data acquisition, data conversion and transmission, big data fusion storage, data management, data objects, data calculation, intelligent analysis and intelligent application;
the data acquisition acquires various data of the power plant equipment through a DCS/SIS/KDM interface;
the data conversion and transmission module transmits various equipment data acquired by data acquisition to a data storage module, a service module, a display module and the like of the monitoring platform;
the big data fusion storage stores structured data and unstructured data;
the data management classifies different data into different databases for effective management according to the service of monitoring data of different equipment;
the data object records and displays the process parameters, the equipment state, the working condition information and the knowledge items;
the data calculation is carried out on the equipment diagnosis health prediction through a big data engine, and the data are calculated and combed through different calculation modules according to the intelligent analysis requirements of the business;
the intelligent analysis uses various artificial intelligence and machine learning algorithms to carry out intelligent analysis on services such as intelligent monitoring platform equipment diagnosis and the like;
the intelligent application main functions comprise measuring point abnormity detection, overrun statistics, operation assessment and deterioration trend analysis.
The method comprises the steps of acquiring various data of all equipment of the power plant in real time through data acquisition, completely reserving historical data of the whole life cycle of the equipment, sending the data for other services in a data sharing mode, and mainly taking charge of acquiring various data of the equipment from a KDM system through the data acquisition.
The data conversion and transmission processes pretreatment such as filtering and cleaning of equipment state information and working condition information through TCP/IP protocol, and then high speed transmission is carried out on the network.
The data management system comprises a data management module, a data processing module and a data processing module, wherein the data management module is used for storing data such as real-time data, model analysis results, historical hotspot data, models and knowledge;
the real-time database stores the data of each measuring point transmitted in real time; and the historical database stores historical data of each measuring point.
The intelligent analysis adopts different intelligent analysis algorithms to provide intelligent analysis capability for fault monitoring, diagnosis, prediction and the like, the algorithm of the intelligent analysis can be used by other programs after being initialized, and the initialization stage is divided into four steps: data preprocessing, feature extraction, model training and algorithm deployment.
The historical database stores historical data in a Redis historical database by adopting hot data caching and pre-reading technologies according to the current data storage situation and by combining the data characteristics of equipment, and only keeps the historical data and other historical hot data in the recent period of time;
the hot spot data caching stores the hot spot data into a cache, stores the hot spot data into a Redis distributed database, a calculation or application server obtains the hot spot data from the hot spot database, and directly obtains the data through a KDM data center data sharing API for the data which is not in the database;
the pre-reading technology is used for pre-judging data required by a computer program or an application in the future, and reading and caching the data in advance.
The data preprocessing is to process the data into a required format and a required distribution type so as to meet the requirement of an intelligent analysis algorithm;
the feature extraction is to process the preprocessed data, extract the data needed by intelligent analysis from the preprocessed data, and simultaneously smooth the data;
the algorithm training generates a data database query condition according to a data driving model to be trained, a database server is queried so as to read equipment state data stored in a data warehouse, data calculation tasks such as data conversion and feature extraction are generated, the result of the data calculation task calculation is used as training data of the data driving model and input into an intelligent calculation server, and the intelligent calculation server calls various intelligent algorithms to perform data driving modeling on the equipment state;
the algorithm deployment obtains a trained data driving model stored in the database from the database, the intelligent analysis server loads the data driving model and performs necessary initialization work on the model, and the intelligent analysis server calls an interface provided by the WebService server and externally releases functions provided by the data driving model into a restful WebService form.
The method comprises the steps of carrying out unsupervised learning by intelligent analysis and combining with data objects, establishing an intelligent analysis model of the wall temperature of the boiler, classifying new data by using the model after the new data arrives, capturing abnormal fluctuation of furnace tube temperature measuring points in time and changes of temperature correlation with surrounding furnace tube measuring points by intelligent application depth, and establishing a deteriorated furnace tube evaluation standard model.
The algorithm of the boiler wall temperature intelligent analysis model is as follows:
the calculation formula of the metal temperature of the pipe wall is as follows:
the calculation formula of the outer wall temperature is as follows:
in the formula: t is tqCalculating the temperature in the point pipe; beta is the ratio of the outer diameter to the inner diameter of the tube; mu is a heat dissipation coefficient; delta is the thickness of the tube wall; q is the calculated point heat load absorbed by the pipe; lambda is the heat conductivity coefficient of the metal of the tube wall; alpha is alpha2Heat release coefficient for the vapor side;
the calculation formula of the heat absorption load of the pipe is as follows:
in the formula: theta is the calculated point flue gas temperature; alpha is alpha1Calculating the convection heat release coefficient of the smoke side of the point; alpha is alpha3Calculating the radiation heat release coefficient of the ignition smoke; ε is the contamination coefficient of the tube at the point of calculation.
Wherein, the flow of the deteriorated furnace tube evaluation standard model is as follows: reading a measuring point information file, acquiring a measuring point list needing to be calculated and detected, and grouping the measuring points; extracting historical data from kdm for each group of measuring points, and extracting data of the current time period; and asynchronously calling the main function of the algorithm program.
Referring to fig. 3, when the deteriorated furnace tube evaluation standard model works, firstly reading a measuring point information file, acquiring a measuring point list needing to be calculated and detected, and grouping measuring points; extracting historical data from kdm for each group of measuring points, and extracting data of the current time period; asynchronously calling a main function of an algorithm program;
then judging the working state of the unit and the abnormal state of the measuring point, if the working state and the abnormal state of the measuring point exist, returning to False, and jumping out of the algorithm program; loading a prediction model corresponding to the measuring point; aligning temperature measuring point data and unit load data; using a ridge regression model, calculating the station degradation state:
1) processing the load data by using PolynomialFeatures to obtain a characteristic item;
2) obtaining a measuring point temperature predicted value based on a ridge regression prediction model;
3) judging whether the measuring points are degraded or not by the algorithm model;
if the model judges that the measuring point is degraded, updating the model information file pkl, and putting the current window time period into the model information file pkl; updating a current measuring point prediction model; generating alarm information according to the format requirement of a database, and returning the result to an interface program;
if the model judges that the measuring point is updated to be in a normal state (maintenance occurs) from the degradation state, updating the model information file pkl, and putting the current window time period into the model information file pkl; updating a current measuring point prediction model;
if the model judges that the measuring point is not degraded, returning to False;
in the interface program, if furnace tube degradation alarm information exists in a result returned by the degradation algorithm program, the formatted alarm information is pushed to kafka;
acquiring measurement point data of the reference time and data of a current window based on the reference model time and the current window time in the furnace tube degradation alarm information, and realizing temperature and load data alignment in the function (according to the front end requirement);
and pushing the measuring point data acquired in the previous step to a background.
After completing all computing tasks, the interface program waits for timing tasks: the main function is re-executed periodically.
The working process of the intelligent analysis model for the wall temperature of the boiler is as follows:
1) calibrating the working condition of each time through the temperature change of the key measuring point;
2) analyzing distribution conditions (highest point, lowest point, percentile and the like) of the temperature of each measuring point under different historical working conditions by combining with working condition information, setting a threshold value of an absolute value of the temperature according to the distribution conditions, and alarming when new data exceeds the threshold value;
3) analyzing the distribution (standard deviation, range difference and the like) of all tube temperatures of the same screen at the same time under different historical working conditions by combining with working condition information, setting a threshold value according to the distribution, and alarming when new data exceeds the threshold value;
4) analyzing the distribution conditions (highest point, lowest point, quantile and the like) of the change rate of the temperature of each screen measuring point under different historical working conditions by combining with the working condition information, setting a threshold value of the temperature change rate according to the distribution conditions, and alarming when new data exceed the threshold value;
5) aiming at the temperature of a certain measuring point at a certain moment, modeling the temperature of other pipe measuring points on the same screen at the same time, obtaining a predicted value through a model after new data comes, comparing the predicted value with a real value, and alarming if the difference is large;
6) aiming at the temperature of a certain measuring point at a certain moment, modeling the temperature of the certain measuring point at a plurality of moments before the certain measuring point, obtaining a predicted value through a model after new data comes, comparing the predicted value with a real value, and alarming if the difference is large;
7) combining working condition information, using the temperatures of all measuring points in a certain screen at the same time, performing unsupervised learning and modeling, and classifying (normal/abnormal) new data by using the model after the new data comes;
8) for the temperature of a certain measuring point, a section of data is intercepted by using a sliding window, self-encoding-decoding learning is carried out by using an AutoEncoder technology in deep learning, after new data arrives, the same self-encoding-decoding is carried out, and if the difference between the obtained data and the original data is larger, an alarm is given;
9) according to the fault record, the data are labeled, then a classification model is trained by using supervision algorithms such as random forests, SVM, xgboost and the like, and the new data are classified by using the model after arriving.
In the description of the present invention, it is to be understood that the terms "center", "longitudinal", "lateral", "length", "width", "thickness", "upper", "lower", "front", "rear", "left", "right", "vertical", "horizontal", "top", "bottom", "inner", "outer", "clockwise", "counterclockwise", and the like, indicate orientations and positional relationships based on those shown in the drawings, and are used only for convenience of description and simplicity of description, and do not indicate or imply that the equipment or element being referred to must have a particular orientation, be constructed and operated in a particular orientation, and thus, should not be considered as limiting the present invention.
Furthermore, the terms "first", "second" and "first" are used for descriptive purposes only and are not to be construed as indicating or implying relative importance or implicitly indicating the number of technical features indicated. Thus, a feature defined as "first" or "second" may explicitly or implicitly include one or more of that feature. In the description of the present invention, "a plurality" means two or more unless specifically defined otherwise.
The above description is only for the preferred embodiment of the present invention, but the scope of the present invention is not limited thereto, and any person skilled in the art should be considered to be within the technical scope of the present invention, and the technical solutions and the inventive concepts thereof according to the present invention should be equivalent or changed within the scope of the present invention.