公开(公告)号：CN115237973A

公开(公告)日：2022-10-25

申请号：CN202110440894.6

申请日：2021-04-23

Applicant: 株洲中车时代电气股份有限公司

Inventor： 黄铖 ,  杨卫峰 ,  胡卫民 ,  邓健 ,  杨永滔 ,  成培 ,  雷静

IPC: G06F16/2458 ,  G06F16/248 ,  G06F16/242 ,  G06F16/27

Abstract: 本发明公开了一种列车状态数据回放方法、系统、电子设备及存储介质，该方法包括：通过预设程序接收由车载设备发送的实时状态数据，并将其存储至分布式消息队列；通过预设分布式框架从分布式消息队列中获取实时状态数据进行解析，并写入至分布式数据存储系统；将来自用户页面的查询参数发送至数据接口，并接收数据接口根据查询参数生成的查询条件；基于查询条件，通过预设分布式框架从分布式数据存储系统中并列查询历史数据，并将历史数据发送至用户页面进行展示。本发明数据存储灵活性高，数据写入速度快、数据查询速度快，回放时间范围宽，且能够有效避免数据缓存时的数据丢失或错误问题。

公开(公告)号：CN115733896A

公开(公告)日：2023-03-03

申请号：CN202110991202.7

申请日：2021-08-26

Applicant: 株洲中车时代电气股份有限公司

Inventor： 邓健 ,  杨卫峰 ,  黄铖 ,  胡卫民 ,  杨永滔 ,  蓝凡 ,  雷静

IPC: H04L69/22 ,  H04L69/06 ,  H04L67/12

Abstract: 本申请涉及一种列车数据处理分类方法、装置、计算机设备和存储介质。该方法包括：获取列车设备发送过来的实时数据包，封装成二进制数据结构，并写入到kafka消息队列中，形成原始数据流；从原始数据流中读取二进制数据，按照预设的规则将数据解析成点位信息，并写入到kafka消息队列中形成解析数据流；从解析数据流中获取数据内容，自动筛选出不同业务处理程序所需要的数据点位，写入到kafka消息队列中形成不同业务分类的数据流。该方法使得各业务功能模块相互独立，提高系统开发和产品功能组装的灵活性，同时增加后台处理系统的稳定性。提供了按需订阅所需要的数据能力，显著减轻功能模块的复杂度。