本申请涉及物联网领域,尤其涉及一种数据采集系统及数据采集方法、装置、设备、介质。
背景技术:
1、工业物联网是物联网在工业领域的应用,通过将各种工业设备和机器连接起来,实现自动化生产和智能化管理。随着工业物联网的应用越来越广泛,使得工业物联网在单工厂环境下联网互通、数据采集、数据分析和计算、智能设备连接及运行自动化的技术越来越成熟。
2、随着技术的成熟和业务需求的多元化发展,工业物联网已不再仅仅只满足单工厂的集中处理,其使用范围已扩大到多个工厂联动甚至集团管控。在集团管控场景下,需要实现集团端与各工厂端之间的数据同步,以保障集团端部署的各个物联网应用的决策准确性。
3、已知技术中,存在工厂端向集团端同步数据不及时的缺陷,从而不利于集团端各物联网应用的及时响应。
技术实现思路
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、本申请提供的数据采集系统及数据采集方法、装置、设备、介质,其中,本申请的数据采集系统包括集团端和通过预设方式于集团端通信的多个工厂端,集团端根据物联网应用的应用属性信息,向各工厂端发送数据同步指令,使各工厂端按照数据优先级向集团端同步数据。通过本申请的数据采集系统,对于需要及时响应的物联网应用,集团端通过对这些物联网应用所需的现场数据,设置较高的数据优先级,从而使得工厂端在向集团端同步数据时,能够优先同步相应现场数据,以实现相应物联网应用的及时响应。
1.一种数据采集系统,其特征在于,所述系统包括集团端和多个工厂端,所述集团端和所述多个工厂端之间通过预设方式通信;其中,
2.根据权利要求1所述的系统,其特征在于,所述工厂端集成工厂实时数据库和工厂历史数据库;所述集团端集成集团实时数据库和集团历史数据库;所述工厂端具体用于:
3.根据权利要求1或2所述的系统,其特征在于,所述集团端集成第一监听函数,用于监听各所述工厂端与所述集团端的第一连接状态;所述集团端还用于:
4.根据权利要求3所述的系统,其特征在于,所述集团端还用于:
5.根据权利要求3所述的系统,其特征在于,所述集团端还用于:
6.根据权利要求1或2所述的系统,其特征在于,所述工厂端集成第二监听函数,用于监听各所述现场设备与所述工厂端的第二连接状态;所述工厂端还用于:
7.根据权利要求6所述的系统,其特征在于,所述集团端还用于:
8.一种数据采集方法,其特征在于,应用于如权利要求1-7任一项所述的集团端;所述方法包括:
9.一种数据采集方法,其特征在于,应用于如权利要求1-7任一项所述的工厂端;所述方法包括:
10.一种数据采集装置,其特征在于,所述装置包括用于执行如权利要求8所述方法的模块,或者,所述装置包括用于执行如权利要求9所述方法的模块。
11.一种电子设备,其特征在于,包括:处理器,以及与所述处理器通信连接的存储器;
12.一种计算机可读存储介质,其特征在于,所述计算机可读存储介质中存储有计算机执行指令,所述计算机执行指令被处理器执行时用于实现如权利要求8或9所述的方法。
13.一种计算机程序产品,其特征在于,包括计算机程序,该计算机程序被处理器执行时实现权利要求8或9所述的方法。