(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210667907.8 (22)申请日 2022.06.14 (71)申请人 浪潮软件集团有限公司 地址 250100 山东省济南市高新区科航路 2877号 (72)发明人 李杨　 (74)专利代理 机构 济南信达专利事务所有限公 司 37100 专利代理师 潘悦梅 (51)Int.Cl. G06F 16/2455(2019.01) G06F 16/2457(2019.01) G06F 16/2458(2019.01) (54)发明名称 基于订阅发布的时序数据查询方法、 系统及 计算机介质 (57)摘要 本发明公开了基于订阅发布的时序数据查 询方法、 系统及计算机介质， 属于时序数据库技 术领域， 要解决的技术问题为基于时序数据库进 行时序数据查询时， 如何节省线程以减少内存资 源消耗。 包括如下步骤： 计算引擎作为订阅点提 交订阅请求， 所述订阅请求用于申请某段时间的 时序数据； 通过监听器监听到订阅请求后， 调用 订阅API， 通过订阅API将所述订阅请求对应的订 阅点更新至 所申请时序数据对应topic的订阅列 表中； 采集点采集时序数据后， 调用发布API， 通 过发布API查找所述时序数对应topic的订阅列 表， 并将所述时序数据发布至订阅列表中记录的 所有订阅点。 权利要求书2页 说明书5页 附图1页 CN 115168415 A 2022.10.11 CN 115168415 A 1.一种基于订 阅发布的时序数据查询方法， 其特征在于通过订 阅发布的方式将时序数 据的查询操作变为异步， 所述方法包括如下步骤： 计算引擎作为 订阅点提交订阅请求， 所述 订阅请求用于申请某段时间的时序数据； 通过监听器监听到订阅请求后， 调用订阅API， 通过订阅API将所述订阅请求对应的订 阅点更新至所申请时序数据对应topic的订阅列表中； 采集点采集时序数据后， 调用发布API， 通过发布API查找所述时序数对应topic的订阅 列表， 并将所述时序数据发布至订阅列表中记录的所有订阅点。 2.根据权利要求1所述的基于订阅发布的时序数据查询方法， 其特征在于通过监听器 监听到订阅请求后， 将订阅请求推送至消息队列， 消息队列调用订阅API， 通过订阅API将所 述订阅请求对应的订阅点更新至所申请时序数据对应topic的订阅列表中。 3.根据权利要求1或2所述的基于订 阅发布的时序 数据查询方法， 其特征在于通过订 阅 API将所述订阅请求对应的订阅点更新至所申请时序数据对应topic的订阅列表中， 包括如 下步骤： 基于订阅请求所申请的某段时间的时序数据， 判断是否存在所述时序数据对应的 topic； 如果存在， 判断所述订阅请求对应的订阅点是否存在于所述topic的订阅列表中， 如果 否， 将所述 订阅请求对应的订阅点更新至所述topic的订阅列表中； 如果不存在， 创建所述时序数据对应的topic， 并将所述订阅申请对应的订阅点更新至 所述topic的订阅列表中。 4.根据权利要求1或2所述的基于订 阅发布的时序 数据查询方法， 其特征在于所述发布 API通过多线程模式将时序数据发布至订阅列表中记录的所有订阅点。 5.一种基于订阅发布的时序数据查询系统， 其特征在于用于通过如权利要求1 ‑4任一 项所述的一种基于订阅发布的时序数据查询方法实现时序数据 的查询操作， 所述系统包 括： 计算引擎， 所述计算引擎作为订阅点提交订阅请求， 所述订阅请求用于申请某段时间 的时序数据； 监听器， 所述 监听器用于监听计订阅请求； 消息队列， 所述消息队列用于 接收并缓存监听器发送的订阅请求； 订阅API， 所述订阅API用于接收消息队列推送的订阅请求， 将所述订阅请求对应的订 阅点更新至所申请时序数据对应topic的订阅列表中； 采集点， 所述采集 点用于采集时序数据； 发布API， 所述发布API用于接收采集点采集的时序数据， 用于查找所述时序数对应 topic的订阅列表， 并将所述时序数据发布至订阅列表中记录的所有订阅点。 6.根据权利要求5所述的基于订阅发布的时序 数据查询系统， 其特征在于所述订阅API 用于通过如下步骤将所述订阅请求对应的订阅点更新至所申请时序数据对应t opic的订阅 列表中： 基于订阅请求所申请的某段时间的时序数据， 判断是否存在所述时序数据对应的 topic； 如果存在， 判断所述订阅请求对应的订阅点是否存在于所述topic的订阅列表中， 如果权　利　要　求　书 1/2 页 2 CN 115168415 A 2否， 将所述 订阅请求对应的订阅点更新至所述topic的订阅列表中； 如果不存在， 创建所述时序数据对应的topic， 并将所述订阅申请对应的订阅点更新至 所述topic的订阅列表中。 7.根据权利要求5所述的基于订阅发布的时序 数据查询系统， 其特征在于所述发布API 用于通过多 线程模式将时序数据发布至订阅列表中记录的所有订阅点。 8.计算机介质， 为计算机可读介质， 其特征在于， 所述计算机可读介质上存储有计算机 指令， 所述计算机指令在被处理器执行时， 使所述处理器执行权利要求1至4任一所述的方 法。权　利　要　求　书 2/2 页 3 CN 115168415 A 3