一种时序数据库的流计算方法
技术领域
[0001]
本发明涉及数据库技术领域,尤其涉及一种时序数据库的流计算方法。
背景技术
[0002]
时序数据是指时间序列数据。是按时间顺序记录的数据列,在同一数据列中的各
个数据必须是同口径的,要求具有可比性。时序数据可以是时期数,也可以时点数。
[0003]
时序数据管理主要通过对时序数据的采集、处理和分析帮助企业实时监控企业的
生产与经营过程。
[0004]
时序数据在应用上特点也很明显,比如数据往往只保留一定时长,需要做降频采
样、插值、实时计算、聚合等操作,关心的是一段时间的趋势,而不是某一特定时间的值等。
[0005]
工业企业为了监测设备、生产线以及整个系统的运行状态,在各个关键点都配有
传感器、采集各种数据。这些数据是周期或准周期产生的,有的采集频率高,有的采集频率
低,这些采集的数据一般会发送至服务器,进行汇总并实时处理,对系统的运行做出实时监
测或预警。
[0006]
随着工业物联网、数字能源、交通车联网、智慧产业等行业的核心业务场景下对时
序数据采集、处理、计算、分析、应用的综合业务需求的不断增加,对于时序大数据的存储和
处理,如果仍采用关系型数据库的方式进行处理,则无法满足高吞吐写入数据的同时快速
获取查询结果的要求。
发明内容
[0007]
为了解决以上技术问题,本发明提供了一种时序数据库的流计算方法,能够在高
吞吐的数据写入情况下,提供快速的计算结果查询,帮助用户快速的得到想要的查询结果,
为用户节省了大量的查询时间。
[0008]
本发明的技术方案是:
[0009]
一种时序数据库的流计算方法,根据时间窗口创建相应的流计算定时任务,对实
时的时序数据按照指定时间窗口进行计算,最终将计算结果存储在目标表中。
[0010]
进一步的,
[0011]
通过SQL定义实时数据流的计算规则,从而在时序数据库中保存相应的元数据信
息,并创建相关的目标表,同时启动相应时间窗口的定时任务;当数据写入数据库的源表
后,数据会被定时任务以指定的时间窗口进行自动计算,最终将结果自动地写入目标表。
[0012]
再进一步的,
[0013]
根据用户输入的SQL语句产生相关的流计算的元数据信息,并进行持久化。
[0014]
根据流计算的元数据信息创建目标表,用于存储流计算结果。
[0015]
根据流计算的元数据信息创建流计算的定时任务,对实时数据进行计算,并将计
算结果存储在目标表中。
[0016]
再进一步的,
说 明 书
1/2 页
3
相关文档
评论