CN108327745A - 一种列车数据实时解析方法和装置 - Google Patents

Abstract

本发明实施例提供一种列车数据实时解析方法和装置。所述方法包括：接收WTD传输的列车数据包，列车数据包包括有车型、数据接口类型，以及用于确定各列车参数的取值的数据内容；查找出与列车数据包中的车型和数据接口类型对应的解析配置信息；针对每个列车参数，根据解析配置信息中该列车参数对应的解析编码中的地址指示编码，从列车数据包中提取用于确定该列车参数的取值的数据内容；并根据解析配置信息中该列车参数对应的解析规则对提取出的数据内容进行解析，得到该列车参数的取值。所述装置用于执行上述方法。本发明实施例提供的方法和装置，能够提供列车数据的实时解析，且可保障数据解析的快速响应和准确性。

Description

一种列车数据实时解析方法和装置

技术领域

本发明实施例涉及数据处理领域，尤其涉及一种列车数据实时解析方法和装置。

背景技术

近年来，高速铁路取得飞速发展，高速动车组的运用为高铁建设奠定了良好的基础。然而动车组在为人们出行提供方便的同时，也给车辆运用检修部门提出了新的要求。为了保证动车组安全而高效的运用，满足动车组运营管理需要，需要在现有的维修服务管理基础上，进行维修服务管理的创新。

列车的PHM(Prognostics and Health Management，预测与健康管理)是未来列车运营保障的发展方向。PHM是根据列车运行现状监控和分析，进行有针对性、预测性的维修，提前预判故障的发生时机，而不必等到故障真的发生再进行事后维修。预测性的维修，可以降低维修成本，减少维修时间，提升列车运营的效率，同时，避免重大恶性事故发生。无论是从现有动车数据量来看，还是从长远发展规划来看，动车组PHM系统都应该采用大数据方式进行构建，以提高铁路各列车的监控的实时性和便捷性。

因此，有必要提供一种能够提供大规模的列车数据的实时解析的方案，以便为PHM系统提供实时监测的数据基础。

发明内容

针对现有技术中的缺陷，本发明实施例提供一种列车数据实时解析方法和装置，提供列车数据的实时解析的同时可保障数据解析的快速响应和准确性。

一方面，本发明实施例提供一种列车数据实时解析方法，包括：

接收无线传输装置WTD传输的列车数据包，所述列车数据包包括有车型、数据接口类型，以及用于确定各列车参数的取值的数据内容；

查找出与所述列车数据包中的所述车型和所述数据接口类型对应的解析配置信息；

针对每个列车参数，根据所述解析配置信息中该列车参数对应的解析编码中的地址指示编码，从所述列车数据包中提取用于确定该列车参数的取值的数据内容；并根据所述解析配置信息中该列车参数对应的解析规则对提取出的数据内容进行解析，得到该列车参数的取值。

另一方面，本发明实施例提供一种列车数据实时解析装置，包括：

接收模块，用于接收无线传输装置WTD传输的列车数据包，所述列车数据包包括有车型、数据接口类型，以及用于确定各列车参数的取值的数据内容；

查找模块，用于查找出与所述列车数据包中的所述车型和所述数据接口类型对应的解析配置信息；

解析模块，用于针对每个列车参数，根据所述解析配置信息中该列车参数对应的解析编码中的地址指示编码，从所述列车数据包中提取用于确定该列车参数的取值的数据内容；并根据所述解析配置信息中该列车参数对应的解析规则对提取出的数据内容进行解析，得到该列车参数的取值。

又一方面，本发明实施例提供一种电子设备，包括处理器、存储器和总线，其中：

所述处理器，所述存储器通过总线完成相互间的通信；

所述处理器可以调用存储器中的计算机程序，以执行上述方法的步骤。

再一方面，本发明实施例提供一种计算机可读存储介质，其上存储有计算机程序，该程序被处理器执行时实现上述方法的步骤。

本发明实施例提供的方法和装置，通过接收WTD传输的列车数据包，列车数据包包括有车型、数据接口类型，以及用于确定各列车参数的取值的数据内容；查找出与车型和所述数据接口类型对应的解析配置信息；针对每个列车参数，根据解析配置信息中该列车参数对应的解析编码中的地址指示编码，从所述列车数据包中提取用于确定该列车参数的取值的数据内容；并根据解析配置信息中该列车参数对应的解析规则对提取出的数据内容进行解析运算，得到该列车参数的取值，从而得到WTD传输的实时数据，且通过预先配置与车型和数据接口类型对应的解析配置信息可保障数据解析的快速响应和准确性。

附图说明

为了更清楚地说明本发明实施例或现有技术中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作一简单地介绍，显而易见地，下面描述中的附图是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其他的附图。

图1示出了根据本发明一个实施例的列车数据实时解析方法的示例性流程图；

图2示出了根据本发明一个实施例的列车数据实时解析装置的结构示意图；

图3示出了根据本发明一个实施例的电子设备的实体结构示意图。

具体实施方式

以下将结合附图对本发明的技术方案进行清楚、完整的描述，显然，所描述的实施例仅仅是本发明的一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动的前提下所得到的所有其它实施例，都属于本发明所保护的范围。

本申请使用的“模块”、“装置”等术语旨在包括与计算机相关的实体，例如但不限于硬件、固件、软硬件组合、软件或者执行中的软件。例如，模块可以是，但并不仅限于：处理器上运行的进程、处理器、对象、可执行程序、执行的线程、程序和/或计算机。举例来说，计算设备上运行的应用程序和此计算设备都可以是模块。一个或多个模块可以位于执行中的一个进程和/或线程内，一个模块也可以位于一台计算机上和/或分布于两台或更多台计算机之间。

下面结合附图详细说明本发明的技术方案。

参考图1，其示出了根据本发明一个实施例的列车数据实时解析方法的示例性流程图。

如图1所示，本发明实施例提供的列车数据实时解析方法，可以包括如下步骤：

S110：接收WTD传输的列车数据包，列车数据包包括有车型、数据接口类型，以及用于确定各列车参数的取值的数据内容。

考虑在Hadoop(海杜普)平台中MapReduce(映射归约)计算框架将中间输出和结果存储在HDFS(Hadoop Distributed File System，Hadoop分布式文件系统)中，MapReduce读写HDFS造成磁盘IO(InputOutput，输入输出)压力大，无法满足大规模数据的实时解析与输出的需求。而Spark计算框架允许将中间输出和结果存储在内存中，并支持数据在内存中的计算，这样不仅可节省大量磁盘IO，而且可提高数据处理速度，便于实现大规模数据的实时解析和输出。

因此，本发明实施例提供的列车数据实时解析方法适用于Spark流程序；Spark流程序处理Hadoop平台接收WTD(Wireless Transi无线传输装置)传输的列车数据包。

实际应用中，Spark流程序可以从Hadoop平台在同一时段接收多个WTD传输的列车数据包；当同时接收多个WTD传输的列车数据包时，可以并行处理每个WTD传输的列车数据包。对于每个WTD，该WTD可以按照对应的传输周期进行列车数据包的定期传输。

本发明实施例中，接收的列车数据包中可以包括：包头和数据内容。其中，列车数据包的包头包括但不限于：传输列车数据包的WTD所属列车的车型、传输列车数据包所使用的接口的数据接口类型、列车数据内容所占长度等；列车数据包中携带的数据内容可以包括用于确定各列车参数的取值的数据内容。

实际应用中，WTD所属列车的车型可以使用预设的技术序列代码表示。

本发明实施例中，数据接口类型包括但不限于：主故障类、实时数据类、故障通报数据类。对于不同的数据接口类型可以通过不同的配置码表示。

本发明实施例中，在从Hadoop平台接收到WTD传输的列车数据包之后，可以针对每个列车数据包，从该列车数据包的包头中提取出传输该列车数据包的WTD所属列车的车型，以及传输该列车数据包所使用的接口的数据接口类型。

S120：查找出与列车数据包中的车型和数据接口类型对应的解析配置信息。

本发明实施例中，预先针对不同的列车车型，配置有对应的解析配置协议；解析配置协议中针对不同的数据接口类型，配置有对应的解析配置信息，并存储到数据库中。这样，Spark流程序在提取出数据接口类型和技术序列代码对应的车型之后，可以根据车型和数据接口类型，从数据库中查找出对应的解析配置信息。实际应用中，通过解析配置协议的配置，可保障车型对应的解析配置协议更新的快速更新，同时可便于新车型的解析配置协议的快速拓展。

其中，解析配置信息可以包括：各列车参数各自对应的解析编码、各列车参数各自对应的解析规则。

实际应用中，解析配置信息还可以包括；数据来源、车型、数据接口类型、列车参数的名称、列车参数的单位、列车参数所属系统的名称、列车参数所属系统的编码。解析配置信息中所涉及的列车参数包括：列车运行参数，和/或列车车载设备参数。

本发明实施例中，列车参数与解析编码一一对应；对于一个列车参数，可以根据该列车参数的解析算法，预先配置有对应的解析规则；对于一个解析规则，与该解析规则对应的列车参数可以有一个或多个。

实际应用中，可以预先针对每个车型下的每个数据接口类型，确定该数据接口类型下的所有列车参数的解析算法；并对各列车参数的解析算法进行统计分类，对于同一类的解析算法，构建一个对应的解析规则；将构建的解析规则存储于解析规则库中。

例如，若列车参数1与列车参数2的解析算法相似，均为“先转10进制后判断是否大于等于某一个阈值，如果是，则减去某一个参考值，如果否则保持原数”，则列车参数1与列车参数2各自对应的解析规则为同一解析规则。其中，列车参数1的解析算法中的阈值与列车参数2的解析算法中的阈值可以相同或不同；列车参数1的解析算法中的参考值与列车参数2的解析算法中的参考值可以相同或不同。

S130：针对每个列车参数，根据解析配置信息中该列车参数对应的解析编码中的地址指示编码，从列车数据包中提取用于确定该列车参数的取值的数据内容；并根据解析配置信息中该列车参数对应的解析规则对提取出的数据内容进行解析，得到该列车参数的取值。

具体地，Spark流程序可以针对每个列车参数，从解析配置信息中确定出该列车参数对应的解析编码和解析规则；根据该列车参数对应的解析编码中的地址指示编码，从列车数据包中提取用于确定列车参数的取值的数据内容；并调用该列车参数对应的解析规则所对应的解析函数对提取出的数据内容进行解析，得到列车参数的取值。

本发明实施例中，对于同一解析规则具有唯一对应的解析函数，与解析规则对应的解析函数是预先配置并存储的，如表1所示。

表1

为了便于描述，本发明实施例中，将列车数据包中的数据内容称为目标解析内容。其中，列车数据包中的数据内容可以包括但不限于用于确定列车参数的取值的数据内容、用于确定参数控制字段的取值的数据内容、和/或用于确定主控车标记字段的取值的数据内容。

本发明实施例中，解析编码中可以包括：车型编码、数据接口类型编码和地址指示编码。其中，地址指示编码用于指示目标解析内容在列车数据包中的地址。

实际应用中，车型编码占3个bit(比特)位的编码，数据接口类型编码占2个bit位，地址指示编码所占的bit位数可以根据目标解析内容的长度来配置。

通常，可以分为以下五种情况：

1)在目标解析内容占据一个字节(单字节)的情况下，地址指示编码占L个bit位，通过L个bit位的编码指示目标解析内容所占据的字节。L为大于或等于4的整数。

2)在目标解析内容占据一个字节(单字节)中的某一bit位的情况下，地址指示编码占L+1个bit位，其中，通过L个bit位的编码指示目标解析内容所占据的字节，通过1个bit位的编码指示目标解析内容在占据的字节中的某一bit位。

3)在目标解析内容占据一个字节(单字节)中的多个bit位的情况下，地址指示编码占L+2个bit位，其中，通过L个bit位的编码指示目标解析内容所占据的字节，通过1个bit位的编码指示目标解析内容在占据的字节中的某一bit位开始，通过1个bit为的编码指示目标解析内容所占据的长度。

4)在目标解析内容占据多个字节(多字节)的情况下，地址指示编码占2L+1个bit位，通过L个bit位的编码指示目标解析内容所占据的起始字节，“_”占据1个bit位，通过L个bit位的编码指示目标解析内容所占据的终止字节。

5)在目标解析内容占据多个字节中的多个bit位的情况下，地址指示编码占2L+3个bit位，通过L个bit位的编码指示目标解析内容所占据的起始字节，“_”占据1个bit位，通过L个bit位的编码指示目标解析内容所占据的终止字节，通过1个bit位的编码指示在起始字节中的起始bit位，通过1个bit位的编码指示在终止字节中的终止bit位。

本发明实施例提供的列车数据实时解析方法，通过接收WTD传输的列车数据包，列车数据包包括有车型、数据接口类型，以及用于确定各列车参数的取值的数据内容；查找出与车型和所述数据接口类型对应的解析配置信息；针对每个列车参数，根据解析配置信息中该列车参数对应的解析编码中的地址指示编码，从所述列车数据包中提取用于确定该列车参数的取值的数据内容；并根据解析配置信息中该列车参数对应的解析规则对提取出的数据内容进行解析运算，得到该列车参数的取值，从而得到WTD传输的列车数据包对应的实时解析数据，且通过预先配置与车型和数据接口类型对应的解析配置信息可保障数据解析的快速响应和准确性。

进一步地，本发明实施例中，在解析出各个列车参数的取值后，可以将解析出的各个列车参数的取值作为WTD传输的实时数据，存储于预设的实时数据库中。实际应用中，可以存储于Hbase数据库中。

进一步地，本发明实施例中，在将WTD传输的实时数据进行存储到预设的实时数据库之后，可以从实时数据库中提取WTD传输的实时数据，并输出至PHM系统，以供PHM系统对WTD传输的实时数据进行数据处理。

其中，数据处理包括如下至少一项：数据展示、故障分析、预判分析、预警分析。

在上述实施例的基础上，本发明又一实施例提供的列车数据实时解析方法中，所述列车数据包还包括：列车标识；

相应地，所述方法还包括：

根据预设的解析黑名单和所述列车标识，判断所述列车数据包是否为待解析的数据包；以及

相应地，所述查找出与所述列车数据包中的所述车型和所述数据接口类型对应的解析配置信息，包括：

若所述列车数据包为待解析的数据包，则查找出与所述列车数据包中的所述车型和所述数据接口类型对应的解析配置信息。

本发明实施例中，预先设置有解析黑名单，解析黑名单中包括预先设置为无需进行数据包解析的列车的列车标识。实际应用中，对于一些测试车车型的WTD传输的列车数据包无需进行实时解析，因此，可以将一些测试车的列车标识添加至解析黑名单。当然，也可以根据实际需求，将指定的列车的列车标识添加到解析黑名单中。

相应地，本发明实施例中，在接收WTD传输的列车数据包之后，可以从列车数据包的包头中提取上传该列车数据包的WTD所属列车的列车标识。实际应用中，列车标识可以具体为WTD所属列车的列号。

接着，将提取出的列车标识与解析黑名单中的列车标识进行比对，若解析黑名单中存在与提取出的列车标识匹配的列车标识，则确定列车数据包为无需解析的数据包；若解析黑名单中不存在与提取出的列车标识匹配的列车标识，则确定列车数据包为待解析的数据包。

相应地，在确定列车数据包为待解析的数据包之后，可以查找与列车数据包中的车型和数据接口类型对应的解析配置信息，以进行数据包的解析。

本发明实施例其他步骤与前述实施例步骤相似，本发明实施例不再赘述。

本发明实施例提供的列车数据实时解析方法，通过引入解析黑名单，可以实现无需解析的数据包的过滤，减小了解析压力，提高了解析速率。

在上述实施例的基础上，本发明又一实施例提供的列车数据实时解析方法中，所述列车数据包还包括；用于确定各参数控制字段的取值的数据内容；

相应地，所述解析配置信息还包括：各参数控制字段各自对应的解析编码。

其中，每个参数控制字段具有各自对应的列车参数。

相应地，所述方法还包括：

针对每个参数控制字段，根据该参数控制字段对应的解析编码中的地址指示编码，从所述列车数据包中提取用于确定该参数控制字段的取值的数据内容，将提取出的数据内容作为该参数控制字段的取值；

若所述参数控制字段的取值表示无效，则将所述参数控制字段对应的列车参数的取值标记无效；

若所述参数控制字段的取值表示有效，则将所述参数控制字段对应的列车参数的取值标记为有效。

本发明实施例中，解析配置信息中除了包括各列车参数各自对应的解析编码、各列车参数各自对应的解析规则，还可以进一步包括各参数控制字段各自对应的解析编码。

其中，对于解析配置信息中所包括的所有列车参数中存在一个或多个具有对应的参数控制字段的列车参数；每个参数控制字段对应一个列车参数，参数控制字段用于进行列车参数的取值的有效性判断。

本发明实施例中，针对每个参数控制字段，Spark流程序可以从解析配置信息中确定出该参数控制字段对应的解析编码；根据该参数控制字段对应的解析编码中的地址指示编码，从列车数据包中提取用于确定该参数控制字段的取值的数据内容，将提取出的数据内容作为该参数控制字段的取值。

其中，参数控制字段对应的解析编码中除了可以包括：车型编码、数据接口类型编码、地址指示编码，还可以包括该参数控制字段所对应的列车参数。

本发明实施例中，在得到参数控制字段的取值之后，可以根据参数控制字段的取值，来判断该参数控制字段所对应的列车参数的取值的有效性。

具体地，若参数控制字段的取值表示无效，则可确定该参数控制字段对应的列车参数的取值无效。若参数控制字段的取值表示有效，则可确定该参数控制字段对应的列车参数的取值有效。

可选地，本发明实施例中，解析配置信息还包括：各参数控制字段各自对应的解析规则。

针对每个参数控制字段，根据该参数控制字段对应的解析编码中的地址指示编码，从列车数据包中提取用于确定参数控制字段的取值的数据内容之后，可以调用参数控制字段对应的解析规则所对应的解析函数对提取出的数据内容进行解析，得到参数控制字段的取值。

实际应用中，可以对取值无效的列车参数进行无效标记。

这样，在对解析出的各个列车参数的取值进行存储时，存储取值无效的列车参数的无效标记，以便后续在PHM系统中进行实时数据展示时避免展示取值无效的列车参数的取值。

本发明实施例其他步骤与前述实施例步骤相似，本发明实施例不再赘述。

本发明实施例提供的列车数据实时解析方法，通过引入参数控制字段，可以实现对列车参数的取值的有效性判断，提高数据准确性。

在上述实施例的基础上，本发明又一实施例提供的列车数据实时解析方法中，所述列车数据包还包括：用于确定主控车标记字段的取值的数据内容。

相应地，所述解析配置信息还包括：主控车标记字段对应配置的解析编码。

相应地，所述方法还包括：

根据所述主控车标记字段对应配置的解析编码中的地址指示编码，从所述列车数据包中提取确定所述主控车标记字段的取值的数据内容，将提取出的数据内容作为所述主控车标记字段的取值；

若所述主控车标记字段的取值表示主控车，则确定解析出的各个列车参数的取值为主控车的实时数据；

若所述主控车标记字段的取值表示非主控车，则确定解析出的各个列车参数的取值为非主控车的实时数据。

本发明实施例中，解析配置信息中除了包括各列车参数各自对应配置的解析编码、各列车参数各自对应配置的解析规则，还可以进一步包括主控车标记字段对应配置的解析编码、主控车标记字段对应配置的解析规则。

其中，主控车标记字段对应配置的解析编码中可以包括：车型编码、数据接口类型编码、地址指示编码。

本发明实施例中，从解析配置信息中确定出主控车标记字段对应而配置的解析规则之后，可以根据主控车标记字段对应配置的解析编码中的地址指示编码，从列车数据包中提取用于确定主控车标记字段的取值的数据内容，将提取出的数据内容作为主控车标记字段的取值。

接着，若主控车标记字段的取值表示主控车，则可以确定WTD所属的列车为主控车，解析出的各列车参数的取值为主控车的实时数据，；若主控车标记字段的取值表示非主控车，则可以确定WTD所属的列车为非主控车，解析出的各列车参数的取值为非主控车的实时数据。

可选地，本发明实施例中，解析配置信息还包括：各主控车标记字段各自对应配置的解析规则。

相应地，从解析配置信息中确定出主控车标记字段对应配置的解析编码的同时，可以从解析配置信息中确定出主控车标记字段对应配置的解析规则；继而，根据主控车标记字段对应配置的解析编码中的地址指示编码，从列车数据包中提取用于确定主控车标记字段的取值的数据内容；并调用主控车标记字段对应配置的解析规则所对应的解析函数对提取出的数据内容进行解析，得到主控车标记字段的取值。

进一步地，所述方法还包括：将标记为主控车的所述WTD实时数据存储至第一数据库中；将标记为非主控车的所述WTD实时数据存储至第二数据库中。

本发明实施例其他步骤与前述实施例步骤相似，本发明实施例不再赘述。

本发明实施例提供的列车数据实时解析方法，通过引入主控车标记字段，可以实现对来自主控车的WTD的列车数据包的标记，便于后续针对主控车的数据进行针对性处理。

进一步地，本发明又一实施例提供的列车数据实时解析方法中，所述方法还包括：

将所述主控车的实时数据输出至PHM系统，以使所述PHM系统对所述主控车的实时数据进行展示。

本发明实施例中，可以将主控车的实时数据和非主控车的实时数据进行存储到实时数据库中，比如存储至Hbase数据库中。

PHM系统展示时可以从实时数据库中提取出主控车的实时数据进行展示。

实际应用中，PHM系统还可以基于提取出的主控车的实时数据进行故障分析、预判分析等。

本发明实施例其他步骤与前述实施例步骤相似，本发明实施例不再赘述。

本发明实施例提供的列车数据实时解析方法，通过对主控车的数据的处理，可减小PHM系统数据处理压力。

在上述各实施例的基础上，本发明又一实施例提供了一种列车数据实时解析装置。

参考图2，其示出了根据本发明一个实施例的列车数据实时解析装置的结构示意图。

如图2所示，本发明实施例提供的列车数据实时解析装置200可以包括：接收模块201、查找模块202和解析模块203。

其中，接收模块201用于接收无线传输装置WTD传输的列车数据包，所述列车数据包包括有车型、数据接口类型，以及用于确定各列车参数的取值的数据内容；

查找模块202用于查找出与所述列车数据包中的所述车型和所述数据接口类型对应的解析配置信息；

解析模块203用于针对每个列车参数，根据所述解析配置信息中该列车参数对应的解析编码中的地址指示编码，从所述列车数据包中提取用于确定该列车参数的取值的数据内容；并根据所述解析配置信息中该列车参数对应的解析规则对提取出的数据内容进行解析，得到该列车参数的取值。

可选地，所述列车数据包还包括：列车标识；

相应地，所述查找模块202还用于根据预设的解析黑名单和所述列车标识，判断所述列车数据包是否为待解析的数据包；根据预设的解析黑名单和所述列车标识，判断所述列车数据包是否为待解析的数据包。若所述列车数据包为待解析的数据包，则查找出与所述列车数据包中的所述车型和所述数据接口类型对应的解析配置信息。

可选地，本发明实施例提供的列车数据实时解析装置200还可以包括：存储模块。

存储模块用于将解析出的各个列车参数的取值作为WTD传输的实时数据，存储于预设的实时数据库中。

可选地，本发明实施例提供的列车数据实时解析装置200还可以包括：输出模块。

输出模块用于从所述实时数据库中提取所述WTD传输的实时数据，并输出至预测与健康管理PHM系统，以供所述PHM系统对所述WTD传输的实时数据进行数据处理；

其中，所述数据处理包括如下至少一项：数据展示、故障分析、预判分析、预警分析。

可选地，所述列车数据包还包括；用于确定各参数控制字段的取值的数据内容。

相应地，所述解析配置信息还包括：各参数控制字段各自对应的解析编码；其中，每个所述参数控制字段具有各自对应的列车参数；

所述解析模块203还用于针对每个参数控制字段，根据该参数控制字段对应的解析编码中的地址指示编码，从所述列车数据包中提取用于确定该参数控制字段的取值的数据内容，将提取出的数据内容作为该参数控制字段的取值；若所述参数控制字段的取值表示无效，则确定所述参数控制字段对应的列车参数的取值无效；若所述参数控制字段的取值表示有效，则确定所述参数控制字段对应的列车参数的取值有效。

可选地，所述列车数据包还包括：用于确定主控车标记字段的取值的数据内容。

相应地，所述解析配置信息还包括：主控车标记字段对应的解析编码。

所述解析模块203还用于根据所述主控车标记字段对应的解析编码中的地址指示编码，从所述列车数据包中提取确定所述主控车标记字段的取值的数据内容，将提取出的数据内容作为所述主控车标记字段的取值；

若所述主控车标记字段的取值表示主控车，则确定解析出的各个列车参数的取值为主控车的实时数据；

若所述主控车标记字段的取值表示非主控车，则确定解析出的各个列车参数的取值为非主控车的实时数据。

可选地，所述输出模块还用于将所述主控车的实时数据输出至PHM系统，以使所述PHM系统对所述主控车的实时数据进行展示。

本发明实施例提供的列车数据实时解析装置，通过接收WTD传输的列车数据包，列车数据包包括有车型、数据接口类型，以及用于确定各列车参数的取值的数据内容；查找出与车型和所述数据接口类型对应的解析配置信息；针对每个列车参数，根据解析配置信息中该列车参数对应的解析编码中的地址指示编码，从所述列车数据包中提取用于确定该列车参数的取值的数据内容；并根据解析配置信息中该列车参数对应的解析规则对提取出的数据内容进行解析运算，得到该列车参数的取值，从而得到WTD传输的列车数据包对应的实时解析数据，且通过预先配置与车型和数据接口类型对应的解析配置信息可保障数据解析的快速响应和准确性。

本发明提供的列车数据实时解析装置的实施例具体可以用于执行上述各方法实施例的处理流程，其功能在此不再赘述，可以参照上述方法实施例的详细描述。

参考图3，其示出了根据本发明一个实施例的电子设备的实体结构示意图。如图3所示，该电子设备300可以包括：处理器(processor)301、存储器(memory)302和总线303，其中，处理器301，存储器302通过总线303完成相互间的通信。处理器301可以调用存储器302中的计算机程序，以执行上述各方法实施例所提供的方法，例如包括：

接收无线传输装置WTD传输的列车数据包，所述列车数据包包括有车型、数据接口类型，以及用于确定各列车参数的取值的数据内容；查找出与所述列车数据包中的所述车型和所述数据接口类型对应的解析配置信息；针对每个列车参数，根据所述解析配置信息中该列车参数对应的解析编码中的地址指示编码，从所述列车数据包中提取用于确定该列车参数的取值的数据内容；并根据所述解析配置信息中该列车参数对应的解析规则对提取出的数据内容进行解析，得到该列车参数的取值。

在另一种实施方式中，所述处理器301执行所述计算机程序时实现如下方法：

所述列车数据包还包括：列车标识；

相应地，所述方法还包括：

根据预设的解析黑名单和所述列车标识，判断所述列车数据包是否为待解析的数据包；以及

相应地，所述查找出与所述列车数据包中的所述车型和所述数据接口类型对应的解析配置信息，包括：

若所述列车数据包为待解析的数据包，则查找出与所述列车数据包中的所述车型和所述数据接口类型对应的解析配置信息。

在另一种实施方式中，所述处理器301执行所述计算机程序时实现如下方法：所述方法还包括：

将解析出的各个列车参数的取值作为WTD传输的实时数据，存储于预设的实时数据库中。

在另一种实施方式中，所述处理器301执行所述计算机程序时实现如下方法：所述方法还包括：

从所述实时数据库中提取所述WTD传输的实时数据，并输出至预测与健康管理PHM系统，以供所述PHM系统对所述WTD传输的实时数据进行数据处理；

其中，所述数据处理包括如下至少一项：数据展示、故障分析、预判分析、预警分析。

在另一种实施方式中，所述处理器301执行所述计算机程序时实现如下方法：

所述列车数据包还包括；用于确定各参数控制字段的取值的数据内容；

相应地，所述解析配置信息还包括：各参数控制字段各自对应的解析编码；其中，每个所述参数控制字段具有各自对应的列车参数；

相应地，所述方法还包括：

针对每个参数控制字段，根据该参数控制字段对应的解析编码中的地址指示编码，从所述列车数据包中提取用于确定该参数控制字段的取值的数据内容，将提取出的数据内容作为该参数控制字段的取值；

若所述参数控制字段的取值表示无效，则确定所述参数控制字段对应的列车参数的取值无效；

若所述参数控制字段的取值表示有效，则确定所述参数控制字段对应的列车参数的取值有效。

在另一种实施方式中，所述处理器301执行所述计算机程序时实现如下方法：

所述列车数据包还包括：用于确定主控车标记字段的取值的数据内容；

相应地，所述解析配置信息还包括：主控车标记字段对应的解析编码；

相应地，所述方法还包括：

根据所述主控车标记字段对应的解析编码中的地址指示编码，从所述列车数据包中提取确定所述主控车标记字段的取值的数据内容，将提取出的数据内容作为所述主控车标记字段的取值；

若所述主控车标记字段的取值表示主控车，则确定解析出的各个列车参数的取值为主控车的实时数据；

若所述主控车标记字段的取值表示非主控车，则确定解析出的各个列车参数的取值为非主控车的实时数据。

在另一种实施方式中，所述处理器301执行所述计算机程序时实现如下方法：所述方法还包括：

将所述主控车的实时数据输出至PHM系统，以使所述PHM系统对所述主控车的实时数据进行展示。

本发明实施例提供的电子设备，至少具有以下技术效果：通过接收WTD传输的列车数据包，列车数据包包括有车型、数据接口类型，以及用于确定各列车参数的取值的数据内容；查找出与车型和所述数据接口类型对应的解析配置信息；针对每个列车参数，根据解析配置信息中该列车参数对应的解析编码中的地址指示编码，从所述列车数据包中提取用于确定该列车参数的取值的数据内容；并根据解析配置信息中该列车参数对应的解析规则对提取出的数据内容进行解析运算，得到该列车参数的取值，从而得到WTD传输的列车数据包对应的实时解析数据，且通过预先配置与车型和数据接口类型对应的解析配置信息可保障数据解析的快速响应和准确性。

本发明实施例公开一种计算机程序产品，所述计算机程序产品包括存储在非暂态计算机可读存储介质上的计算机程序，所述计算机程序包括程序指令，当所述程序指令被计算机执行时，计算机能够执行上述各方法实施例所提供的方法，例如包括：

接收无线传输装置WTD传输的列车数据包，所述列车数据包包括有车型、数据接口类型，以及用于确定各列车参数的取值的数据内容；查找出与所述列车数据包中的所述车型和所述数据接口类型对应的解析配置信息；针对每个列车参数，根据所述解析配置信息中该列车参数对应的解析编码中的地址指示编码，从所述列车数据包中提取用于确定该列车参数的取值的数据内容；并根据所述解析配置信息中该列车参数对应的解析规则对提取出的数据内容进行解析，得到该列车参数的取值。

本发明实施例提供一种非暂态计算机可读存储介质，所述非暂态计算机可读存储介质存储计算机程序，所述计算机程序使所述计算机执行上述各方法实施例所提供的方法，例如包括：

接收无线传输装置WTD传输的列车数据包，所述列车数据包包括有车型、数据接口类型，以及用于确定各列车参数的取值的数据内容；查找出与所述列车数据包中的所述车型和所述数据接口类型对应的解析配置信息；针对每个列车参数，根据所述解析配置信息中该列车参数对应的解析编码中的地址指示编码，从所述列车数据包中提取用于确定该列车参数的取值的数据内容；并根据所述解析配置信息中该列车参数对应的解析规则对提取出的数据内容进行解析，得到该列车参数的取值。

此外，上述的存储器中的逻辑指令可以通过软件功能单元的形式实现并作为独立的产品销售或使用时，可以存储在一个计算机可读取存储介质中。基于这样的理解，本发明的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质中，包括若干指令用以使得一台计算机装置(可以是个人计算机，服务器，或者网络装置等)执行本发明各个实施例所述方法的全部或部分步骤。而前述的存储介质包括：U盘、移动硬盘、只读存储器(ROM，Read-Only Memory)、随机存取存储器(RAM，Random Access Memory)、磁碟或者光盘等各种可以存储程序代码的介质。

以上所描述的装置实施例仅仅是示意性的，其中所述作为分离部件说明的单元可以是或者也可以不是物理上分开的，作为单元显示的部件可以是或者也可以不是物理单元，即可以位于一个地方，或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部模块来实现本实施例方案的目的。本领域普通技术人员在不付出创造性的劳动的情况下，即可以理解并实施。

通过以上的实施方式的描述，本领域的技术人员可以清楚地了解到各实施方式可借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件。基于这样的理解，上述技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来，该计算机软件产品可以存储在计算机可读存储介质中，如ROM/RAM、磁碟、光盘等，包括若干指令用以使得一台计算机装置(可以是个人计算机，服务器，或者网络装置等)执行各个实施例或者实施例的某些部分所述的方法。

最后应说明的是：以上实施例仅用以说明本发明的技术方案，而非对其限制；尽管参照前述实施例对本发明进行了详细的说明，本领域的普通技术人员应当理解：其依然可以对前述各实施例所记载的技术方案进行修改，或者对其中部分技术特征进行等同替换；而这些修改或者替换，并不使相应技术方案的本质脱离本发明各实施例技术方案的精神和范围。

Claims (10)

1.一种列车数据实时解析方法，其特征在于，包括：

接收无线传输装置WTD传输的列车数据包，所述列车数据包包括有车型、数据接口类型，以及用于确定各列车参数的取值的数据内容；

查找出与所述列车数据包中的所述车型和所述数据接口类型对应的解析配置信息；

针对每个列车参数，根据所述解析配置信息中该列车参数对应的解析编码中的地址指示编码，从所述列车数据包中提取用于确定该列车参数的取值的数据内容；并根据所述解析配置信息中该列车参数对应的解析规则对提取出的数据内容进行解析，得到该列车参数的取值。

2.根据权利要求1所述的方法，其特征在于，所述列车数据包还包括：列车标识；

相应地，所述方法还包括：

根据预设的解析黑名单和所述列车标识，判断所述列车数据包是否为待解析的数据包；以及

相应地，所述查找出与所述列车数据包中的所述车型和所述数据接口类型对应的解析配置信息，包括：

若所述列车数据包为待解析的数据包，则查找出与所述列车数据包中的所述车型和所述数据接口类型对应的解析配置信息。

3.根据权利要求1所述的方法，其特征在于，所述方法还包括：

将解析出的各个列车参数的取值作为WTD传输的实时数据，存储于预设的实时数据库中。

4.根据权利要求3所述的方法，其特征在于，所述方法还包括：

从所述实时数据库中提取所述WTD传输的实时数据，并输出至预测与健康管理PHM系统，以供所述PHM系统对所述WTD传输的实时数据进行数据处理；

其中，所述数据处理包括如下至少一项：数据展示、故障分析、预判分析、预警分析。

5.根据权利要求1-4任一所述的方法，其特征在于，所述列车数据包还包括；用于确定各参数控制字段的取值的数据内容；

相应地，所述解析配置信息还包括：各参数控制字段各自对应的解析编码；其中，每个所述参数控制字段具有各自对应的列车参数；

相应地，所述方法还包括：

针对每个参数控制字段，根据该参数控制字段对应的解析编码中的地址指示编码，从所述列车数据包中提取用于确定该参数控制字段的取值的数据内容，将提取出的数据内容作为该参数控制字段的取值；

若所述参数控制字段的取值表示无效，则确定所述参数控制字段对应的列车参数的取值无效；

若所述参数控制字段的取值表示有效，则确定所述参数控制字段对应的列车参数的取值有效。

6.根据权利要求1-4任一所述的方法，其特征在于，所述列车数据包还包括：用于确定主控车标记字段的取值的数据内容；

相应地，所述解析配置信息还包括：主控车标记字段对应的解析编码；

相应地，所述方法还包括：

根据所述主控车标记字段对应的解析编码中的地址指示编码，从所述列车数据包中提取确定所述主控车标记字段的取值的数据内容，将提取出的数据内容作为所述主控车标记字段的取值；

若所述主控车标记字段的取值表示主控车，则确定解析出的各个列车参数的取值为主控车的实时数据；

若所述主控车标记字段的取值表示非主控车，则确定解析出的各个列车参数的取值为非主控车的实时数据。

7.根据权利要求6所述的方法，其特征在于，所述方法还包括：

将所述主控车的实时数据输出至PHM系统，以使所述PHM系统对所述主控车的实时数据进行展示。

8.一种列车数据实时解析装置，其特征在于，包括：

接收模块，用于接收无线传输装置WTD传输的列车数据包，所述列车数据包包括有车型、数据接口类型，以及用于确定各列车参数的取值的数据内容；

查找模块，用于查找出与所述列车数据包中的所述车型和所述数据接口类型对应的解析配置信息；

解析模块，用于针对每个列车参数，根据所述解析配置信息中该列车参数对应的解析编码中的地址指示编码，从所述列车数据包中提取用于确定该列车参数的取值的数据内容；并根据所述解析配置信息中该列车参数对应的解析规则对提取出的数据内容进行解析，得到该列车参数的取值。

9.一种电子设备，其特征在于，包括处理器、存储器和总线，其中：

所述处理器，所述存储器通过总线完成相互间的通信；

所述处理器可以调用存储器中的计算机程序，以执行如权利要求1-7任意一项所述的方法的步骤。

10.一种计算机可读存储介质，其上存储有计算机程序，其特征在于，该程序被处理器执行时实现如权利要求1-7任意一项所述方法的步骤。