一种基于列式存储的时序数据库系统

    公开(公告)号:CN110362572B

    公开(公告)日:2022-07-01

    申请号:CN201910554845.8

    申请日:2019-06-25

    Abstract: 本发明公开了一种基于列式存储的时序数据库系统,包括SQL解析器:将SQL通过解析转换为抽象语法树;逻辑计划生成器:利用抽象语法树生成逻辑查询计划,逻辑查询计划由关系代数表示;查询优化器:利用数据库的状态信息进行查询计划的优化,输出改写后的查询计划;执行器:以块迭代方式执行查询计划,负责与存储层进行交互,获取用户查询的数据;存储引擎:以行+列的方式存储数据。本发明采用列方式存储数据库中的数据,并基于列存储与rocksdb的结合实现了高速插入数据特性与传统数据库的索引功能,在执行器方面,改进了部分算子以与存储引擎的特性深度结合,同时利用现代处理器的新特性为查询加速。

    一种用于轨道交通多源流数据的分布式实时处理方法

    公开(公告)号:CN110096520B

    公开(公告)日:2021-08-17

    申请号:CN201910350049.2

    申请日:2019-04-28

    Abstract: 本发明公开了一种用于轨道交通多源流数据的分布式实时处理方法,该方法包括多源流数据的合并和合并后流数据的分布式处理两部分;多源流数据的合并首先对同一轨道线路上同一车辆的实时数据进行维度上的合并,对维度合并后得到的新流进行广度上的合并;合并后流数据的分布式处理在分布式系统上实现,分布式系统拥有两种类型的Manager,分别为JobManager以及TaskManager;设置多个JobManager;本发明具有一定的伸缩度,且整个架构的伸缩不会降低或增加整体的流处理计算量;本发明拥有性能高的特点;本发明在进行分布式处理时,采用了分布式多JobManager状态同步的方式实现了完全的分布式处理。

    动车组电气作业安全控制装置及动车组电气作业安全控制方法

    公开(公告)号:CN113156875A

    公开(公告)日:2021-07-23

    申请号:CN202110557512.8

    申请日:2021-05-21

    Abstract: 本发明涉及电气安全作业领域,具体涉及一种动车组电气作业安全控制装置及动车组电气作业安全控制方法,将安全锁与吊锁具相结合实现对动车组电气设备控制电源断路器断开状态的锁闭,所述吊锁内设置有由表面感测电极、按压开关、集成电路组成的断路器锁闭状态测控报警电路,当人体触碰吊锁锁体表面表面感测电极,可实现报警提示,同时配合作业标识牌的应用,使其所述动车组电气作业安全操作方法的实施更加完善。通过本发明装置及方法能够降低触电事故发生率,从而减少事故本身的直接经济损失和赔偿经济损失;降低伤亡人数或频率,从而减少工作时间停产造成的直接损失;通过创造良好的工作安全条件,提高生产率,从而增加公司产值和利润。

    一种轨道交通网络监测流数据的实时处理方法

    公开(公告)号:CN111090619A

    公开(公告)日:2020-05-01

    申请号:CN201911200527.8

    申请日:2019-11-29

    Abstract: 本发明公开了一种轨道交通网络监测流数据的实时处理方法,其特征在于,该方法包括以下步骤:首先采集监测数据,汇总到第三方综合运维云平台;然后在第三方运维云平台上建立Hadoop分布式文件系统HDFS,基于HDFS建立Hbase数据库,使用基于哈希的MapReduce方法进行数据的处理,并在Map和Reduce两个阶段之间增加流水线控制器,进而提高对流数据的实时处理性能,以降低Map和Reduce阶段间数据传输的时延;最后设计基于动态容增哈希技术的快速内存处理方法提高Reduce阶段的数据处理的实时性。本发明避免了Map阶段的分段、排序,消除了同步带来的阻塞,提高了流数据的实时处理能力。

    一种轨道交通流数据处理方法

    公开(公告)号:CN110971687A

    公开(公告)日:2020-04-07

    申请号:CN201911201991.9

    申请日:2019-11-29

    Abstract: 本发明公开了一种轨道交通流数据处理方法,该方法基于Kafka的消息分发并且设计Storm拓扑结构,通过Kafka汇总轨道交通客流及设备等监测数据形成数据源,并将数据源发送给Storm进行实时处理;Storm拓扑结构由数据源组件KafkaSpout和三个逻辑处理单元PreBolt、RunBolt以及PostBolt组成;通过ZooKeeper提供的Watcher接口则用于对Storm进行监听,通过监听来了解轨道交通信息等变化,然后控制Kafka集群做出相应的指令处理;本发明数据在程序的传递过程均采用随机分组的方式,分布式处理的过程使得数据处理的延时大大降低。

    一种轨道交通网络监测流数据的实时处理方法

    公开(公告)号:CN111090619B

    公开(公告)日:2023-05-23

    申请号:CN201911200527.8

    申请日:2019-11-29

    Abstract: 本发明公开了一种轨道交通网络监测流数据的实时处理方法,其特征在于,该方法包括以下步骤:首先采集监测数据,汇总到第三方综合运维云平台;然后在第三方运维云平台上建立Hadoop分布式文件系统HDFS,基于HDFS建立Hbase数据库,使用基于哈希的MapReduce方法进行数据的处理,并在Map和Reduce两个阶段之间增加流水线控制器,进而提高对流数据的实时处理性能,以降低Map和Reduce阶段间数据传输的时延;最后设计基于动态容增哈希技术的快速内存处理方法提高Reduce阶段的数据处理的实时性。本发明避免了Map阶段的分段、排序,消除了同步带来的阻塞,提高了流数据的实时处理能力。

    一种轨道交通网络客流数据中图结构数据的实时查询方法

    公开(公告)号:CN110083609B

    公开(公告)日:2021-06-08

    申请号:CN201910350630.4

    申请日:2019-04-28

    Abstract: 本发明公开了一种轨道交通网络客流数据中图结构数据的实时查询方法,对带有属性和标签的数据图进行基于跳数的分区,并建立相关索引;输入查询图,计算查询图的半径并选取查询起始点;生成查询图的查询序列;在各个分区内根据查询图的查询起始点的特征过滤出满足条件的数据图的查询起始点;进行级联式的图查询过程;收集所有分区的查询结果,完成分布式图查询过程。本发明在跨分区查询过程中传输查询图而不传输数据图,进而减少了数据传输量;级联查询过程基于起始点而不在整个数据图范围内进行,进而大幅降低了查询范围;采用异步并发和查询时结果集检测,能够最大化查询效率,从而能够满足轨道交通网络客流数据中图结构数据的实时查询处理需求。

    继电器强吸工装
    8.
    实用新型

    公开(公告)号:CN218258158U

    公开(公告)日:2023-01-10

    申请号:CN202221867171.0

    申请日:2022-07-20

    Abstract: 本实用新型涉及继电器强吸工装,公开了一种继电器强吸工装,包括:活动铁芯、固定铁芯、吸合线圈座、锁紧卡套与底座,所述吸合线圈座包括圆柱体与固定架,所述圆柱体设置在固定架下方,所述固定铁芯上端套入在圆柱体与固定架之间,所述圆柱体安装在固定铁芯内部,所述底座设置在固定铁芯下方,所述锁紧卡套设置在底座上,所述活动铁芯由上至下穿过固定铁芯与吸合线圈座。使用本实用新型提供的强吸工装,可以缩短处理继电器故障的时间,在短时间内处理好继电器故障,快速恢复动车组电气控制回路功能状态,避免动车组因继电器故障造成动车组无法运行的情况;同时根据动车组自动控制要求,正常吸合、断开故障继电器,保障动车组安全稳定运行。

Patent Agency Ranking