技术摘要:
一种大数据实时处理系统及其方法,包括包括处理单元;处理单元与存储单元连接,用于根据存储单元所存储的作为存储数据的室内空气质量的实时数据、室外空气质量数据和空气净化器的使用数据得到空气净化器的提前启动时间;所述处理单元还连接无线通信模块,而给现场工作 全部
背景技术:
大数据(big data)是指无法在一定时间范围内用常规软件工具进行捕捉、管理和 处理的数据集合,是需要新处理模式才能具有更强的决策力、洞察发现力和流程优化能力 的海量、高增长率和多样化的信息资产。 另一方面,为解决空气质量监测点的数据的精度不高,因此难以直接根据户外空 气质量及时开启空气净化器或调整空气净化器的档位的问题,利用大数据技术,就有了一 种实时处理大数据的服务器,包括:第一数据获取设备、第二数据获取设备、空气净化器控 制设备、存储单元和处理单元; 第一数据获取设备分别与智能家居控制系统和存储单元连接,用于获取智能家居 控制系统中室内空气质量的实时数据和空气净化器的使用数据,并将所述室内空气质量的 实时数据和空气净化器的使用数据写入存储单元;所述空气净化器的使用数据包括空气净 化器的洁净空气输出比率和设定的启动时间; 第二数据获取设备与存储单元连接,用于获取室外空气质量数据,并将所述室外 空气质量数据写入存储单元; 处理单元分别与存储单元和空气净化器控制设备连接,用于根据存储单元所存储 的室内空气质量的实时数据、室外空气质量数据和空气净化器的使用数据得到空气净化器 的提前启动时间;当当前时间距设定的启动时间达到提前启动时间时,处理单元向空气净 化器控制设备发送启动空气净化器的控制指令; 空气净化器控制设备还与智能家居控制系统连接,用于在接收到处理单元发来的 启动空气净化器的控制指令后,将所述启动空气净化器的控制指令发送至智能家居控制系 统,通过智能家居控制系统实现对空气净化器的启动控制。 为了达到现场灵活监控存储单元中的存储数据的目的,所述处理单元还通过 Rapid IO接口连接无线通信模块,而给现场工作者配备有无线PDA,所述无线通信模块与所 述无线PDA无线连接,这样就能通过所述处理单元控制所述第一FPGA把存储数据从存储单 元中取出,然后再把该存储数据传输到所述处理单元中而由所述处理单元经由无线通信模 块传递到现场工作者的所述无线PDA中显示,以此达到监控存储数据的目的。 但是在企业人员共享数据日益重要的时代,现场工作者要把一存储数据传递给全 体无线PDA的共享表里的各个共享者的手持终端之际,就须经由该无线PDA选择相应的存储 数据,接着经该无线PDA把存储数据传递给本地共享表中的各个共享者的手持终端,运作过 程异常繁琐;并且在一些手持终端不在共享者旁边、位于电量耗尽、实际这样无法运用的条 件之际;现场工作者不能把存储数据传递到此类位于无法运用条件的共享表里的各个共享 者的手持终端,给现场工作者添加了很大的不便利,现场工作者运用无线PDA的效果差;所 5 CN 111614525 A 说 明 书 2/9 页 述共享表中包括有各个共享者的手持终端的IP地址。手持终端也能够是无线PDA。
技术实现要素:
为解决上述问题,本发明提供了一种大数据实时处理系统及其方法,有效避免了 现有技术中现场工作者不能把存储数据传递到此类位于无法运用条件的共享表里的各个 共享者的手持终端、给现场工作者添加了很大的不便利、现场工作者运用无线PDA的效果差 的缺陷。 为了克服现有技术中的不足,本发明提供了一种大数据实时处理系统及其方法的 解决方案,具体如下: 一种大数据实时处理系统,包括处理单元; 处理单元与存储单元连接,用于根据存储单元所存储的作为存储数据的室内空气 质量的实时数据、室外空气质量数据和空气净化器的使用数据得到空气净化器的提前启动 时间; 所述处理单元还连接无线通信模块,而给现场工作者配备有无线PDA,所述无线通 信模块与所述无线PDA无线连接。 把一存储数据传递给全体无线PDA的共享表里的各个共享者的手持终端,所述共 享表中包括有各个共享者的手持终端的IP地址。 一种大数据实时处理系统的方法,包括: 所述把一存储数据传递给全体无线PDA的共享表里的各个共享者的手持终端的方 法,包括如下步骤: A-1,无线PDA凭借现场工作者录入的均选广播命令,把该无线PDA的共享表和该无 线PDA的共享表所在的备份服务器的IP地址传递到处理终端; A-1里所述的均选广播命令是代表现场工作者选取对该无线PDA的共享表里全部 的共享者的手持终端传递要传递存储数据的命令; A-2,处理终端根据备份服务器的IP地址得到备份服务器中全部共享表,推导所述 该无线PDA的共享表中相应的共享者的手持终端的个数K,还有所述全部共享表中相应的全 体共享者的手持终端的个数L; 在这里因为同一现场工作者的全部无线PDA的共享表贮存于备份服务器的同一贮 存区域里,所以A-2里处理终端得到的所述全部共享表包括所述现场工作者的全部无线PDA 的共享表。 A-3,对比K和L,在L高过K之际,就对全体共享者的手持终端执行分群,划分为若干 个群的共享表一,顺序朝所述无线PDA传递各个共享表一; A-3里所述对总共享者的手持终端执行分群,划分为若干个群的共享表一的过程 包括:用各个共享表一相应的共享者的手持终端数为K执行分群,划分为L÷K个群共享表 一; 本步骤A-3中所述处理终端在向无线PDA传递每一共享表一之际,还并发显示现时 传递的共享表一,还有该共享表一在分群里的序列;让现场工作者可实时了解存储数据传 递的情况与进程。 在这里,在L未高过K之际,那么处理终端朝相应的无线PDA回应分群失败消息,并 6 CN 111614525 A 说 明 书 3/9 页 终止该进程;无线PDA收受到分群失败消息,就凭借现有的方式,把要传递的存储数据传递 至该无线PDA的共享表所相应的各个共享者的手持终端。 A-4,无线PDA收受到每一共享表一后,把要传递的存储数据传递到相应群的共享 表一中的各个共享者的手持终端; A-4里,无线PDA收受到一共享表一后,就先把相应群的共享表一全部的共享者的 手持终端的标识或共享者的手持终端的称谓增设至要传递的存储数据的收受者录入区里, 接着凭借现场工作者录入的传递命令,把事先选定的要传递的存储数据传递到所述收受者 录入区里的共享者的手持终端的标识或者共享者的手持终端的称谓相应的共享者的手持 终端的标识里。 所述A-1之前还包括无线PDA把该无线PDA的共享表贮存到备份服务器的方法;所 述无线PDA把该无线PDA的共享表贮存到备份服务器的方式如下: B-1,所述无线PDA朝备份服务器传递具有无线PDA消息、该无线PDA的共享表的共 享表贮存请求消息; B-2,备份服务器凭借所述共享表贮存请求消息,判定备份服务器是不是具有同所 述无线PDA消息相应的无线PDA的共享表的贮存区域;如果是,就执行B-3;如果不是,就执行 B-4; B-3,把所述该无线PDA的共享表贮存到所述无线PDA的共享表的贮存区域; B-4,在备份服务器为所述无线PDA配置无线PDA的共享表的贮存区域,且把该无线 PDA的共享表贮存到所述无线PDA的共享表的贮存区域。 在这里,所述无线PDA消息能够为无线PDA的称谓、无线PDA的MAC地址; 在这里,所述均选广播命令具有所述无线PDA的标识。其中所述处理终端对总共享 者的手持终端执行分群,分成若干个群的共享表一后还包括如下处理:所述处理终端备份 分群的存储数据,给所述分群的存储数据增设所述无线PDA的标识,把增设的所述无线PDA 标识的所述分群的存储数据贮存到备份服务器中的所述无线PDA相应的无线PDA的共享表 的贮存区域。 在这里,在A-1之后还包括如下处置方法:所述处理终端判定备份服务器中是不是 存在增设有所述无线PDA标识的分群的存储数据;如果是,那么处理终端得到所述分群的存 储数据,还顺序朝所述无线PDA传递所述分群的存储数据里每一群的共享表一;如果不是, 那么处理终端执行A-2与A-3。 针对所述把一存储数据传递给全体无线PDA的共享表里的各个共享者的手持终端 的方法,提出了一套体系架构,所述体系架构包括:备份服务器、同一现场工作者的若干无 线PDA、处理终端。其中所述备份服务器,用于把同一现场工作者的全部无线PDA的该无线 PDA的共享表贮存在备份服务器的同一贮存区域内。所述各个无线PDA,用来凭借现场工作 者录入的均选广播命令,把该无线PDA的共享表以及该无线PDA的共享表所在的备份服务器 的IP地址传递至处理终端;还有收受智能终端传递的各群的共享表一,且收受到每一组共 享表一后,把要传递的存储数据传递到相应群的共享表一中的各个共享者的手持终端。所 述处理终端,用来凭借无线PDA传递的该无线PDA的共享表和该无线PDA的共享表在备份服 务器的贮存区域地址,得到备份服务器中全部共享表,推导所述该无线PDA的共享表相应的 共享者的手持终端数K,还有所述全部共享表相应的总共享者的手持终端数L;对比K与L,当 7 CN 111614525 A 说 明 书 4/9 页 L高过K之际,就对全部共享者的手持终端执行分群,划分为若干群的共享表一,顺序朝所述 无线PDA传递各群的共享表一。 在这里,所述的均选广播命令是代表现场工作者选取对该无线PDA的共享表里全 部的共享者的手持终端传递要传递存储数据的命令; 在这里,因为同一现场工作者的全部无线PDA的共享表贮存在备份服务器的同一 贮存区域内,所以在这里所述处理终端得到的所述全部共享表包括所述现场工作者的全部 无线PDA的该无线PDA的共享表。 在这里,在L未高过K之际,那么处理终端朝相应的无线PDA回应分群失败消息,并 终止该进程;无线PDA收受到分群失败消息,就凭借现有的方式,把要传递的存储数据传递 至该无线PDA的共享表所相应的各个共享者的手持终端。 在这里,无线PDA收受到一共享表一后,就先把相应群的共享表一全部的共享者的 手持终端的标识或共享者的手持终端的称谓增设至要传递的存储数据的收受者录入区里, 接着凭借现场工作者录入的传递命令,把事先选定的要传递的存储数据传递到所述收受者 录入区里的共享者的手持终端的标识或者共享者的手持终端的称谓相应的共享者的手持 终端的标识里。所述共享者的手持终端的称谓可以是共享者的手持终端的唯一性编号、也 可以是共享者的手持终端的唯一性用户名;所述共享者的手持终端的标识能够为无线PDA 的mac地址或者在其上运行的MSN的账号。 在该体系结构中,所述无线PDA,还用来朝备份服务器传递具有无线PDA消息、该无 线PDA的共享表的共享表贮存请求消息;所述备份服务器,还用来备份服务器凭借所述共享 表贮存请求消息,判定备份服务器是不是具有同所述无线PDA消息相应的无线PDA的共享表 的贮存区域;如果是,把所述该无线PDA的共享表贮存到所述无线PDA的共享表的贮存区域; 如果不是,在备份服务器为所述无线PDA配置无线PDA的共享表的贮存区域,且把该无线PDA 的共享表贮存到所述无线PDA的共享表的贮存区域。所述无线PDA消息能够为无线PDA的称 谓、无线PDA的MAC地址。 本发明的有益效果为: 本发明通过经由把同一现场工作者的全部无线PDA的共享表贮存在备份服务器的 同一贮存区域里;无线PDA凭借现场工作者录入的均选广播命令,把该无线PDA的共享表和 该无线PDA的共享表所在的备份服务器的IP地址传递到处理终端;处理终端得到备份服务 器中的全部共享表,推导所述该无线PDA的共享表相应的共享者的手持终端数K,还有所述 全部共享表相应的总共享者的手持终端数L;对比K和L,在L高过K之际,就对全体共享者的 手持终端执行分群,划分为若干群共享表一,顺序朝所述无线PDA传递各群共享表一;无线 PDA收受到各群的共享表一后,把要传递的存储数据传递到相应组的共享表一中的各个共 享者的手持终端的方式,现场工作者仅须经由其所属的随意一个能运用的无线PDA来激活 均选广播命令,就能达到朝现场工作者全部无线PDA的共享表中的各个共享者的手持终端 传递存储数据,不必顾及另外的无线PDA是不是处于能运用的条件,对比现有的存储数据的 传递方法,极大的降低了存储数据传递处理的繁琐度,让现场工作者运用非常容易,现场工 作者运用更为有效。 8 CN 111614525 A 说 明 书 5/9 页 附图说明 图1为本发明的大数据实时处理系统方法的一种流程图。 图2为本发明的大数据实时处理系统的方法的另一种流程图。