(12)发明专利申请
(10)申请公布号 CN 111740994 A(43)申请公布日 2020.10.02
(21)申请号 202010572656.6(22)申请日 2020.06.22
(71)申请人 天畅智汇（广州）科技有限公司
地址 510000 广东省广州市广州高新技术
产业开发区联和街天鹿南路100号五楼501(72)发明人 黄克颖 尹冰
(74)专利代理机构 北京商专润文专利代理事务
所(普通合伙) 11317
代理人 许春兰 罗泳诗(51)Int.Cl.
H04L 29/06(2006.01)H04L 29/08(2006.01)H04L 12/66(2006.01)
权利要求书2页 说明书13页 附图6页
(54)发明名称
一种基于边缘计算的高通量网关及其实现方法
(57)摘要
本发明公开了基于边缘计算的高通量网关及其实现方法，该方法包括：配置用于对外提供一致化服务的接口；响应于数据服务请求，根据数据服务请求调用用于对外提供一致化服务的接口与近设备端系统进行交互；其中，数据服务请求包括数据查询服务请求、数据获取服务请求和数据编目服务请求。从而能够解决现有的网关不能对外服务提供一致化服务接口的问题。并且，在不改变边缘计算环境中各业务系统运行模式的前提下，实现了一致化服务与业务系统的交互。CN 111740994 ACN 111740994 A
权 利 要 求 书
1/2页
1.一种基于边缘计算的高通量网关的实现方法，其特征在于，所述方法包括：配置用于对外提供一致化服务的接口；响应于数据服务请求，根据所述数据服务请求调用所述用于对外提供一致化服务的接口与近设备端系统进行交互；
其中，所述数据服务请求包括数据查询服务请求、数据获取服务请求和数据编目服务请求。
2.根据权利要求1所述的基于边缘计算的高通量网关的实现方法，其特征在于，所述配置用于对外提供一致化服务的接口实现为：
屏蔽各近设备端系统提供服务的异构性，根据所述各近端设备的代理程序实现对外提供一致化的数据访问服务。
3.根据权利要求2所述的基于边缘计算的高通量网关的实现方法，其特征在于，所述数据服务请求为数据查询服务请求，所述根据所述数据服务请求调用所述用于对外提供一致化服务的接口与近设备端系统进行交互包括：
接收所述数据查询服务请求，其中，所述数据查询服务请求包括数据查询条件；根据所述数据查询条件调用所述用于对外提供一致化服务的接口；
通过用于对外提供一致化服务的接口生成符合所述数据查询条件的查询结果。4.根据权利要求3所述的基于边缘计算的高通量网关的实现方法，其特征在于，接收所述数据查询服务请求之后还包括：
判断所述数据查询条件是否大于预设的查询容量条件；当所述数据查询条件大于所述预设的查询容量条件时，则输出重置数据查询条件的提醒信息。
5.根据权利要求3所述的基于边缘计算的高通量网关的实现方法，其特征在于，所述数据服务请求为数据获取服务请求，所述通过用于对外提供一致化服务的接口生成符合所述数据查询条件的查询结果，之后还包括：
接收所述数据获取服务请求，其中，所述数据获取服务请求包括获取任务ID；根据所述数据获取ID调用所述用于对外提供一致化服务的接口；
通过所述用于对外提供一致化服务的接口获取与所述获取任务ID匹配的数据信息，其中，所述数据信息包括数据基本信息、请求时间、数据有效期、数据下载地址。
6.根据权利要求2所述的基于边缘计算的高通量网关的实现方法，其特征在于，所述数据服务请求为数据编目服务请求，所述根据所述数据服务请求调用所述用于对外提供一致化服务的接口与近设备端系统进行交互包括：
接收所述数据编目服务请求，其中，所述数据编目服务请求包括对外数据编目请求和/或对内编目数据请求；
当所述数据编目服务请求为对外数据编目请求，获取所述数据编目服务请求包含的查询任务ID；
根据所述查询任务ID调用所述用于对外提供一致化服务的接口；
通过所述用于对外提供一致化服务的接口对数据条目和数据量进行统计。7.根据权利要求1-6任一项所述的基于边缘计算的高通量网关的实现方法，其特征在于，还包括：
2
CN 111740994 A
权 利 要 求 书
2/2页
与近设备端系统进行交互时，判断所述近设备端系统是否有相应的数据服务；根据判断结果实现与所述近设备端系统进行交互。
8.根据权利要求7所述的基于边缘计算的高通量网关的实现方法，其特征在于，所述判断结果包括所述近设备端系统没有相应的数据服务，所述根据判断结果实现与所述近设备端系统进行交互包括：
根据所述近设备端系统提供的元数据库，通过所述元数据库的中心数据节点生成制定接口；
根据所述制定接口与所述近设备端系统进行交互。9.一种基于边缘计算的高通量网关，其特征在于，包括：一致化服务模块，用于对外提供一致化服务；业务系统交互模块，用于响应于数据服务请求，根据所述数据服务请求调用所述一致化服务模块与近设备端系统进行交互；
其中，所述数据服务请求包括数据查询服务请求、数据获取服务请求和数据编目服务请求。
10.根据权利要求9所述的基于边缘计算的高通量网关，其特征在于，所述业务交互模块包括：
数据查询单元，用于接收所述数据查询服务请求，根据所述数据查询服务请求包含的数据查询条件调用所述一致化服务模块，生成符合所述数据查询条件的查询结果。
3
CN 111740994 A
说 明 书
一种基于边缘计算的高通量网关及其实现方法
1/13页
技术领域
[0001]本发明涉及数据网关技术领域，尤其涉及一种基于边缘计算的高通量网关及其实现方法。
背景技术
[0002]边缘计算是指在靠近物或数据源头的一侧，采用网络、计算、存储、应用核心能力为一体的开放平台，就近提供最近端服务。其应用程序在边缘侧发起，产生更快的网络服务响应，满足行业在实时业务、应用智能、安全与隐私保护等方面的基本需求。边缘计算处于物理实体和工业连接之间，或处于物理实体的顶端。[0003]随着5G和物联网的进一步发展和普及，目前各行业都存在大量近设备端的控制和存储系统，这些系统又都有各自的数据服务系统。跨设备的数据协同过去一般都是采用数据共享的方式，通过数据汇交和交换来实现，但是随着数据量的增加、使用模式复杂度的提升和对于按需处理能力的提出，这就会导致新型数据设施体系架构的多中心之间的数据无法协同。
发明内容
[0004]本发明所要解决的技术问题在于，提供一种基于边缘计算的高通量网关及其实现方法，能够解决现有的网关不能对外服务提供一致化服务接口的问题。并且，在不改变边缘计算环境中各业务系统运行模式的前提下，实现了一致化服务与业务系统的交互。[0005]为了解决上述技术问题，本发明第一方面公开了基于边缘计算的高通量网关方法，该方法包括：配置用于对外提供一致化服务的接口；响应于数据服务请求，根据所述数据服务请求调用所述用于对外提供一致化服务的接口与近设备端系统进行交互；其中，所述数据服务请求包括数据查询服务请求、数据获取服务请求和数据编目服务请求。[0006]在一些实施方式中，配置用于对外提供一致化服务的接口实现为：屏蔽各近设备端系统提供服务的异构性，根据所述各近端设备的代理程序实现对外提供一致化的数据访问服务。
[0007]在一些实施方式中，数据服务请求为数据查询服务请求，所述根据所述数据服务请求调用所述用于对外提供一致化服务的接口与近设备端系统进行交互包括：接收所述数据查询服务请求，其中，所述数据查询服务请求包括数据查询条件；根据所述数据查询条件调用所述用于对外提供一致化服务的接口；通过用于对外提供一致化服务的接口生成符合所述数据查询条件的查询结果。[0008]在一些实施方式中，接收所述数据查询服务请求之后还包括判断所述数据查询条件是否大于预设的查询容量条件；当所述数据查询条件大于所述预设的查询容量条件时，则输出重置数据查询条件的提醒信息。[0009]在一些实施方式中，数据服务请求为数据获取服务请求，所述根据所述数据服务请求调用所述用于对外提供一致化服务的接口与近设备端系统进行交互包括：接收所述数
4
CN 111740994 A
说 明 书
2/13页
据获取服务请求，其中，所述数据获取服务请求包括获取任务ID；根据所述数据获取ID调用所述用于对外提供一致化服务的接口；通过所述用于对外提供一致化服务的接口获取与所述获取任务ID匹配的数据信息，其中，所述数据信息包括数据基本信息、请求时间、数据有效期、数据下载地址。
[0010]在一些实施方式中，数据服务请求为数据编目服务请求，所述根据所述数据服务请求调用所述用于对外提供一致化服务的接口与近设备端系统进行交互包括：接收所述数据编目服务请求，其中，所述数据编目服务请求包括对外数据编目请求和/或对内编目数据请求；当所述数据编目服务请求为对外数据编目请求，获取所述数据编目服务请求包含的查询任务ID；根据所述查询任务ID调用所述用于对外提供一致化服务的接口；通过所述用于对外提供一致化服务的接口对数据条目和数据量进行统计。[0011]在一些实施方式中，还包括：与近设备端系统进行交互时，判断所述近设备端系统是否有相应的数据服务；根据判断结果实现与所述近设备端系统进行交互。[0012]在一些实施方式中，判断结果包括所述近设备端系统没有相应的数据服务，所述根据判断结果实现与所述近设备端系统进行交互包括：根据所述近设备端系统提供的元数据库，通过所述元数据库的中心数据节点生成制定接口；根据所述制定接口与所述近设备端系统进行交互。
[0013]基于本发明的第二个方面，公开了一种基于边缘计算的高通量网关，其包括：一致化服务模块，用于对外提供一致化服务；业务系统交互模块，用于响应于数据服务请求，根据所述数据服务请求调用所述一致化服务模块与近设备端系统进行交互；其中，所述数据服务请求包括数据查询服务请求、数据获取服务请求和数据编目服务请求。[0014]在一些实施方式中，所述业务交互模块包括：数据查询单元，用于接收所述数据查询服务请求，根据所述数据查询服务请求包含的数据查询条件调用所述一致化服务模块，生成符合所述数据查询条件的查询结果。[0015]在一些实施方式中，业务交互模块还包括：数据获取单元，用于接收所述数据获取服务请求，根据所述数据获取服务请求包含的数据获取ID调用所述一致化服务模块，获取与所述获取任务ID匹配的数据信息，其中，所述数据信息包括数据基本信息、请求时间、数据有效期、数据下载地址。[0016]在一些实施方式中，所述业务交互模块还包括：目录编目单元，用于接收所述数据编目服务请求，所述数据编目服务请求包括对外数据编目请求和/或对内编目数据请求；当所述数据编目服务请求为对外数据编目请求，获取所述数据编目服务请求包含的查询任务ID，根据所述查询任务ID调用所述一致化服务模块，对数据条目和数据量进行统计。[0017]在一些实施方式中，还包括：网关管理模块，用于对各近设备端系统网关提供管理操作指令；其中，所述操作指令包括数据数据服务发布指令、服务启动/关闭指令、服务配置修改指令、数据访问记录指令和更新数据到中心元数据库指令的一种或多种组合。[0018]基于本发明的第三个方面，公开了一种基于边缘计算的高通量网关的交互系统，包括：近设备端系统；用于与所述近设备端系统进行交互的如上述的基于边缘计算的高通量网关。
[0019]基于本发明的第四个方面，公开了一种利用基于边缘计算的高通量网关与近设备端系统进行交互的方法，其中，基于边缘计算的高通量网关如上述，所述方法包括：判断所
5
CN 111740994 A
说 明 书
3/13页
述近设备端系统是否有相应的数据服务；根据判断结果实现基于边缘计算的高通量网关与所述近设备端系统的交互。[0020]在一些实施方式中，所述判断结果包括所述近设备端系统没有相应的数据服务，所述根据判断结果实现基于边缘计算的高通量网关与所述近设备端系统的交互包括：所述近设备端系统向所述基于边缘计算的高通量网关提供的元数据库；基于边缘计算的高通量网关访问所述元数据库，根据所述元数据库的中心数据节点生成制定接口；所述基于边缘计算的高通量网关根据所述制定接口与所述近设备端系统进行交互。[0021]在一些实施方式中，所述判断结果包括所述近设备端系统有相应的数据服务，所述根据判断结果实现基于边缘计算的高通量网关与所述近设备端系统的交互包括：在基于边缘计算的高通量网关配置适用于中心数据节点的服务接口；近设备端系统根据所述服务接口与所述基于边缘计算的高通量网关进行交互。[0022]在一些实施方式中，所述判断结果包括所述近设备端系统有相应的数据服务，所述根据判断结果实现基于边缘计算的高通量网关与所述近设备端系统的交互包括：所述基于边缘计算的高通量网关调用用于对外提供一致化服务的接口；所述近设备端系统根据所述用于对外提供一致化服务的接口与所述近设备端系统进行交互。[0023]与现有技术相比，本发明的有益效果在于：
[0024]实施本发明能够实现高效协同的轻量级高通量网关，通过该基于边缘计算的高通量网关所提供的对外服务的一致化服务接口，并且该服务接口是根据各近端设备的代理程序实现对外提供一致化的数据访问服务，克服了现有技术各近端数据系统的接口不统一，导致的实现了各数据业务的处理进度不同，效率低下等问题。由此，可以实现工业物联网近设备端的现有业务系统的无缝协同，并且在保持原有业务系统独立性自治性的前提下，为实现了全局化的数据发现、数据获取和数据按需处理打下了良好的基础。附图说明
[0025]图1为本发明实施例公开的一种基于边缘计算的高通量网关实现方法的流程示意图；
[0026]图2为本发明实施例公开的又一种基于边缘计算的高通量网关实现方法的流程示意图；
[0027]图3为本发明实施例公开的又一种基于边缘计算的高通量网关实现方法的流程示意图；
[0028]图4为本发明实施例公开的又一种基于边缘计算的高通量网关实现方法的流程示意图；
[0029]图5为本发明实施例公开的一种基于边缘计算的高通量网关的结构示意图；[0030]图6为本发明实施例公开的又一种基于边缘计算的高通量网关的结构示意图；[0031]图7为本发明实施例公开的一种基于边缘计算的高通量网关的交互系统结构示意图；
[0032]图8是本发明实施例公开的一种利用基于边缘计算的高通量网关与近设备端系统进行交互的方法的流程示意图；
[0033]图9是本发明实施例公开的一种基于边缘计算的高通量网关的交互装置结构示意
6
CN 111740994 A
说 明 书
4/13页
图。
具体实施方式
[0034]为了更好地理解和实施，下面将结合本发明实施例中的附图，对本发明实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅是本发明一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本发明保护的范围。[0035]本发明实施例的术语“包括”和“具有”以及他们的任何变形，意图在于覆盖不排他的包含，例如，包含了一系列步骤或模块的过程、方法、系统、产品或设备不必限于清楚地列出的那些步骤或模块，而是可包括没有清楚地列出的或对于这些过程、方法、产品或设备固有的其它步骤或模块。
[0036]本发明实施例公开了一种基于边缘计算的高通量网关及其实现方法，能够实现高效协同的轻量级高通量网关，通过该基于边缘计算的高通量网关所提供的对外服务的一致化服务接口，并且该服务接口是根据各近端设备的代理程序实现对外提供一致化的数据访问服务，克服了现有技术各近端数据系统的接口不统一，导致的实现了各数据业务的处理进度不同，效率低下等问题。由此，可以实现工业物联网近设备端的现有业务系统的无缝协同，并且在保持原有业务系统独立性自治性的前提下，为实现了全局化的数据发现、数据获取和数据按需处理打下了良好的基础。[0037]实施例一[0038]请参阅图1，图1为本发明实施例公开的一种基于边缘计算的高通量网关方法的流程示意图。其中，该基于边缘计算的高通量网关可以应用在具有近设备端服务的系统，对于该基于边缘计算的高通量网关的应用系统本发明实施例不做限制。如图1所示，该基于边缘计算的高通量网关方法可以包括以下操作：[0039]101、配置用于对外提供一致化服务的接口。
[0040]由于该基于边缘计算的高通量网关所应用的环境包括多个不同的近设备端系统，示例性地，包括工业物联网，那么就涉及多个具有数据服务的系统，对于这种跨设备的数据协同过去一般都是采用数据共享的方式，通过数据汇交和交换来实现，但是随着数据量的增加、使用模式复杂度的提升和对于按需处理能力，就需要配置用于对外提供一致化服务的接口，该用于对外提供一致化服务的接口实现方式是通过屏蔽各近设备端系统提供服务的异构性，再根据各近端设备的代理程序实现对外提供一致化的数据访问服务。[0041]102、响应于数据服务请求，根据数据服务请求调用用于对外提供一致化服务的接口与近设备端系统进行交互，其中，数据服务请求包括数据查询服务请求、数据获取服务请求和数据编目服务请求。
[0042]作为一种具体实施方式，如图2所示，数据服务请求为数据查询服务请求，根据数据服务请求调用用于对外提供一致化服务的接口与近设备端系统进行交互实现为：接收所述数据查询服务请求，数据查询服务多是由应用用户发起，其消息传递机制是应用用户经过近端设备系统的中心节点处理到达对该用于对外提供一致化服务的接口后，通过用于对外提供一致化服务的接口采用异步的方式返回符合条件的数据元信息描述，其中，数据查询服务请求包括数据查询条件，对该数据查询服务请求进行解析，获取该数据查询条件，返
7
CN 111740994 A
说 明 书
5/13页
回符合条件的数据元信息描述的方式就是根据数据查询条件调用用于对外提供一致化服务的接口，通过用于对外提供一致化服务的接口生成符合数据查询条件的查询结果。并且，查询结果数据条目不受限制，可连续请求。例如，在物联网的业务系统中，就可以根据每一数据查询服务请求所包含的任务单号获取附加的查询结果，在查询任务完成一定的时间(可根据需求进行设置)后还可以自动清理查询任务单。[0043]作为一种具体实施方式的优选实施方式，考虑到各近设备端系统数据存储量较大，当数据查询服务请求中的查询条件范围过大时，可能就会导致返回查询结果过多造成堆溢，那么就可以在接收数据查询服务请求之后，判断该数据查询条件是否大于预设的查询容量条件，当数据查询条件大于预设的查询容量条件时，则输出重置数据查询条件的提醒信息。由此，可以对查询条件作出限制，有利于提高数据服务的效率。[0044]作为一种具体实施方式，如图3所示，数据服务请求为数据获取服务请求，在数据查询服务请求后，可对所需的数据进行数据获取服务请求，根据数据服务请求调用用于对外提供一致化服务的接口与近设备端系统进行交互包括：接收数据获取服务请求，数据获取服务多是由应用用户发起，其消息传递机制是应用用户经过近端设备系统的中心节点处理到达对该用于对外提供一致化服务的接口后，通过用于对外提供一致化服务的接口采用异步的方式返回符合条件的数据元信息描述，其中，数据获取服务请求包括获取任务ID，根据数据获取ID调用用于对外提供一致化服务的接口，通过用于对外提供一致化服务的接口获取与获取任务ID匹配的数据信息，其中，数据信息包括数据基本信息、请求时间、数据有效期、数据下载地址等，本发明不对获取的数据信息进行限定。通过用于对外提供一致化服务的接口获取与获取任务ID匹配的数据信息具体实现为：在数据元信息中包含了数据的ID，用户得到元信息后可选择需要的数据ID，之后再发送数据获取请求给对应的数据节点，近设备端系统的端节点数据获取服务以获得获取任务ID，再由该获取任务ID得到数据的下载地址，其中，数据获取服务所采用异步是为了保证有充足时间提前准备数据。[0045]在实际应用中，在接收到用户的数据获取需求后根据上述的方法获取数据，生成订单，并且根据离线或在线状态分为两种不同的处理方式。对于离线状态，直接获取与用户发出的数据获取需求相匹配的离线准备数据，当用户确认后则完成订单确认结束数据获取需求的操作。对于在线状态，首先获取与用户发出的数据获取需求相批评的在线准备数据，通过FTP缓存，等待用户自行下载。根据获取的数据信息中的有效期判断当前是否在有效期中下载，若是在有效期下载，那在用户确认下载后就完成订单确认结束数据获取的操作；若在有效期间，用户未下载则发送邮件提示用户进行下载。若超过了数据信息中的有效期，则自动删除数据结束数据获取的操作。[0046]作为一种具体实施方式，如图4所示，数据服务请求为数据编目服务请求，根据数据服务请求调用用于对外提供一致化服务的接口与近设备端系统进行交互包括：接收该数据编目服务请求，其中，数据编目服务请求包括对外数据编目请求和对内编目数据请求，对内编目数据请求实现为内部的目录本身进行同步的功能。当数据编目服务请求为对外数据编目请求，获取数据编目服务请求包含的查询任务ID，根据查询任务ID调用上述的用于对外提供一致化服务的接口，通过用于对外提供一致化服务的接口对数据条目和数据量进行统计。由于编目服务一般统计量较大，对整个系统带来的负担较重，所以还会通过查询任务ID对当前用户的权限进行判断，仅对特定权限的用户开放使用。
8
CN 111740994 A[0047]
说 明 书
6/13页
进一步地，在通过该基于边缘计算的高通量网关与近设备端系统进行交互时，还
判断近设备端系统是否有相应的数据服务，根据不同的判断结果实现与近设备端系统进行交互。
[0048]当判断结果为近设备端节点没有相应的数据服务，则近设备端系统可以提供元数据库，直接访问元数据库中的数据，按照该元数据库中的中心数据节点生成制定的接口，根据该制定接口与近设备端系统进行交互，为其提供数据服务。[0049]当判断结果为近设备端节点有相应的数据服务，为了实现业务系统的交互，则开发近设备端节点的中心数据节点制定的服务接口，由此可以便于中心节点直接通过基于边缘计算的高通量网关进行访问服务。
[0050]当判断结果为近设备端节点有相应的数据服务，但是近设备端系统所提供的元数据中的数据阻碍，不能开发中心节点制定的服务接口(用于对外提供一致化服务的接口)，则提供基于边缘计算的高通量网关的服务接口给近设备端系统的中心节点，中心节点可以自行通过服务接口的转换实现业务系统交互。
[0051]根据本实施例提供的方法能够实现高效协同的轻量级高通量网关，通过该基于边缘计算的高通量网关所提供的对外服务的一致化服务接口，并且该服务接口是根据各近端设备的代理程序实现对外提供一致化的数据访问服务，克服了现有技术各近端数据系统的接口不统一，导致的实现了各数据业务的处理进度不同，效率低下等问题。由此，可以实现工业物联网近设备端的现有业务系统的无缝协同，并且在保持原有业务系统独立性自治性的前提下，为实现了全局化的数据发现、数据获取和数据按需处理打下了良好的基础。[0052]实施例二[0053]请参阅图5，图5为本发明实施例公开的一种基于边缘计算的高通量网关结构示意图。其中，该基于边缘计算的高通量网关可以应用在具有近设备端服务的系统，对于该基于边缘计算的高通量网关的应用系统本发明实施例不做限制。如图5所示，该基于边缘计算的高通量网关3包括：
[0054]一致化服务模块301，用于对外提供一致化服务。[0055]业务系统交互模块302，用于响应于数据服务请求，根据数据服务请求调用一致化服务模块301与近设备端系统进行交互，其中，数据服务请求包括数据查询服务请求、数据获取服务请求和数据编目服务请求。
[0056]由于该基于边缘计算的高通量网关所应用的环境包括多个不同的近设备端系统，示例性地，包括工业物联网，那么就涉及多个具有数据服务的系统，对于这种跨设备的数据协同过去一般都是采用数据共享的方式，通过数据汇交和交换来实现，但是随着数据量的增加、使用模式复杂度的提升和对于按需处理能力，就需要配置用于对外提供一致化服务的接口，该用于对外提供一致化服务模块301实现方式是通过屏蔽各近设备端系统提供服务的异构性，再根据各近端设备的代理程序实现对外提供一致化的数据访问服务。[0057]进一步地，作为一种具体实施方式，业务交互模块302包括：数据查询单元3021，用于接收数据查询服务请求，根据数据查询服务请求包含的数据查询条件调用一致化服务模块301，生成符合数据查询条件的查询结果。[0058]接收所述数据查询服务请求，数据查询服务多是由应用用户发起，其消息传递机制是应用用户经过近端设备系统的中心节点处理到达对该用于对外提供一致化服务的接
9
CN 111740994 A
说 明 书
7/13页
口后，通过用于对外提供一致化服务的接口采用异步的方式返回符合条件的数据元信息描述，其中，数据查询服务请求包括数据查询条件，对该数据查询服务请求进行解析，获取该数据查询条件，返回符合条件的数据元信息描述的方式就是根据数据查询条件调用用于对外提供一致化服务的接口，通过用于对外提供一致化服务的接口生成符合数据查询条件的查询结果。并且，查询结果数据条目不受限制，可连续请求。例如，在物联网的业务系统中，就可以根据每一数据查询服务请求所包含的任务单号获取附加的查询结果，在查询任务完成一定的时间(可根据需求进行设置)后还可以自动清理查询任务单。[0059]作为一种具体实施方式的优选实施方式，考虑到各近设备端系统数据存储量较大，当数据查询服务请求中的查询条件范围过大时，可能就会导致返回查询结果过多造成堆溢，那么就可以在接收数据查询服务请求之后，判断该数据查询条件是否大于预设的查询容量条件，当数据查询条件大于预设的查询容量条件时，则输出重置数据查询条件的提醒信息。由此，可以对查询条件作出限制，有利于提高数据服务的效率。[0060]进一步地，作为一种具体实施方式，业务交互模块302还包括：数据获取单元3022，用于接收数据获取服务请求，根据数据获取服务请求包含的数据获取ID调用一致化服务模块301，获取与获取任务ID匹配的数据信息，其中，数据信息包括数据基本信息、请求时间、数据有效期、数据下载地址。
[0061]数据获取单元3022可对所需的数据进行数据获取服务请求，根据数据服务请求调用用于对外提供一致化服务的接口与近设备端系统进行交互包括：接收数据获取服务请求，数据获取服务多是由应用用户发起，其消息传递机制是应用用户经过近端设备系统的中心节点处理到达对该用于对外提供一致化服务的接口后，通过用于对外提供一致化服务的接口采用异步的方式返回符合条件的数据元信息描述，其中，数据获取服务请求包括获取任务ID，根据数据获取ID调用用于对外提供一致化服务的接口，通过用于对外提供一致化服务的接口获取与获取任务ID匹配的数据信息，其中，数据信息包括数据基本信息、请求时间、数据有效期、数据下载地址等，本发明不对获取的数据信息进行限定。通过用于对外提供一致化服务的接口获取与获取任务ID匹配的数据信息具体实现为：在数据元信息中包含了数据的ID，用户得到元信息后可选择需要的数据ID，之后再发送数据获取请求给对应的数据节点，近设备端系统的端节点数据获取服务以获得获取任务ID，再由该获取任务ID得到数据的下载地址，其中，数据获取服务所采用异步是为了保证有充足时间提前准备数据。
[0062]在实际应用中，在接收到用户的数据获取需求后根据上述的方法获取数据，生成订单，并且根据离线或在线状态分为两种不同的处理方式。对于离线状态，直接获取与用户发出的数据获取需求相匹配的离线准备数据，当用户确认后则完成订单确认结束数据获取需求的操作。对于在线状态，首先获取与用户发出的数据获取需求相批评的在线准备数据，通过FTP缓存，等待用户自行下载。根据获取的数据信息中的有效期判断当前是否在有效期中下载，若是在有效期下载，那在用户确认下载后就完成订单确认结束数据获取的操作；若在有效期间，用户未下载则发送邮件提示用户进行下载。若超过了数据信息中的有效期，则自动删除数据结束数据获取的操作。[0063]进一步地，作为一种具体实施方式，业务交互模块302还包括：目录编目单元3023，用于接收所述数据编目服务请求，数据编目服务请求包括对外数据编目请求和/或对内编
10
CN 111740994 A
说 明 书
8/13页
目数据请求；当数据编目服务请求为对外数据编目请求，获取数据编目服务请求包含的查询任务ID，根据查询任务ID调用一致化服务模块，对数据条目和数据量进行统计。[0064]目录编目单元3023接收该数据编目服务请求，其中，数据编目服务请求包括对外数据编目请求和对内编目数据请求，对内编目数据请求实现为内部的目录本身进行同步的功能。当数据编目服务请求为对外数据编目请求，获取数据编目服务请求包含的查询任务ID，根据查询任务ID调用上述的用于对外提供一致化服务的接口，通过用于对外提供一致化服务的接口对数据条目和数据量进行统计。由于编目服务一般统计量较大，对整个系统带来的负担较重，所以还会通过查询任务ID对当前用户的权限进行判断，仅对特定权限的用户开放使用。
[0065]进一步地，在通过该基于边缘计算的高通量网关与近设备端系统进行交互时，还判断近设备端系统是否有相应的数据服务，根据不同的判断结果实现与近设备端系统进行交互。
[0066]当判断结果为近设备端节点没有相应的数据服务，则近设备端系统可以提供元数据库，直接访问元数据库中的数据，按照该元数据库中的中心数据节点生成制定的接口，根据该制定接口与近设备端系统进行交互，为其提供数据服务。[0067]当判断结果为近设备端节点有相应的数据服务，为了实现业务系统的交互，则开发近设备端节点的中心数据节点制定的服务接口，由此可以便于中心节点直接通过基于边缘计算的高通量网关进行访问服务。
[0068]当判断结果为近设备端节点有相应的数据服务，但是近设备端系统所提供的元数据中的数据阻碍，不能开发中心节点制定的服务接口(用于对外提供一致化服务的接口)，则提供基于边缘计算的高通量网关的服务接口给近设备端系统的中心节点，中心节点可以自行通过服务接口的转换实现业务系统交互。
[0069]根据本实施例提供的高效协同的轻量级高通量网关，实现了各数据业务系统尤其是工业物联网近设备端的现有业务系统的无缝协同，在保持原有业务系统独立性自治性的前提下，为实现了全局化的数据发现、数据获取和数据按需处理打下了良好的基础。[0070]实施例三[0071]请参阅图6，图6为本发明实施例公开的又一种基于边缘计算的高通量网关结构示意图。其中，该基于边缘计算的高通量网关可以应用在具有近设备端服务的系统，对于该基于边缘计算的高通量网关的应用系统本发明实施例不做限制。如图6所示，该基于边缘计算的高通量网关3与实施例二相近，不同之处在于，还包括：[0072]网关管理模块303，该网关管理模块303用于对各近设备端系统网关提供管理操作指令，其中，操作指令包括数据数据服务发布指令、服务启动或关闭指令、服务配置修改指令、数据访问记录指令和更新数据到中心元数据库指令。需要说明的是，本发明的网关管理模块的操作指令并不局限于以上，其他与网关管理相关的操作指令也属于本发明的保护范围。
[0073]示例性地，数据服务发布指令为边缘计算数据网关上将自带一致化服务，在服务配置稳定后，将数据服务一次性发布到中心元数据库模块，由此可以便于中心元数据库通过该节点访问各近设备端节点数据。服务启动或关闭指令为对于数据网关的数据服务，管理员可以通过该指令对其进行关闭和重新启动。服务配置修改指令为管理数据网关上数据
11
CN 111740994 A
说 明 书
9/13页
访问服务的配置信息，其中，配置信息包括IP地址，访问的元数据库字段或者对应服务接口的元数据属性与服务接口属性的对应关系，元数据库或对应服务的访问地址等。数据访问指令为记录各个用户访问数据的行为，不过主要是记录查询行为和数据获取行为，有利于后续提供数据交互的凭证。数据更新管理指令为边缘计算数据网关可向中心元数据库发起数据更新通知，告知中心元数据库触发编目服务，更新该节点所连接数据的元数据信息。重要的是，数据更新过程不可能更新每个近设备端节点业务系统的全局数据，而是调用该网关的目录编目单元3023进行增量数据更新。
[0074]根据本实施例公开的基于边缘计算的高通量网关增加了网关管理模块，对于网关的集成化统一化管理有着重要意义，并且可以更好的提供与近设备端系统的服务。[0075]实施例四[0076]请参阅图7，图7为本发明实施例公开的一种基于边缘计算的高通量网关的交互系统示意图。其中，该基于边缘计算的高通量网关可以应用在具有近设备端服务的系统，对于该基于边缘计算的高通量网关的应用系统本发明实施例不做限制。如图7所示，公开了一种基于边缘计算的高通量网关的交互系统，包括：近设备端系统4；[0077]用于与近设备端系统4进行交互的基于边缘计算的高通量网关3。[0078]该基于边缘计算的高通量网关3包括：[0079]一致化服务模块301，用于对外提供一致化服务。[0080]业务系统交互模块302，用于响应于数据服务请求，根据数据服务请求调用一致化服务模块301与近设备端系统4进行交互，其中，数据服务请求包括数据查询服务请求、数据获取服务请求和数据编目服务请求。
[0081]由于该基于边缘计算的高通量网关所应用的环境包括多个不同的近设备端系统，示例性地，包括工业物联网，那么就涉及多个具有数据服务的系统，对于这种跨设备的数据协同过去一般都是采用数据共享的方式，通过数据汇交和交换来实现，但是随着数据量的增加、使用模式复杂度的提升和对于按需处理能力，就需要配置用于对外提供一致化服务的接口，该用于对外提供一致化服务模块301实现方式是通过屏蔽各近设备端系统提供服务的异构性，再根据各近端设备的代理程序实现对外提供一致化的数据访问服务。[0082]进一步地，作为一种具体实施方式，业务交互模块302包括：数据查询单元3021，用于接收数据查询服务请求，根据数据查询服务请求包含的数据查询条件调用一致化服务模块301，生成符合数据查询条件的查询结果。[0083]接收所述数据查询服务请求，数据查询服务多是由应用用户发起，其消息传递机制是应用用户经过近端设备系统的中心节点处理到达对该用于对外提供一致化服务的接口后，通过用于对外提供一致化服务的接口采用异步的方式返回符合条件的数据元信息描述，其中，数据查询服务请求包括数据查询条件，对该数据查询服务请求进行解析，获取该数据查询条件，返回符合条件的数据元信息描述的方式就是根据数据查询条件调用用于对外提供一致化服务的接口，通过用于对外提供一致化服务的接口生成符合数据查询条件的查询结果。并且，查询结果数据条目不受限制，可连续请求。例如，在物联网的业务系统中，就可以根据每一数据查询服务请求所包含的任务单号获取附加的查询结果，在查询任务完成一定的时间(可根据需求进行设置)后还可以自动清理查询任务单。[0084]作为一种具体实施方式的优选实施方式，考虑到各近设备端系统数据存储量较
12
CN 111740994 A
说 明 书
10/13页
大，当数据查询服务请求中的查询条件范围过大时，可能就会导致返回查询结果过多造成堆溢，那么就可以在接收数据查询服务请求之后，判断该数据查询条件是否大于预设的查询容量条件，当数据查询条件大于预设的查询容量条件时，则输出重置数据查询条件的提醒信息。由此，可以对查询条件作出限制，有利于提高数据服务的效率。[0085]进一步地，作为一种具体实施方式，业务交互模块302还包括：数据获取单元3022，用于接收数据获取服务请求，根据数据获取服务请求包含的数据获取ID调用一致化服务模块301，获取与获取任务ID匹配的数据信息，其中，数据信息包括数据基本信息、请求时间、数据有效期、数据下载地址。
[0086]数据获取单元3022可对所需的数据进行数据获取服务请求，根据数据服务请求调用用于对外提供一致化服务的接口与近设备端系统进行交互包括：接收数据获取服务请求，数据获取服务多是由应用用户发起，其消息传递机制是应用用户经过近端设备系统的中心节点处理到达对该用于对外提供一致化服务的接口后，通过用于对外提供一致化服务的接口采用异步的方式返回符合条件的数据元信息描述，其中，数据获取服务请求包括获取任务ID，根据数据获取ID调用用于对外提供一致化服务的接口，通过用于对外提供一致化服务的接口获取与获取任务ID匹配的数据信息，其中，数据信息包括数据基本信息、请求时间、数据有效期、数据下载地址等，本发明不对获取的数据信息进行限定。通过用于对外提供一致化服务的接口获取与获取任务ID匹配的数据信息具体实现为：在数据元信息中包含了数据的ID，用户得到元信息后可选择需要的数据ID，之后再发送数据获取请求给对应的数据节点，近设备端系统的端节点数据获取服务以获得获取任务ID，再由该获取任务ID得到数据的下载地址，其中，数据获取服务所采用异步是为了保证有充足时间提前准备数据。
[0087]在实际应用中，在接收到用户的数据获取需求后根据上述的方法获取数据，生成订单，并且根据离线或在线状态分为两种不同的处理方式。对于离线状态，直接获取与用户发出的数据获取需求相匹配的离线准备数据，当用户确认后则完成订单确认结束数据获取需求的操作。对于在线状态，首先获取与用户发出的数据获取需求相批评的在线准备数据，通过FTP缓存，等待用户自行下载。根据获取的数据信息中的有效期判断当前是否在有效期中下载，若是在有效期下载，那在用户确认下载后就完成订单确认结束数据获取的操作；若在有效期间，用户未下载则发送邮件提示用户进行下载。若超过了数据信息中的有效期，则自动删除数据结束数据获取的操作。[0088]进一步地，作为一种具体实施方式，业务交互模块302还包括：目录编目单元3023，用于接收所述数据编目服务请求，数据编目服务请求包括对外数据编目请求和/或对内编目数据请求；当数据编目服务请求为对外数据编目请求，获取数据编目服务请求包含的查询任务ID，根据查询任务ID调用一致化服务模块，对数据条目和数据量进行统计。[0089]目录编目单元3023接收该数据编目服务请求，其中，数据编目服务请求包括对外数据编目请求和对内编目数据请求，对内编目数据请求实现为内部的目录本身进行同步的功能。当数据编目服务请求为对外数据编目请求，获取数据编目服务请求包含的查询任务ID，根据查询任务ID调用上述的用于对外提供一致化服务的接口，通过用于对外提供一致化服务的接口对数据条目和数据量进行统计。由于编目服务一般统计量较大，对整个系统带来的负担较重，所以还会通过查询任务ID对当前用户的权限进行判断，仅对特定权限的
13
CN 111740994 A
说 明 书
11/13页
用户开放使用。
[0090]进一步地，在通过该基于边缘计算的高通量网关与近设备端系统进行交互时，还判断近设备端系统是否有相应的数据服务，根据不同的判断结果实现与近设备端系统进行交互。
[0091]当判断结果为近设备端节点没有相应的数据服务，则近设备端系统可以提供元数据库，直接访问元数据库中的数据，按照该元数据库中的中心数据节点生成制定的接口，根据该制定接口与近设备端系统进行交互，为其提供数据服务。[0092]当判断结果为近设备端节点有相应的数据服务，为了实现业务系统的交互，则开发近设备端节点的中心数据节点制定的服务接口，由此可以便于中心节点直接通过基于边缘计算的高通量网关进行访问服务。
[0093]当判断结果为近设备端节点有相应的数据服务，但是近设备端系统所提供的元数据中的数据阻碍，不能开发中心节点制定的服务接口(用于对外提供一致化服务的接口)，则提供基于边缘计算的高通量网关的服务接口给近设备端系统的中心节点，中心节点可以自行通过服务接口的转换实现业务系统交互。
[0094]根据本实施例提供的交互系统能够实现高效协同的轻量级高通量网关，通过该基于边缘计算的高通量网关所提供的对外服务的一致化服务接口，并且该服务接口是根据各近端设备的代理程序实现对外提供一致化的数据访问服务，克服了现有技术各近端数据系统的接口不统一，导致的实现了各数据业务的处理进度不同，效率低下等问题。由此，可以实现工业物联网近设备端的现有业务系统的无缝协同，并且在保持原有业务系统独立性自治性的前提下，为实现了全局化的数据发现、数据获取和数据按需处理打下了良好的基础。[0095]实施例五[0096]请参阅图8，图8为本发明实施例公开的一种利用基于边缘计算的高通量网关与近设备端系统进行交互的方法流程示意图。其中，该基于边缘计算的高通量网关可以应用在具有近设备端服务的系统，对于该基于边缘计算的高通量网关的应用系统本发明实施例不做限制。如图8所示，该利用基于边缘计算的高通量网关与近设备端系统进行交互的方法包括：
[0097]501、判断近设备端系统是否有相应的数据服务。[0098]判断的方式可以根据近设备端系统的代理程序内容进行读取。[0099]502、根据判断结果实现基于边缘计算的高通量网关与近设备端系统的交互。[0100]作为一种实施方式，判断结果包括近设备端系统没有相应的数据服务，根据判断结果实现基于边缘计算的高通量网关与近设备端系统的交互实现为：近设备端系统基于边缘计算的高通量网关提供的元数据库，基于边缘计算的高通量网关访问元数据库，根据元数据库的中心数据节点生成制定接口，基于边缘计算的高通量网关根据所述制定接口与所述近设备端系统进行交互，为其提供数据服务。[0101]作为一种实施方式，判断结果包括近设备端系统有相应的数据服务，为了实现业务系统的交互，则开发近设备端节点的中心数据节点制定的服务接口，由此可以便于中心节点直接通过基于边缘计算的高通量网关进行访问服务，根据判断结果实现基于边缘计算的高通量网关与近设备端系统的交互实现为：在基于边缘计算的高通量网关配置适用于中心数据节点的服务接口，近设备端系统根据所述服务接口与所述基于边缘计算的高通量网
14
CN 111740994 A
说 明 书
12/13页
关进行交互。
[0102]作为一种实施方式，判断结果包括近设备端系统有相应的数据服务，但是近设备端系统所提供的元数据中的数据阻碍，不能开发中心节点制定的服务接口(用于对外提供一致化服务的接口)，则提供基于边缘计算的高通量网关的服务接口给近设备端系统的中心节点，中心节点可以自行通过服务接口的转换实现业务系统交互。
[0103]根据本实施例公开的利用基于边缘计算的高通量网关与近设备端系统进行交互的方法可以应用该具有对外服务的一致化服务接口的网关进行近设备端系统的交互，并且该服务接口是根据各近端设备的代理程序实现对外提供一致化的数据访问服务，克服了现有技术各近端数据系统的接口不统一，导致的实现了各数据业务的处理进度不同，效率低下等问题。由此，可以实现工业物联网近设备端的现有业务系统的无缝协同，并且在保持原有业务系统独立性自治性的前提下，为实现了全局化的数据发现、数据获取和数据按需处理打下了良好的基础。[0104]实施例六[0105]请参阅图9，图9是本发明实施例公开的一种基于边缘计算的高通量网关装置的结构示意图。其中，图9所描述的装置可以应用在具有近设备端服务的系统，对于该基于边缘计算的高通量网关的应用系统本发明实施例不做限制。如图9所示，该装置可以包括：[0106]存储有可执行程序代码的存储器601；[0107]与存储器601耦合的处理器602；
[0108]处理器602调用存储器601中存储的可执行程序代码，用于执行实施例一所描述的基于边缘计算的高通量网关实现方法。[0109]实施例七
[0110]本发明实施例公开了一种计算机可读存储介质，其存储用于电子数据交换的计算机程序，其中，该计算机程序使得计算机执行实施例一所描述的基于边缘计算的高通量网关实现方法。[0111]实施例八
[0112]本发明实施例公开了一种计算机程序产品，该计算机程序产品包括存储了计算机程序的非瞬时性计算机可读存储介质，且该计算机程序可操作来使计算机执行实施例一或实施例二中所描述的基于边缘计算的高通量网关方法。[0113]以上所描述的的实施例仅是示意性的，其中所述作为分离部件说明的模块可以是或者也可以不是物理上分开的，作为模块显示的部件可以是或者也可以不是物理模块，即可以位于一个地方，或者也可以分布到多个网络模块上。可以根据实际的需要选择其中的部分或者全部模块来实现本实施例方案的目的。本领域普通技术人员在不付出创造性的劳动的情况下，即可以理解并实施。
[0114]通过以上的实施例的具体描述，本领域的技术人员可以清楚地了解到各实施方式可借助软件加必需的通用硬件平台的方式来实现，当然也可以通过硬件。基于这样的理解，上述技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来，该计算机软件产品可以存储在计算机可读存储介质中,存储介质包括只读存储器(Read-OnlyMemory，ROM)、随机存储器(RandomAccessMemory，RAM)、可编程只读存储器(ProgrammableRead-onlyMemory，PROM)、可擦除可编程只读存储器(ErasableProgrammab
15
CN 111740994 A
说 明 书
13/13页
leReadOnlyMemory，EPROM)、一次可编程只读存储器(One-timeProgrammableRead-OnlyMemory，OTPROM)、电子抹除式可复写只读存储器(Electrically-ErasableProgrammableRead-OnlyMemory，EEPROM)、只读光盘(CompactDiscRead-OnlyMemory，CD-ROM)或其他光盘存储器、磁盘存储器、磁带存储器、或者能够用于携带或存储数据的计算机可读的任何其他介质。[0115]最后应说明的是：本发明实施例公开的一种基于边缘计算的高通量网关方法及装置所揭露的仅为本发明较佳实施例而已，仅用于说明本发明的技术方案，而非对其限制；尽管参照前述实施例对本发明进行了详细的说明，本领域的普通技术人员应当理解；其依然可以对前述各项实施例所记载的技术方案进行修改，或者对其中部分技术特征进行等同替换；而这些修改或替换，并不使相应的技术方案的本质脱离本发明各项实施例技术方案的精神和范围。
16
CN 111740994 A
说 明 书 附 图
1/6页
图1
图2
17
CN 111740994 A
说 明 书 附 图
2/6页
图3
图4
18
CN 111740994 A
说 明 书 附 图
3/6页
图5
19
CN 111740994 A
说 明 书 附 图
4/6页
图6
20
CN 111740994 A
说 明 书 附 图
5/6页
图7
图8
21
CN 111740994 A
说 明 书 附 图
6/6页
图9
22
因篇幅问题不能全部显示，请点此查看更多更全内容