本技术涉及核电,尤其涉及一种时序数据传输方法和装置、电子设备及存储介质。
背景技术:
1、相关技术中,通过物理传感器采集核电厂运行过程中产生的生产运行数据,并将生产运行数据传输至异常检测端,来检测核电厂设备的运行状态。但是,生产运行数据通常是大规模的时序数据,物理传感器和异常检测端也分别位于不同的网络分区,这就涉及大量时序数据的跨网络分区传输。因此,如何实现大量时序数据的跨区域传输,成为了亟待解决的问题。
技术实现思路
1、本技术实施例的主要目的在于提出一种时序数据传输方法和装置、电子设备及存储介质,旨在实现大量时序数据的跨网络分区传输。
2、为实现上述目的,本技术实施例的第一方面提出了一种时序数据传输方法,所述方法包括:
3、将存储于第一网络分区的第一核电运行时序数据传输至预设数据摆渡设备,得到第二核电运行时序数据;所述第一核电运行时序数据和所述第二核电运行时序数据相同;
4、将存储于所述预设数据摆渡设备的所述第二核电运行时序数据传输至第二网络分区的预设存储空间,得到文件存储信息;所述第一网络分区与所述第二网络分区为不同的网络分区;所述文件存储信息包括所述第二核电运行时序数据在所述预设存储空间的存储地址;
5、将存储于所述预设存储空间的所述存储地址存储至第一消息队列,并获取所述存储地址在所述第一消息队列中的存储顺序;其中,所述第一消息队列位于所述第二网络分区;
6、按照所述存储顺序从所述第一消息队列获取所述存储地址,得到目标存储地址;
7、根据所述目标存储地址从所述预设存储空间获取所述第二核电运行时序数据,得到目标核电运行时序数据;
8、将所述目标核电运行时序数据传输至数据消费端;所述数据消费端位于所述第二网络分区。
9、在一些实施例,所述根据所述目标存储地址从所述预设存储空间获取所述第二核电运行时序数据,得到目标核电运行时序数据,包括:
10、根据所述目标存储地址从所述预设存储空间获取所述第二核电运行时序数据,得到第一候选核电运行时序数据;
11、对所述第一候选核电运行时序数据进行数据解析,得到第二候选核电运行时序数据;
12、将所述第二候选核电运行时序数据存储至第二消息队列;所述第二消息队列位于所述第二网络分区;
13、从所述第二消息队列获取所述第二候选核电运行时序数据,得到所述目标核电运行时序数据。
14、在一些实施例,在所述将所述第二候选核电运行时序数据存储至第二消息队列之前,所述时序数据传输方法还包括:
15、获取核电机组的机组编码;所述核电机组位于第一网络分区,所述核电机组为产生所述第二候选核电运行时序数据的机组;
16、根据所述机组编码对预设消息主题进行筛选,得到目标消息主题;所述目标消息主题包括预设消息队列;所述预设消息主题位于所述第二网络分区;
17、获取数据测点的测点编码;所述数据测点设置于所述核电机组,所述数据测点为产生所述第二候选核电运行时序数据的测点;
18、根据所述测点编码对所述预设消息队列进行筛选,得到所述第二消息队列。
19、在一些实施例,所述将所述第二候选核电运行时序数据存储至第二消息队列,包括:
20、获取所述第二候选核电运行时序数据的数据属性和数据质量;
21、若所述数据属性表征所述第二候选核电运行时序数据为生产数据,且所述数据质量表征所述第二候选核电运行时序数据为正常数据,则将所述第二候选核电运行时序数据存储至所述第二消息队列。
22、在一些实施例,所述对所述第一候选核电运行时序数据进行数据解析,得到第二候选核电运行时序数据,包括:
23、对所述第一候选核电运行时序数据进行数据数量统计,得到时序数据数量;
24、若所述时序数据数量大于预设数量阈值,则对预先获取的时序数据解析实例进行实例复制,得到目标解析实例;
25、根据所述第一候选核电运行时序数据对所述目标解析实例进行数据分配,得到参考核电运行时序数据;
26、通过所述目标解析实例对所述参考核电运行时序数据进行数据解析,得到所述第二候选核电运行时序数据。
27、在一些实施例,所述将存储于第一网络分区的第一核电运行时序数据传输至预设数据摆渡设备,得到第二核电运行时序数据,包括:
28、每隔预设时长对存储于第一网络分区的第一核电运行时序数据进行数据聚合,得到初始核电运行时序数据;
29、将存储于第一网络分区的所述初始核电运行时序数据传输至预设数据摆渡设备,得到所述第二核电运行时序数据。
30、在一些实施例,所述文件存储信息还包括数据传输时间,所述数据传输时间为所述第二核电运行时序数据传输至预设存储空间的时间,所述将存储于所述预设存储空间的所述存储地址存储至第一消息队列,并获取所述存储地址在所述第一消息队列中的存储顺序,包括:
31、根据所述数据传输时间确定所述存储顺序;
32、按照所述存储顺序将存储于所述预设存储空间的所述存储地址存储至所述第一消息队列。
33、为实现上述目的,本技术实施例的第二方面提出了一种时序数据传输装置,所述装置包括:
34、第一传输模块,用于将存储于第一网络分区的第一核电运行时序数据传输至预设数据摆渡设备,得到第二核电运行时序数据;所述第一核电运行时序数据和所述第二核电运行时序数据相同;
35、第二传输模块,用于将存储于所述预设数据摆渡设备的所述第二核电运行时序数据传输至第二网络分区的预设存储空间,得到文件存储信息;所述第一网络分区与所述第二网络分区为不同的网络分区;所述文件存储信息包括所述第二核电运行时序数据在所述预设存储空间的存储地址;
36、存储模块,用于将存储于所述预设存储空间的所述存储地址存储至第一消息队列,并获取所述存储地址在所述第一消息队列中的存储顺序;其中,所述第一消息队列位于所述第二网络分区;
37、第一获取模块,用于按照所述存储顺序从所述第一消息队列获取所述存储地址,得到目标存储地址;
38、第二获取模块,用于根据所述目标存储地址从所述预设存储空间获取所述第二核电运行时序数据,得到目标核电运行时序数据;
39、第三传输模块,用于将所述目标核电运行时序数据传输至数据消费端;所述数据消费端位于所述第二网络分区。
40、为实现上述目的,本技术实施例的第三方面提出了一种电子设备,电子设备包括存储器和处理器,存储器存储有计算机程序,处理器执行计算机程序时实现上述第一方面的时序数据传输方法。
41、为实现上述目的,本技术实施例的第四方面提出了一种计算机可读存储介质,计算机可读存储介质存储有计算机程序,计算机程序被处理器执行时实现上述第一方面的时序数据传输方法。
42、本技术提出的时序数据传输方法、时序数据传输装置、电子设备及计算机可读存储介质,通过将存储于第一网络分区的第一核电运行时序数据传输至预设数据摆渡设备,得到第二核电运行时序数据,以利用预设数据摆渡设备将核电运行时序数据从第一网络分区跨区传输至第二网络分区。为了实现时序数据的共享访问,将存储于预设数据摆渡设备的第二核电运行时序数据传输至第二网络分区的预设存储空间,得到文件存储信息。为了减轻读取大批量时序数据对预设存储空间的压力,并减少存储资源的消耗,将存储于预设存储空间的存储地址而非时序数据存储至第一消息队列。获取存储地址在第一消息队列中的存储顺序,按照存储顺序从第一消息队列获取存储地址,得到目标存储地址,根据目标存储地址从预设存储空间获取第二核电运行时序数据,使得能够按照目标存储地址依序获取时序数据,而非直接从预设存储空间获取大量时序数据,避免了实时数据传输造成的数据堵塞。将目标核电运行时序数据传输至数据消费端,以使数据消费端对目标核电运行时序数据进行消费,实现了大量时序数据从第一网络分区到数据消费端的跨网络分区传输。
1.时序数据传输方法,其特征在于,所述方法包括:
2.根据权利要求1所述的时序数据传输方法,其特征在于,所述根据所述目标存储地址从所述预设存储空间获取所述第二核电运行时序数据,得到目标核电运行时序数据,包括:
3.根据权利要求2所述的时序数据传输方法,其特征在于,在所述将所述第二候选核电运行时序数据存储至第二消息队列之前,所述时序数据传输方法还包括:
4.根据权利要求2所述的时序数据传输方法,其特征在于,所述将所述第二候选核电运行时序数据存储至第二消息队列,包括:
5.根据权利要求2所述的时序数据传输方法,其特征在于,所述对所述第一候选核电运行时序数据进行数据解析,得到第二候选核电运行时序数据,包括:
6.根据权利要求1至5任一项所述的时序数据传输方法,其特征在于,所述将存储于第一网络分区的第一核电运行时序数据传输至预设数据摆渡设备,得到第二核电运行时序数据,包括:
7.根据权利要求1至5任一项所述的时序数据传输方法,其特征在于,所述文件存储信息还包括数据传输时间,所述数据传输时间为所述第二核电运行时序数据传输至预设存储空间的时间,所述将存储于所述预设存储空间的所述存储地址存储至第一消息队列,并获取所述存储地址在所述第一消息队列中的存储顺序,包括:
8.时序数据传输装置,其特征在于,所述装置包括:
9.电子设备,其特征在于,所述电子设备包括存储器和处理器,所述存储器存储有计算机程序,所述处理器执行所述计算机程序时实现权利要求1至7任一项所述的时序数据传输方法。
10.计算机可读存储介质,所述计算机可读存储介质存储有计算机程序,其特征在于,所述计算机程序被处理器执行时实现权利要求1至7任一项所述的时序数据传输方法。
