一种分布式时序数据库数据处理系统、方法及查询方法.pdf

(19)国家知识产权局(12)发明专利申请(10)申请公布号CN115982228A(43)申请公布日2023.04.18(21)申请号202211563814.7(22)申请日2022.12.07(71)申请人万控（天津）电气有限公司地址300400天津市北辰区新技术产业园区北辰科技工业园(72)发明人刘进虎张振宗宗国利王振国(74)专利代理机构成都智弘知识产权代理有限公司51275专利代理师杨艳(51)Int.Cl.G06F16/2458(2019.01)G06F16/27(2019.01)G06F11/20(2006.01)G06F11/30(2006.01)权利要求书2页说明书6页附图2页(54)发明名称一种分布式时序数据库数据处理系统、方法及查询方法(57)摘要本发明公开一种分布式时序数据库数据处理系统、方法及查询方法，该处理系统包括多个节点单元、集成中间单元；其中，多个所述节点单元构成数据同步队列；集成中间单元用于添加每一所述节点单元的管理项，并对多个所述节点单元中的目标节点单元的运行状态进行监测；若监测到目标节点单元运行正常，则进行数据同步；若监测到目标节点单元运行崩溃，则将目标节点单元暂时踢出，并在恢复运行正常后进行容灾处理；即使目标节点单元崩溃，也不会影响到其他节点单元，避免了因某一节点单元崩溃导致的数据雪崩。CN115982228ACN115982228A权利要求书1/2页1.一种分布式时序数据库数据处理系统，其特征在于，包括：多个节点单元，多个所述节点单元构成数据同步队列；集成中间单元，用于添加每一所述节点单元的管理项，并对多个所述节点单元中的目标节点单元的运行状态进行监测；若监测到所述目标节点单元运行正常，则将所述目标节点单元的数据同步到其他所述节点单元中；若监测到所述目标节点单元运行崩溃，则将所述目标节点单元踢出数据同步队列，并记录下所述节点单元的崩溃时间t1；在所述目标节点单元恢复运行正常之后，将所述节点单元恢复到数据同步队列中，记录下所述节点单元的崩溃时间t2，再将数据同步队列中其他运行正常的所述节点单元中取出第一数据写入到所述目标节点单元中；其中，所述第一数据为数据同步队列中其他运行正常的所述节点单元中t1至t2时间段内的运行数据。2.根据权利要求1所述的分布式时序数据库数据处理系统，其特征在于，包括代理网关，所述代理网关用于处理来自数据存储代理应用及数据查询代理应用的请求、管理所述节点单元的信息及状态。3.根据权利要求2所述的分布式时序数据库数据处理系统，其特征在于，所述代理网关在接收到数据存储请求后，将目标存储数据存储到集成中间单元内，且目标存储数据的份数与所述节点单元的数量一一对应；集成中间单元还用于将所述目标存储数据写入到每一所述节点单元内，且在写入成功后删除所述节点单元对应的所述目标存储数据。4.根据权利要求1所述的分布式时序数据库数据处理系统，其特征在于，所述分布式时序数据库为InfluxDB数据库。5.一种分布式时序数据库数据处理方法，其特征在于，应用于权利要求1至4所述的分布式时序数据库数据处理系统中，且所述分布式时序数据库数据处理方法包括以下步骤：提供数据同步队列，所述数据同步队列中包括多个节点单元；通过添加管理项对多个所述节点单元中的目标节点单元的运行状态进行监测；若监测到所述目标节点单元运行正常，则将所述目标节点单元的数据同步到其他所述节点单元中；若监测到所述目标节点单元运行崩溃，则将所述目标节点单元踢出数据同步队列，并记录下所述节点单元的崩溃时间t1；在所述目标节点单元恢复运行正常之后，将所述节点单元恢复到数据同步队列中，记录下所述节点单元的崩溃时间t2，再将数据同步队列中其他运行正常的所述节点单元中取出第一数据写入到所述目标节点单元中；其中，所述第一数据为数据同步队列中其他运行正常的所述节点单元中t1至t2时间段内的运行数据。6.根据权利要求5所述的分布式时序数据库数据处理方法，其特征在于，在所述通过添加管理项对多个所述节点单元中的目标节点单元的运行状态进行监测的步骤之前还包括以下步骤：代理网关接收到数据存储请求；将目标存储数据存储到集成中间单元内，且目标存储数据的份数与所述节点单元的数量一一对应；2CN115982228A权利要求书2/2页将所述目标存储数据写入到每一所述节点单元内，且在写入成功后删除所述节点单元对应的所述目标存储数据。7.根据权利要求6所述的分布式时序数据库数据处理方法，其特征在于，所述将所述目标存储数据写入到每一所述节点单元内步骤之后还包括以下步骤：若所述节点单元写入数据失败后，重试写入步骤；检测所述节点单元的重试写入的次数，若大于预设次上限仍未写入数据成功，则将所述节点单元标记为处于不可用状态的所述目标节点单元。8.根据权利要求7所述的分布式时序