一种核电工业互联网平台的时序数据存储方法
摘要:
本发明提供了一种核电工业互联网平台的时序数据存储方法,包括如下步骤:各电厂接口机上的时序数据采集和上传工具将时序数据经由相应的MQTT客户端分别发送至核电工业互联网平台中心侧的MQTT服务器,并依据时序数据的属性分别上传到不同的Topic中;设置第一个消费者模块,第一个消费者模块订阅并消费MQTT服务器中的数据然后进行处理;Kafka系统接收第一个消费者模块发送过来的时序数据,把不同类型的时序数据存储在不同的Topic中;设置第二个消费者模块,第二个消费者模块订阅并消费Kafka消息系统中的数据然后进行处理;时序数据库用于将依据时序数据的属性将低频时序数据和高频时序数据分开保存。本发明提供的方法能够更加合理、高效地管理时序数据。
公开/授权文献
0/0