CN114584859A - Rolling bearing data transmission method of PHM system of train traction motor - Google Patents
Rolling bearing data transmission method of PHM system of train traction motor Download PDFInfo
- Publication number
- CN114584859A CN114584859A CN202111617041.1A CN202111617041A CN114584859A CN 114584859 A CN114584859 A CN 114584859A CN 202111617041 A CN202111617041 A CN 202111617041A CN 114584859 A CN114584859 A CN 114584859A
- Authority
- CN
- China
- Prior art keywords
- data
- rolling bearing
- traction motor
- train
- transmission method
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
- 238000000034 method Methods 0.000 title claims abstract description 42
- 238000005096 rolling process Methods 0.000 title claims abstract description 27
- 230000005540 biological transmission Effects 0.000 title claims abstract description 23
- 238000012544 monitoring process Methods 0.000 claims abstract description 3
- 230000003595 spectral effect Effects 0.000 claims description 14
- 238000004458 analytical method Methods 0.000 claims description 3
- 238000012423 maintenance Methods 0.000 claims description 3
- 238000004519 manufacturing process Methods 0.000 claims description 3
- 238000001228 spectrum Methods 0.000 claims description 2
- 238000012545 processing Methods 0.000 description 4
- 238000003860 storage Methods 0.000 description 4
- 238000004891 communication Methods 0.000 description 2
- 238000007726 management method Methods 0.000 description 2
- 238000012986 modification Methods 0.000 description 2
- 230000004048 modification Effects 0.000 description 2
- 238000013500 data storage Methods 0.000 description 1
- 238000013461 design Methods 0.000 description 1
- 238000011161 development Methods 0.000 description 1
- 238000005516 engineering process Methods 0.000 description 1
- 238000004321 preservation Methods 0.000 description 1
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04Q—SELECTING
- H04Q9/00—Arrangements in telecontrol or telemetry systems for selectively calling a substation from a main station, in which substation desired apparatus is selected for applying a control signal thereto or for obtaining measured values therefrom
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/06—Protocols specially adapted for file transfer, e.g. file transfer protocol [FTP]
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Electric Propulsion And Braking For Vehicles (AREA)
Abstract
Description
技术领域technical field
本发明涉及列车牵引电机PHM故障预测与健康管理技术领域,具体为一种列车牵引电机PHM系统的滚动轴承数据传输方法。The invention relates to the technical field of PHM fault prediction and health management of a train traction motor, in particular to a rolling bearing data transmission method of a train traction motor PHM system.
背景技术Background technique
随着轨道交通技术的发展,轨道交通系统的智能化也随之发展。其中,PHM故障预测与健康管理为轨道交通提供了针对高速铁路牵引电机滚动轴承健康状态预测问题的解决方案。With the development of rail transit technology, the intelligence of rail transit systems also develops. Among them, PHM fault prediction and health management provides a solution to the health state prediction problem of high-speed railway traction motor rolling bearings for rail transit.
列车牵引电机PHM系统的车载单元通过传感器对滚动轴承进行信号采集,生成的信号包括温度、转速、振动信号、电流、电压等。这些信号生成的数据需要从车载单元传输至服务器平台。在该传输过程中大量设备同时连接,多个车载单元在多个列车牵引电机上同时采集数据。但是,列车牵引电机如此大量的滚动轴承数据在高并发场景下容易发生宕机,很难以高效的方式在PHM系统中支持实时数据流的保存和异步处理。The on-board unit of the train traction motor PHM system collects signals from the rolling bearing through sensors, and the generated signals include temperature, rotational speed, vibration signal, current, voltage, etc. The data generated by these signals needs to be transmitted from the onboard unit to the server platform. During the transmission process, a large number of devices are connected at the same time, and multiple on-board units simultaneously collect data on multiple train traction motors. However, such a large amount of rolling bearing data of the train traction motor is prone to downtime in high concurrency scenarios, and it is difficult to support the preservation and asynchronous processing of real-time data streams in the PHM system in an efficient manner.
发明内容SUMMARY OF THE INVENTION
本发明目的是提供一种列车牵引电机PHM系统的滚动轴承数据传输方法,用于应对高并发场景下的应用需求,提高消息的传送速度,支持实时数据流的保存和异步处理。The purpose of the present invention is to provide a rolling bearing data transmission method of a PHM system of a train traction motor, which is used to meet application requirements in high concurrency scenarios, improve message transmission speed, and support real-time data stream storage and asynchronous processing.
本发明是采用如下技术方案实现的:The present invention adopts the following technical scheme to realize:
一种列车牵引电机PHM系统的滚动轴承数据传输方法,包括以下步骤:A rolling bearing data transmission method of a train traction motor PHM system, comprising the following steps:
步骤一、车载单元采集滚动轴承信号生成原始文件,将该原始文件解析成原始数据;Step 1. The on-board unit collects the rolling bearing signal to generate an original file, and parses the original file into original data;
步骤二、将所述原始数据通过车载单元的MQTT消息网关代理以相对应的Topic进行MQTT发布过程;Step 2, carrying out the MQTT publishing process with the corresponding Topic through the MQTT message gateway agent of the vehicle-mounted unit;
步骤三、将所述原始数据通过PHM服务器平台的MQTT input通道以所述Topic进行MQTT订阅过程;Step 3, carry out the MQTT subscription process with the Topic through the MQTT input channel of the PHM server platform;
步骤四、将所述原始数据进行添加配属信息解析过程,使得所述数据消息成为完整数据;Step 4. The original data is added to the attachment information analysis process, so that the data message becomes complete data;
步骤五、将所述完整数据通过Kafka Producer以所述Topic进行Kafka生产过程;Step 5, carrying out the Kafka production process with the Topic through the Kafka Producer with the complete data;
步骤六、将所述完整数据通过Kafka Listener 以监听所述Topic的方式进行Kafka消费过程;Step 6. Perform the Kafka consumption process by monitoring the Topic through the Kafka Listener for the complete data;
步骤七、将所述完整数据解析成多种数据进行入库过程。Step 7: Parse the complete data into a variety of data for warehousing.
进一步优选的,步骤一中,所述原始文件包括以下至少一种:振动信号原始文件tsFile,温度原始文件tmFile,转速原始文件gssFile,电压原始文件volFile,电流原始文件curFile;所述原始数据包括以下至少一种:振动信号原始数据,温度原始数据,电压原始数据,电流原始数据,转速原始数据。Further preferably, in step 1, the original file includes at least one of the following: vibration signal original file tsFile, temperature original file tmFile, rotational speed original file gssFile, voltage original file volFile, current original file curFile; The original data includes the following At least one: raw data of vibration signal, raw data of temperature, raw data of voltage, raw data of current, raw data of rotational speed.
进一步优选的,所述步骤二进行MQTT发布过程之前,用算法模型对所述原始数据进行计算获得特征数据和/或频谱数据,所述特征数据和/或频谱数据比振动信号原始数据更小。Further preferably, before the MQTT publishing process is performed in the second step, an algorithm model is used to calculate the raw data to obtain characteristic data and/or spectral data, where the characteristic data and/or spectral data are smaller than the original vibration signal data.
进一步优选的,对所述原始数据和/或所述特征数据和/或所述频谱数据进行加密与压缩,使得所述原始数据和/或所述特征数据和/或所述频谱数据更安全以及更小。Further preferably, the original data and/or the characteristic data and/or the spectral data are encrypted and compressed, so that the original data and/or the characteristic data and/or the spectral data are more secure and smaller.
进一步优选的,步骤四中,所述配属信息包括列车编号,该列车编号在数据库中能够编辑,使得列车牵引电机在下车检修或者新机上车时PHM平台能够正确调取电机对应列车编号,数据被补全为所属完整数据。Further preferably, in step 4, the associated information includes the train number, and the train number can be edited in the database, so that the PHM platform can correctly retrieve the train number corresponding to the motor when the train traction motor gets off for maintenance or when the new machine gets on the train. Completed as the complete data of the corresponding.
进一步优选的,所述步骤七进行入库过程之前,用算法模型对所述完整数据进行计算获得剩余使用寿命和/或健康度和/或预测健康度和/或报警等级和/或故障代号。对将完整数据解析成的多种数据进行压缩,使得所述完整数据更小。Further preferably, before the warehousing process in step 7, an algorithm model is used to calculate the complete data to obtain remaining service life and/or health degree and/or predicted health degree and/or alarm level and/or fault code. The various data into which the complete data is parsed is compressed so that the complete data is smaller.
本发明还提供了一种包括上述高速铁路列车牵引电机PHM系统的滚动轴承数据传输方法的任意装置。The present invention also provides an arbitrary device comprising the above-mentioned rolling bearing data transmission method of the traction motor PHM system of a high-speed railway train.
本发明还提供了一种包括上述列车牵引电机PHM系统的滚动轴承数据传输方法和/或装置的传输平台。The present invention also provides a transmission platform including the rolling bearing data transmission method and/or device of the train traction motor PHM system.
本发明通过利用Kafka专注于数据存储和读取、流数据处理的高实时性能,充分利用MQTT轻量级协议专注于客户端和服务器之间的通信以及通信中支持数百万个设备同时连接以及鲁棒性的特点,结合序列化工具以及算法模型,减少数据量,提高PHM系统的数据传送速度与稳定性,支持实时数据流的保存和异步处理,满足了高并发场景下的应用需求。The present invention focuses on the high real-time performance of data storage and reading and stream data processing by using Kafka, and makes full use of the MQTT lightweight protocol to focus on the communication between the client and the server, and supports the simultaneous connection of millions of devices in the communication and The characteristics of robustness, combined with serialization tools and algorithm models, reduce the amount of data, improve the data transmission speed and stability of the PHM system, support the storage and asynchronous processing of real-time data streams, and meet application requirements in high concurrency scenarios.
本发明设计合理,使得列车牵引电机PHM系统的滚动轴承数据能够以高效且安全的方式进行发送、接收、解析以及入库,具有很好的实际应用价值。The invention has a reasonable design, so that the rolling bearing data of the PHM system of the train traction motor can be sent, received, analyzed and stored in an efficient and safe manner, which has good practical application value.
具体实施方式Detailed ways
下面结合实施例对本发明作进一步详细描述,但本发明的实施方式不限于此。The present invention will be described in further detail below with reference to the examples, but the embodiments of the present invention are not limited thereto.
本实施例提供列车牵引电机PHM系统的滚动轴承数据传输方法,包括以下步骤:The present embodiment provides a rolling bearing data transmission method of a PHM system of a train traction motor, including the following steps:
步骤一、车载单元采集滚动轴承信号生成振动信号原始文件tsFile,温度原始文件tmFile,转速原始文件gssFile,电压原始文件volFile,电流原始文件curFile。Step 1. The on-board unit collects the rolling bearing signal to generate the original vibration signal file tsFile, the original temperature file tmFile, the original rotational speed file gssFile, the original voltage file volFile, and the original current file curFile.
将这些原始文件解析成振动信号原始数据,温度原始数据,转速原始数据,电压原始数据,电流原始数据;分别采用均方根值、方差、峭度、谱有效值以及谱均值等的算法模型对振动信号原始数据进行计算后,再获得特征数据文件cvFile和/或频谱数据文件fftFile,解析成特征数据和/或频谱数据,该特征数据和/或频谱数据比原始数据更小。These raw files are parsed into raw vibration signal data, raw temperature data, raw rotational speed data, raw voltage data, and raw current data; the algorithm models of root mean square value, variance, kurtosis, spectral RMS and spectral mean are used to After the raw data of the vibration signal is calculated, the characteristic data file cvFile and/or the spectral data file fftFile are obtained and parsed into characteristic data and/or spectral data, which are smaller than the original data.
对所有原始数据和/或特征数据和/或频谱数据进行加密与压缩,使得数据消息和/或特征数据和/或频谱数据更安全以及更小。All raw data and/or characteristic data and/or spectral data are encrypted and compressed, making data messages and/or characteristic data and/or spectral data more secure and smaller.
在“temperature”Topic存入温度数据,在“gss”Topic存入转速数据,在“voltage”Topic存入电压数据,在“current”Topic存入电流数据,在“feature”Topic存入特征数据,在“spectrum”Topic存入频谱数据。The temperature data is stored in the "temperature" topic, the rotational speed data is stored in the "gss" topic, the voltage data is stored in the "voltage" topic, the current data is stored in the "current" topic, and the feature data is stored in the "feature" topic. Store spectral data in the "spectrum" topic.
步骤二、将这些数据通过车载单元的MQTT消息网关代理进行MQTT发布过程。Step 2: Execute the MQTT publishing process through the MQTT message gateway agent of the vehicle-mounted unit.
步骤三、将这些数据通过PHM服务器平台的MQTT input通道以这些Topic进行MQTT订阅过程。Step 3: Use these Topics to perform MQTT subscription process through the MQTT input channel of the PHM server platform.
步骤四、将这些原始数据进行添加配属信息解析过程,配属信息包括列车编号trainId,该trainId的值以及与电机编号motorId的对应关系在数据库中可编辑,使得列车牵引电机在下车检修或者新机上车时PHM平台能够正确调取电机对应列车编号,添加配属信息解析过程后的原始数据成为完整数据。Step 4. Add these original data to the process of analyzing the attachment information. The attachment information includes the train number trainId. The value of the trainId and the corresponding relationship with the motor number motorId can be edited in the database, so that the train traction motor can be removed for maintenance or on a new machine. The PHM platform can correctly retrieve the train number corresponding to the motor, and the original data after adding the attachment information analysis process becomes the complete data.
步骤五、将完整数据通过Kafka Producer以Topic进行Kafka生产过程。Step 5. Pass the complete data through the Kafka Producer and use the Topic for the Kafka production process.
步骤六、将完整数据通过Kafka Listener 以监听Topic的方式进行Kafka消费过程。Step 6: Pass the complete data through the Kafka Listener to monitor the Topic for the Kafka consumption process.
步骤七、分别采用剩余使用寿命和/或健康度和/或预测健康度和/或报警等级和/或故障代号的算法模型对完整数据进行计算后,最终获得剩余使用寿命和/或健康度和/或预测健康度和/或报警等级和/或故障代号,其中,报警等级代表故障的严重程度,故障代号代表故障类型。Step 7. After calculating the complete data by using the algorithm model of the remaining service life and/or health degree and/or predicted health degree and/or alarm level and/or fault code, the remaining service life and/or health degree and /or predicted health degree and/or alarm level and/or fault code, wherein, the alarm level represents the severity of the fault, and the fault code represents the type of fault.
将完整数据解析成多种数据,进行压缩,使得所述完整数据更小,再进行入库过程。The complete data is parsed into a variety of data, compressed to make the complete data smaller, and then the storage process is performed.
将所述完整数据解析成多种数据进行入库过程。The complete data is parsed into a variety of data for the storage process.
以上所述仅是本发明的具体实施方式,使本领域技术人员能够理解或实现本发明。对这些实施例的多种修改对本领域的技术人员来说将是显而易见的,本文中所定义的一般原理可以在不脱离本发明的精神或范围的情况下,在其它实施例中实现。应当理解的是,本发明并不局限于上述已经描述的内容,并且可以在不脱离其范围进行各种修改和改变。本发明的范围仅由所附的权利要求来限制。The above descriptions are only specific embodiments of the present invention, so that those skilled in the art can understand or implement the present invention. Various modifications to these embodiments will be readily apparent to those skilled in the art, and the generic principles defined herein may be implemented in other embodiments without departing from the spirit or scope of the invention. It should be understood that the present invention is not limited to what has been described above and that various modifications and changes may be made without departing from its scope. The scope of the present invention is limited only by the appended claims.
Claims (9)
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111617041.1A CN114584859A (en) | 2021-12-28 | 2021-12-28 | Rolling bearing data transmission method of PHM system of train traction motor |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111617041.1A CN114584859A (en) | 2021-12-28 | 2021-12-28 | Rolling bearing data transmission method of PHM system of train traction motor |
Publications (1)
| Publication Number | Publication Date |
|---|---|
| CN114584859A true CN114584859A (en) | 2022-06-03 |
Family
ID=81769938
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202111617041.1A Pending CN114584859A (en) | 2021-12-28 | 2021-12-28 | Rolling bearing data transmission method of PHM system of train traction motor |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN114584859A (en) |
Citations (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| KR101834837B1 (en) * | 2016-11-14 | 2018-03-06 | 충북대학교 산학협력단 | System of IoT sensor simulator using MQTT and KAFKA |
| CN108768826A (en) * | 2018-05-16 | 2018-11-06 | 华南理工大学 | Based on the message route method under MQTT and Kafka high concurrent scenes |
| CN110222091A (en) * | 2019-06-10 | 2019-09-10 | 帷幄匠心科技(杭州)有限公司 | A kind of mass data real-time statistic analysis method |
| CN110602178A (en) * | 2019-08-26 | 2019-12-20 | 杭州电子科技大学 | Method for calculating and processing temperature sensor data based on edge compression |
| CN112637301A (en) * | 2020-12-16 | 2021-04-09 | 华中师范大学 | Project reader framework-based data transmission method and system |
| CN112883011A (en) * | 2021-02-05 | 2021-06-01 | 京东方科技集团股份有限公司 | Real-time data processing method and device |
| CN113157449A (en) * | 2021-04-16 | 2021-07-23 | 上海寰果信息科技有限公司 | Real-time stream data analysis processing method based on MQTT |
| CN113420048A (en) * | 2021-05-19 | 2021-09-21 | 中交公规土木大数据信息技术(北京)有限公司 | Data aggregation method and device, electronic equipment and storage medium |
-
2021
- 2021-12-28 CN CN202111617041.1A patent/CN114584859A/en active Pending
Patent Citations (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| KR101834837B1 (en) * | 2016-11-14 | 2018-03-06 | 충북대학교 산학협력단 | System of IoT sensor simulator using MQTT and KAFKA |
| CN108768826A (en) * | 2018-05-16 | 2018-11-06 | 华南理工大学 | Based on the message route method under MQTT and Kafka high concurrent scenes |
| CN110222091A (en) * | 2019-06-10 | 2019-09-10 | 帷幄匠心科技(杭州)有限公司 | A kind of mass data real-time statistic analysis method |
| CN110602178A (en) * | 2019-08-26 | 2019-12-20 | 杭州电子科技大学 | Method for calculating and processing temperature sensor data based on edge compression |
| CN112637301A (en) * | 2020-12-16 | 2021-04-09 | 华中师范大学 | Project reader framework-based data transmission method and system |
| CN112883011A (en) * | 2021-02-05 | 2021-06-01 | 京东方科技集团股份有限公司 | Real-time data processing method and device |
| CN113157449A (en) * | 2021-04-16 | 2021-07-23 | 上海寰果信息科技有限公司 | Real-time stream data analysis processing method based on MQTT |
| CN113420048A (en) * | 2021-05-19 | 2021-09-21 | 中交公规土木大数据信息技术(北京)有限公司 | Data aggregation method and device, electronic equipment and storage medium |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| BE1025976B1 (en) | DEVICE FOR PROCESSING DATA OF ROLLING EQUIPMENT | |
| CN107037800B (en) | Fault diagnosis method based on remote fault diagnosis system of client-side oxygen generating equipment | |
| CN111310948A (en) | Obtaining method of optimal maintenance strategy for rail transit on-board signal system | |
| CN113285861A (en) | Vehicle data acquisition method based on intelligent central gateway | |
| CN114387124B (en) | Time sequence data storage method of nuclear power industry internet platform | |
| CN109895815B (en) | Train operation data acquisition method and system | |
| CN111770022B (en) | Capacity expansion method, system, equipment and computer storage medium based on link monitoring | |
| CN113112038B (en) | Intelligent monitoring and diagnostic analysis system, device, electronic equipment and storage medium | |
| CN116184973A (en) | Vehicle state remote monitoring method and system | |
| CN108255659A (en) | A kind of application program capacity monitoring method and its system | |
| CN113411229A (en) | Data processing method, playback data acquisition device and movable platform | |
| CN114691633A (en) | Log management method, equipment and storage medium for rail traffic signal system | |
| CN202939486U (en) | Automobile fault remote diagnosis system | |
| CN114584859A (en) | Rolling bearing data transmission method of PHM system of train traction motor | |
| CN104468248A (en) | Service performance monitoring method, reverse proxy server, statistical analysis server and system | |
| CN115473910A (en) | Data management method and device, electronic device and storage medium | |
| CN117112039B (en) | Transmission optimization system and operation method of data center | |
| CN116132540B (en) | Multi-service system data processing method and device | |
| CN116968781A (en) | An equipment early warning data processing method and system for autonomous train operation systems | |
| CN116866099A (en) | Operation and maintenance data access method and device | |
| CN103067518A (en) | In-vehicle network video monitoring system and alarming method thereof | |
| JP2010212744A (en) | Method and device for data compression, and program | |
| CN115203302A (en) | System, method and computer-readable storage medium for real-time monitoring of vehicle conditions of connected vehicles | |
| CN116032996A (en) | Voiceprint data standardized acquisition method and system based on power transformation equipment | |
| CN115396490A (en) | Vehicle health data center system based on data center |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination |