+

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 PDF

Info

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
Application number
CN202111617041.1A
Other languages
Chinese (zh)
Inventor
赵梦露
张里洋
张微
张健
张建丽
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
CRRC Yongji Electric Co Ltd
Original Assignee
CRRC Yongji Electric Co Ltd
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by CRRC Yongji Electric Co Ltd filed Critical CRRC Yongji Electric Co Ltd
Priority to CN202111617041.1A priority Critical patent/CN114584859A/en
Publication of CN114584859A publication Critical patent/CN114584859A/en
Pending legal-status Critical Current

Links

Classifications

    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04QSELECTING
    • H04Q9/00Arrangements 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
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/01Protocols
    • H04L67/06Protocols 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

The invention discloses a rolling bearing data transmission method of a train traction motor PHM system, which comprises the following steps: firstly, a vehicle-mounted unit collects signals of a rolling bearing to generate an original file, and the original file is analyzed into original data; secondly, carrying out MQTT release process on the original data through an MQTT message gateway agent of the vehicle-mounted unit by using corresponding Topic; thirdly, performing MQTT subscription process on the original data through an MQTT input channel of the PHM server platform by means of Topic; fourthly, performing an attachment information adding and analyzing process on the original data, and enabling the data message to become complete data; fifthly, the complete data is processed by Kafka Producer through Topic; sixthly, carrying out a Kafka consumption process on the complete data in a Topic monitoring mode through Kafka Listener; and seventhly, analyzing the complete data into various data to be subjected to a warehousing process.

Description

一种列车牵引电机PHM系统的滚动轴承数据传输方法A rolling bearing data transmission method of a train traction motor PHM system

技术领域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)

1.一种列车牵引电机PHM系统的滚动轴承数据传输方法,其特征在于:包括以下步骤:1. a rolling bearing data transmission method of a train traction motor PHM system, is characterized in that: comprise 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. 2.根据权利要求1所述的一种列车牵引电机PHM系统的滚动轴承数据传输方法,其特征在于:步骤一中,所述原始文件包括以下至少一种:振动信号原始文件tsFile,温度原始文件tmFile,转速原始文件gssFile,电压原始文件volFile,电流原始文件curFile;2. the rolling bearing data transmission method of a kind of train traction motor PHM system according to claim 1, is characterized in that: in step 1, described original file comprises following at least one: vibration signal original file tsFile, temperature original file tmFile , the speed original file gssFile, the voltage original file volFile, the current original file curFile; 所述原始数据包括以下至少一种:振动信号原始数据,温度原始数据,电压原始数据,电流原始数据,转速原始数据。The raw data includes at least one of the following: raw vibration signal data, raw temperature data, raw voltage data, raw current data, and raw rotational speed data. 3.根据权利要求2所述的一种列车牵引电机PHM系统的滚动轴承数据传输方法,其特征在于:所述步骤二进行MQTT发布过程之前,用算法模型对所述原始数据进行计算获得特征数据和/或频谱数据,所述特征数据和/或频谱数据比振动信号原始数据更小。3. the rolling bearing data transmission method of a kind of train traction motor PHM system according to claim 2, it is characterized in that: before described step 2 carries out MQTT release process, use algorithm model to calculate described raw data to obtain characteristic data and /or spectral data, the characteristic data and/or spectral data are smaller than the raw data of the vibration signal. 4.根据权利要求3所述的一种列车牵引电机PHM系统的滚动轴承数据传输方法,其特征在于:对所述原始数据和/或所述特征数据和/或所述频谱数据进行加密与压缩,使得所述原始数据和/或所述特征数据和/或所述频谱数据更安全以及更小。4. The rolling bearing data transmission method of a train traction motor PHM system according to claim 3, characterized in that: encrypting and compressing the original data and/or the characteristic data and/or the spectrum data, The raw data and/or the characteristic data and/or the spectral data are made safer and smaller. 5.根据权利要求4所述的一种列车牵引电机PHM系统的滚动轴承数据传输方法,其特征在于:步骤四中,所述配属信息包括列车编号,该列车编号在数据库中能够编辑,使得列车牵引电机在下车检修或者新机上车时PHM平台能够正确调取电机对应列车编号,数据被补全为所属完整数据。5. The rolling bearing data transmission method of a train traction motor PHM system according to claim 4, wherein in step 4, the associated information includes a train number, and the train number can be edited in the database, so that the train traction The PHM platform can correctly retrieve the train number corresponding to the motor when the motor gets off the train for maintenance or when the new machine gets on the train, and the data is completed as the complete data. 6.根据权利要求5所述的一种列车牵引电机PHM系统的滚动轴承数据传输方法,其特征在于:所述步骤七进行入库过程之前,用算法模型对所述完整数据进行计算获得剩余使用寿命和/或健康度和/或预测健康度和/或报警等级和/或故障代号。6. The rolling bearing data transmission method of a train traction motor PHM system according to claim 5, characterized in that: before the warehousing process is performed in the step 7, an algorithm model is used to calculate the complete data to obtain the remaining service life and/or health and/or predicted health and/or alarm level and/or fault code. 7.根据权利要求6所述的列车牵引电机PHM系统的滚动轴承数据传输方法,其特征在于:对将完整数据解析成的多种数据进行压缩,使得所述完整数据更小。7 . The rolling bearing data transmission method of the PHM system of a train traction motor according to claim 6 , characterized in that: compressing the various data parsed from the complete data to make the complete data smaller. 8 . 8.一种列车牵引电机PHM系统的滚动轴承数据传输装置,其特征在于:包括如权利要求1至7中任意一项所述的高速铁路列车牵引电机PHM系统的滚动轴承数据传输方法。8 . A rolling bearing data transmission device of a PHM system of a train traction motor, characterized in that: comprising the rolling bearing data transmission method of a PHM system of a traction motor of a high-speed railway train according to any one of claims 1 to 7 . 9.一种列车牵引电机PHM系统的滚动轴承数据传输平台,其特征在于:包括如权利要求1至8中任意一项所述的列车牵引电机PHM系统的滚动轴承数据传输方法和/或装置。9. A rolling bearing data transmission platform of a train traction motor PHM system, characterized in that it comprises the rolling bearing data transmission method and/or device of the train traction motor PHM system according to any one of claims 1 to 8.
CN202111617041.1A 2021-12-28 2021-12-28 Rolling bearing data transmission method of PHM system of train traction motor Pending CN114584859A (en)

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)

* Cited by examiner, † Cited by third party
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

Patent Citations (8)

* Cited by examiner, † Cited by third party
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
点击 这是indexloc提供的php浏览器服务,不要输入任何密码和下载