-
公开(公告)号：CN116561221B
公开(公告)日：2024-03-19
申请号：CN202310440709.2
申请日：2023-04-21
申请人： 清华大学 , 天谋科技(北京)有限公司
摘要： 本发明提供支持物联网场景的分布式时序数据库副本共识协议的方法，包括：获取时序数据库的写入请求，在时序数据库的共识层执行本地写入请求；在所述共识层执行本地写入请求后向当前节点所在共识组内的其它节点执行写入请求，同步线程流程，形成副本组；基于所述同步线程流程，接收同步的共识写入请求，并更新系统状态；基于同步的共识写入请求，通过异步回调进行最终系统状态更新，完成时序数据库物联网共识建立。本发明解决了现有时序数据库日志写入成本高、缺少对整体资源控制的问题。
-
公开(公告)号：CN116561120B
公开(公告)日：2023-12-26
申请号：CN202310443507.3
申请日：2023-04-21
申请人： 清华大学 , 天谋科技(北京)有限公司
IPC分类号： G06F16/22 , G06F16/215 , G06F16/245 , G06F16/2457 , G06F16/2458 , G06F9/50
摘要： 本发明提供一种用于时序数据库的数据文件快速合并方法及系统，包括：从预设的初始文件列表中按字典序分批读取数据储存设备，依次遍历每个数据储存设备；基于每个数据储存设备读取所述数据储存设备下的序列，并将所述序列均分至多个子线程执行合并任务；所述子线程执行合并任务过程中识别具有重叠的数据点进行点优先级读取，重新排序，未重叠的数据点则无需重新排序，生成排序结果，根据所述排序结果将数据点写入目标文件，进行合并操作，完成数据文件的快速合并，解决现有时序数据库文件合并速率低、资源占用多的问题。
-
公开(公告)号：CN116561124A
公开(公告)日：2023-08-08
申请号：CN202310468738.X
申请日：2023-04-26
申请人： 清华大学 , 天谋科技(北京)有限公司
IPC分类号： G06F16/22 , G06F16/245 , G06F16/2457 , G06F16/2458 , G06F9/50
摘要： 本发明提供的用于时序数据库的文件合并方法和装置，所述时序数据库中的文件存储于顺序空间或乱序空间中，包括：在所述时序数据库的文件合并线程被触发之后，确定所述时序数据库可执行的文件合并任务；将所述文件合并任务按照优先级降序的方式缓冲至全局队列中；依次执行所述全局队列中的文件合并任务。本发明一次性将所有可执行的文件合并任务都选出后缓存在全局队列中，只要全局队列还有文件合并任务没有被执行，就会一直执行下去，避免了特定时机执行大量文件合并任务而引发前台读写性能波动的问题。
-
公开(公告)号：CN116561120A
公开(公告)日：2023-08-08
申请号：CN202310443507.3
申请日：2023-04-21
申请人： 清华大学 , 天谋科技(北京)有限公司
IPC分类号： G06F16/22 , G06F16/215 , G06F16/245 , G06F16/2457 , G06F16/2458 , G06F9/50
摘要： 本发明提供一种用于时序数据库的数据文件快速合并方法及系统，包括：从预设的初始文件列表中按字典序分批读取数据储存设备，依次遍历每个数据储存设备；基于每个数据储存设备读取所述数据储存设备下的序列，并将所述序列均分至多个子线程执行合并任务；所述子线程执行合并任务过程中识别具有重叠的数据点进行点优先级读取，重新排序，未重叠的数据点则无需重新排序，生成排序结果，根据所述排序结果将数据点写入目标文件，进行合并操作，完成数据文件的快速合并，解决现有时序数据库文件合并速率低、资源占用多的问题。
-
公开(公告)号：CN116775692B
公开(公告)日：2024-01-30
申请号：CN202310436472.0
申请日：2023-04-21
申请人： 清华大学 , 天谋科技(北京)有限公司
IPC分类号： G06F16/2453 , G06F16/2455 , G06F16/2458
摘要： 本发明提供一种用于时序数据库的分段聚合查询方法及系统，包括：从时序数据库中获取时序数据，将所述时序数据的时间序列进行切分，分为多个子段；通过时间序列的第一个数据点初始化第一个子段并计算聚合值；从时间序列的第二个数据点开始，通过时间序列分段逻辑判断当前数据点是否为分割点，生成判断结果；根据所述判断结果更新聚合值或重新初始化聚合值，直至所述时间序列全部遍历完成；对于定长时间区段分段，当子段之间存在重叠，将时间序列切分成多个长度固定的子段，每个子段产生一个聚合值；所述时间序列全部遍历完成后生成聚合结果，输出结果集，完成分段聚合查询。本发明解决了现有时序数据分析处理效率低的问题。
-
公开(公告)号：CN116561221A
公开(公告)日：2023-08-08
申请号：CN202310440709.2
申请日：2023-04-21
申请人： 清华大学 , 天谋科技(北京)有限公司
摘要： 本发明提供支持物联网场景的分布式时序数据库副本共识协议方法，包括：获取时序数据库的写入请求，在时序数据库的共识层执行本地写入请求；在所述共识层执行本地写入请求后向当前节点所在共识组内的其它节点执行写入请求，同步线程流程，形成副本组；基于所述同步线程流程，接收同步的共识写入请求，并更新系统状态；基于同步的共识写入请求，通过异步回调进行最终系统状态更新，完成时序数据库物联网共识建立。本发明解决了现有时序数据库日志写入成本高、缺少对整体资源控制的问题。
-
公开(公告)号：CN116737810A
公开(公告)日：2023-09-12
申请号：CN202310503870.X
申请日：2023-05-06
申请人： 清华大学 , 天谋科技(北京)有限公司
IPC分类号： G06F16/25 , G06F16/2455
摘要： 本发明提供一种用于分布式时序数据库的共识服务接口，主要包括创建接口、增删共识组接口和读写接口；其中，创建接口用于接入上层指定的共识算法；增删共识组接口用于创建/删除管理用户数据的共识组，读写接口用于通过共识算法将用户数据写入/读出对应的共识组。本发明共识服务接口对外统一且支持不同共识算法实现，可以为不同一致性需求的应用场景提供更契合的共识方案。
-
公开(公告)号：CN116560628A
公开(公告)日：2023-08-08
申请号：CN202310436195.3
申请日：2023-04-21
申请人： 清华大学 , 天谋科技(北京)有限公司
IPC分类号： G06F8/30 , G06F8/71 , G06F16/23 , G06F16/242 , G06F16/2455
摘要： 本发明提供一种用于时序数据库的触发器设计方法、系统及存储介质，包括：获取预设的编程接口，通过所述编程接口创建触发器设定类；将所述触发器设定类打包为指定格式的压缩包，并将所述压缩包放置在指定目录下；基于所述压缩包通过预设的结构化查询语言数据库命令向系统中注册触发器实例；进行数据写入，所述触发器实例进行响应，完成数据写入操作；其中，所述压缩包是通过打包命令进行压缩的，所述打包命令通过预设的项目对象模型工具提供。本发明解决了现有时序数据库难以自定义触发器实现复杂计算的问题。
-
公开(公告)号：CN116737810B
公开(公告)日：2024-06-25
申请号：CN202310503870.X
申请日：2023-05-06
申请人： 清华大学 , 天谋科技(北京)有限公司
IPC分类号： G06F16/25 , G06F16/2455
摘要： 本发明提供一种用于分布式时序数据库的共识服务接口，主要包括创建接口、增删共识组接口和读写接口；其中，创建接口用于接入上层指定的共识算法；增删共识组接口用于创建/删除管理用户数据的共识组，读写接口用于通过共识算法将用户数据写入/读出对应的共识组。本发明共识服务接口对外统一且支持不同共识算法实现，可以为不同一致性需求的应用场景提供更契合的共识方案。
-
公开(公告)号：CN116775692A
公开(公告)日：2023-09-19
申请号：CN202310436472.0
申请日：2023-04-21
申请人： 清华大学 , 天谋科技(北京)有限公司
IPC分类号： G06F16/2453 , G06F16/2455 , G06F16/2458
摘要： 本发明提供一种用于时序数据库的分段聚合查询方法及系统，包括：从时序数据库中获取时序数据，将所述时序数据的时间序列进行切分，分为多个子段；通过时间序列的第一个数据点初始化第一个子段并计算聚合值；从时间序列的第二个数据点开始，通过时间序列分段逻辑判断当前数据点是否为分割点，生成判断结果；根据所述判断结果更新聚合值或重新初始化聚合值，直至所述时间序列全部遍历完成；对于定长时间区段分段，当子段之间存在重叠，将时间序列切分成多个长度固定的子段，每个子段产生一个聚合值；所述时间序列全部遍历完成后生成聚合结果，输出结果集，完成分段聚合查询。本发明解决了现有时序数据分析处理效率低的问题。
-
-
-
-
-
-
-
-
-
搜索结果
339 条记录 (耗时 0.065 秒)
