遥测数据处理方法、装置、设备及存储介质.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN114257646A(43)申请公布日2022.03.29(21)申请号202111560291.6(22)申请日2021.12.20(71)申请人浙江时空道宇科技有限公司地址310051浙江省杭州市滨江区西兴街道江陵路1782号1幢1505室申请人浙江吉利控股集团有限公司(72)发明人陈学洋程艳超丁晟(74)专利代理机构北京同立钧成知识产权代理有限公司11205代理人朱颖刘芳(51)Int.Cl.H04L67/568(2022.01)H04L67/30(2022.01)H04Q9/00(2006.01)权利要求书2页说明书11页附图6页(54)发明名称遥测数据处理方法、装置、设备及存储介质(57)摘要本申请提供一种遥测数据处理方法、装置、设备及存储介质。该遥测数据处理方法包括：根据遥测数据的类型，确定所述遥测数据对应的配置文件；基于所述遥测数据对应的配置文件，控制数据采集工具采集所述遥测数据，生成遥测流数据；将所述遥测流数据序列化至消息中间件中，以存储所述遥测流数据；基于分布式实时计算引擎拉取消息中间件中存储的遥测流数据，当所述遥测流数据触发预设事件时，基于所述预设事件对应的处理规则对所述遥测流数据进行数据处理，并将处理结果返回至消息中间件中或将处理结果发送至目标端；实现了多类型数据的实时存储，以及基于各种业务需求的遥测数据处理，提高了遥测数据处理的通用性以及效率。CN114257646ACN114257646A权利要求书1/2页1.一种遥测数据处理方法，其特征在于，所述方法包括：根据遥测数据的类型，确定所述遥测数据对应的配置文件；基于所述遥测数据对应的配置文件，控制数据采集工具采集所述遥测数据，生成遥测流数据；将所述遥测流数据序列化至消息中间件中，以存储所述遥测流数据；基于分布式实时计算引擎拉取消息中间件中存储的遥测流数据，当所述遥测流数据触发预设事件时，基于所述预设事件对应的处理规则对所述遥测流数据进行数据处理，并将处理结果返回至消息中间件中或将处理结果发送至目标端。2.根据权利要求1所述的方法，其特征在于，基于所述预设事件对应的处理规则对所述遥测流数据进行数据处理，并将处理结果返回至消息中间件中或将处理结果发送至目标端，包括：获取所述遥测流数据触发的预设事件的异常判断预定义文件；基于分布式实时计算引擎的复杂事件处理单元根据所述异常判断预定义文件，对所述遥测流数据进行异常检测；基于异常检测结果，生成卫星状态告警信息，并将所述卫星状态告警信息发送至目标端。3.根据权利要求1所述的方法，其特征在于，所述遥测数据包括拷机测试数据、功率测量精度数据、定位精度数据、失锁重捕数据、通道时延一致性数据中的一项或多项。4.根据权利要求3所述的方法，其特征在于，当所述遥测数据为定位精度数据时，触发定位精度计算事件；基于所述定位精度计算对应的处理规则对所述定位精度数据进行数据处理，并将处理结果返回至消息中间件中或将处理结果发送至目标端，包括：对所述定位精度流数据进行反序列化，得到各个信号支路的第一坐标定位误差、第二坐标定位误差和第三坐标定位误差；基于分布式实时计算引擎的转换算子，根据各个信号支路的第一坐标定位误差、第二坐标定位误差和第三坐标定位误差，确定各个信号支路的最大综合误差；当任意一个信号支路的最大综合误差大于预设误差时，生成定位精度告警信息；将所述定位精度告警信息发送至目标端。5.根据权利要求1所述的方法，其特征在于，在基于分布式实时计算引擎拉取消息中间件中存储的遥测流数据之后，所述方法还包括：基于分布式实时计算引擎对所拉取的遥测流数据进行数据清洗；当所述遥测流数据未触发预设事件时，将清洗后的遥测流数据回流至消息中间件以及写入列式存储引擎中，以进行备份。6.根据权利要求5所述的方法，其特征在于，在将清洗后的遥测流数据写入列式存储引擎中之后，所述方法还包括：通过Java数据库连接的方式读取列式存储引擎数据库中存储的清洗后的遥测流数据；采用Websocket协议将处理后的遥测数据实时推送至目标端进行展示。7.根据权利要求1‑6任一项所述的方法，其特征在于，所述方法还包括：将处理后的遥测流数据以及处理结果持久化存储至分布式文件存储系统中。8.一种遥测数据处理装置，其特征在于，所述装置包括：2CN114257646A权利要求书2/2页配置文件确定模块，用于根据遥测数据的类型，确定所述遥测数据对应的配置文件；数据采集模块，用于基于所述遥测数据对应的配置文件，控制数据采集工具采集所述遥测数据，生成遥测流数据；数据存储模块，用于将所述遥测流数据序列化至消息中间件中，以存储所述遥测流数据；数据处理模块，用于基于分布式实时计算引擎拉取消息中间件中存储的遥测流数据，当所述遥测