详情

原文传递列车的运行数据采集法及系统

专利名称：	列车的运行数据采集法及系统
摘要：	本发明提出一种列车的运行数据采集方法及系统，其中，方法包括：数据网关从采集终端中获取数据包，并将数据包发送给消息队列中间件；消息队列中间件从数据包中提取采集终端的标识码，将数据包中的运行数据，存储到标识码对应的消息队列中；其中，不同的标识码对应不同的消息队列；当运行数据为数据中心所关注的数据时，消息队列中间件将运行数据发送给数据中心。该方法能够利用消息队列中间件高效可靠的消息传递机制，高效可靠地将运行数据传输给数据中心，有利于保证数据的完整性。此外，数据中心接收的只是自身感兴趣的数据，从而提升了数据中心处理数据的效率，保证系统的可靠性。
专利类型：	发明专利
国家地区组织代码：	广东;44
申请人：	比亚迪股份有限公司
发明人：	康腊梅;杨耕田
专利状态：	有效
申请日期：	2017-12-11T00:00:00+0800
发布日期：	2019-06-18T00:00:00+0800
申请号：	CN201711311276.1
公开号：	CN109895815A
代理机构：	北京清亦华知识产权代理事务所(普通合伙)
代理人：	张润
分类号：	B61L27/00(2006.01);B;B61;B61L;B61L27
申请人地址：	518118 广东省深圳市坪山新区比亚迪路3009号
主权项：	1.一种列车的运行数据采集方法，其特征在于，包括：数据网关从采集终端中获取数据包，并将所述数据包发送给消息队列中间件；所述消息队列中间件从数据包中提取所述采集终端的标识码，将所述数据包中的运行数据，存储到所述标识码对应的消息队列中；其中，不同的标识码对应不同的消息队列；当所述运行数据为数据中心所关注的数据时，所述消息队列中间件将所述运行数据发送给所述数据中心。 2.根据权利要求1所述的列车的运行数据采集方法，其特征在于，所述当所述运行数据为数据中心所关注的数据时，所述消息队列中间件将所述运行数据发送给所述数据中心，包括：所述消息队列中间件识别所述数据包中的运行数据所对应的列车设备；所述消息队列中间件判断所述列车设备是否为所述数据中心关注的设备；如果所述列车设备为所述数据中心关注的设备，所述消息队列中间件将所述运行数据发送给所述数据中心。 3.根据权利要求2所述的列车的运行数据采集方法，其特征在于，所述消息队列中间件识别所述数据包中的运行数据所对应的列车设备之前，还包括：所述消息队列中间件接收所述数据中心发送的订阅消息，其中所述订阅消息中携带所关注的至少一个列车设备；所述消息队列中间件判断所述列车设备是否为所述数据中心关注的设备，包括：所述消息队列中间件判断所述列车设备是否为订阅消息中携带的列车设备。 4.根据权利要求1所述的列车的运行数据采集方法，其特征在于，所述消息队列中间件将所述运行数据发送给所述数据中心之后，还包括：所述数据中心对接收到的所述运行数据进行故障诊断，以判断所述列车设备是否存在故障；如果存在故障，所述数据中心生成故障信息发送给列车控制中心。 5.根据权利要求1-4任一项所述的列车的运行数据采集方法，其特征在于，所述消息队列中间件将所述运行数据发送给所述数据中心之后，还包括：所述数据中心识别所述运行数据是否为列车的行车数据；如果所述运行数据为所述行车数据，所述数据中心将所述运行数据发送给云端进行存储；如果所述运行数据非所述行车数据，所述数据中心将所述运行数据缓存到所述数据中心中的存储设备中。 6.根据权利要求1-4任一项所述的列车的运行数据采集方法，其特征在于，所述数据网关从采集终端中获取数据包之前，还包括：所述数据网关对所述采集终端进行鉴权，在鉴权通过后与所述采集终端按照预设的通信协议构建网络连接；所述采集终端按照所述通信协议的所规定的格式生成所述数据包；所述采集终端对所述数据包进行加密；所述数据网关从采集终端中获取数据包，并将所述数据包发送给消息队列中间件，包括：所述数据网关采集加密后的所述数据包，并对加密后的所述数据包进行解密，并按照所述通信协议对解密后的所述数据包进行解析，得到所述数据包发送给所述消息队列中间件。 7.一种列车的运行数据采集系统，其特征在于，包括：数据网关、采集终端、消息队列中间件以及数据中心；其中，所述数据网关，用于从所述采集终端中获取数据包，并将所述数据包发送给所述消息队列中间件；所述消息队列中间件，用于从数据包中提取所述采集终端的标识码，将所述数据包中的运行数据，存储到所述标识码对应的消息队列中；其中，不同的标识码对应不同的消息队列，以及当所述运行数据为数据中心所关注的数据时，将所述运行数据发送给所述数据中心。 8.根据权利要求7所述的列车的运行数据采集系统，其特征在于，所述消息队列中间件，具体用于：识别所述数据包中的运行数据所对应的列车设备；判断所述列车设备是否为所述数据中心关注的设备；如果所述列车设备为所述数据中心关注的设备，将所述运行数据发送给所述数据中心。 9.根据权利要求8所述的列车的运行数据采集系统，其特征在于，所述消息队列中间件，还用于：接收所述数据中心发送的订阅消息，其中所述订阅消息中携带所关注的至少一个列车设备，以及判断所述列车设备是否为订阅消息中携带的列车设备。 10.根据权利要求7所述的列车的运行数据采集系统，其特征在于，还包括：列车控制中心；所述数据中心，用于对接收到的所述运行数据进行故障诊断，以判断所述列车设备是否存在故障，如果存在故障，所述数据中心生成故障信息发送给列车控制中心。 11.根据权利要求7-10任一项所述的列车的运行数据采集系统，其特征在于，所述数据中心，还用于识别所述运行数据是否为列车的行车数据，以及如果所述运行数据为所述行车数据，将所述运行数据发送给云端进行存储，而如果所述运行数据非所述行车数据，将所述运行数据缓存到所述数据中心中的存储设备中。 12.根据权利要求7-10任一项所述的列车的运行数据采集系统，其特征在于，所述数据网关，还用于对所述采集终端进行鉴权，在鉴权通过后与所述采集终端按照预设的通信协议构建网络连接，以及采集加密后的所述数据包，并对加密后的所述数据包进行解密，并按照所述通信协议对解密后的所述数据包进行解析，得到所述数据包发送给所述消息队列中间件。所述采集终端，还用于按照所述通信协议的所规定的格式生成所述数据包，并对所述数据包进行加密。 13.一种计算机设备，其特征在于，包括处理器和存储器；其中，所述处理器通过读取所述存储器中存储的可执行程序代码来运行与所述可执行程序代码对应的程序，以用于实现如权利要求1-6中任一所述的列车的运行数据采集方法。 14.一种计算机程序产品，当所述计算机程序产品中的指令由处理器执行时，执行如权利要求1-6中任一项所述的列车的运行数据采集方法。 15.一种计算机可读存储介质，其上存储有计算机程序，其特征在于，该计算机程序被处理器执行时实现如权利要求1-6中任一项所述的列车的运行数据采集方法。
所属类别：	发明专利