CN117527894A - 网络数据面系统、数据交互方法及存储介质 - Google Patents
网络数据面系统、数据交互方法及存储介质 Download PDFInfo
- Publication number
- CN117527894A CN117527894A CN202210907497.XA CN202210907497A CN117527894A CN 117527894 A CN117527894 A CN 117527894A CN 202210907497 A CN202210907497 A CN 202210907497A CN 117527894 A CN117527894 A CN 117527894A
- Authority
- CN
- China
- Prior art keywords
- data
- module
- subscription
- standard
- service module
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Pending
Links
- 238000000034 method Methods 0.000 title claims abstract description 115
- 230000003993 interaction Effects 0.000 title claims abstract description 62
- 238000003860 storage Methods 0.000 title claims abstract description 29
- 238000013499 data model Methods 0.000 claims abstract description 131
- 238000013075 data extraction Methods 0.000 claims abstract description 125
- 238000004519 manufacturing process Methods 0.000 claims description 148
- 238000012545 processing Methods 0.000 claims description 98
- 238000006243 chemical reaction Methods 0.000 claims description 72
- 230000008569 process Effects 0.000 claims description 41
- 238000004891 communication Methods 0.000 claims description 4
- 238000004590 computer program Methods 0.000 claims description 3
- 230000009466 transformation Effects 0.000 claims 2
- 238000000605 extraction Methods 0.000 description 11
- 238000010586 diagram Methods 0.000 description 9
- 238000013461 design Methods 0.000 description 8
- 230000006870 function Effects 0.000 description 6
- 206010063385 Intellectualisation Diseases 0.000 description 4
- 238000010276 construction Methods 0.000 description 4
- 238000007726 management method Methods 0.000 description 4
- 230000004069 differentiation Effects 0.000 description 3
- 238000005516 engineering process Methods 0.000 description 3
- 230000008520 organization Effects 0.000 description 3
- 238000013500 data storage Methods 0.000 description 2
- 238000012423 maintenance Methods 0.000 description 2
- 238000010295 mobile communication Methods 0.000 description 2
- 238000012986 modification Methods 0.000 description 2
- 230000004048 modification Effects 0.000 description 2
- 238000007781 pre-processing Methods 0.000 description 2
- 238000006467 substitution reaction Methods 0.000 description 2
- 230000009286 beneficial effect Effects 0.000 description 1
- 238000013480 data collection Methods 0.000 description 1
- 230000003287 optical effect Effects 0.000 description 1
- 239000007787 solid Substances 0.000 description 1
- 230000007723 transport mechanism Effects 0.000 description 1
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/50—Network services
- H04L67/56—Provisioning of proxy services
- H04L67/565—Conversion or adaptation of application format or content
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L69/00—Network arrangements, protocols or services independent of the application payload and not provided for in the other groups of this subclass
- H04L69/08—Protocols for interworking; Protocol conversion
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04W—WIRELESS COMMUNICATION NETWORKS
- H04W8/00—Network data management
- H04W8/18—Processing of user or subscriber data, e.g. subscribed services, user preferences or user profiles; Transfer of user or subscriber data
- H04W8/20—Transfer of user or subscriber data
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Computer Security & Cryptography (AREA)
- Databases & Information Systems (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
- Multi Processors (AREA)
Abstract
本发明公开了一种网络数据面系统、数据交互方法及存储介质,网络数据面系统包括第一层级数据面系统,第一层级数据面系统包括第一应用代理模块和第一数据服务模块,第一数据服务模块用于根据标准数据订阅需求向第二层级数据面系统发送标准数据订阅需求;第一数据服务模块还用于根据标准数据提取请求向第二层级数据面系统发送标准数据提取请求以获取第二层级数据面系统根据标准数据订阅需求得到的第二订阅数据,以使第一应用代理模块根据第一订阅数据和第二订阅数据得到定制数据并将定制数据发送给数据消费者。本发明能够拉通不同网络层的数据模型和标准化流程,提升网络数据一致性和有效性,提高不同网络层之间基于数据交互的功能协作成功率。
Description
技术领域
本发明涉及移动通信网络技术领域,特别涉及一种网络数据面系统、数据交互方法及存储介质。
背景技术
相关技术中,在4G和5G网络架构中没有设计跨网络协议栈或跨网络设备的数据面系统,网络中不同协议层之间或不同设备间的数据协作缺少标准流程,不同设备、不同协议层的数据处理相关流程各异,数据维护复杂度随着数据协作波及方的增多而急剧增加,导致不同网络层之间基于数据交互的功能协作成功率较低。
发明内容
本发明旨在至少解决现有技术中存在的技术问题之一。为此,本发明提出一种网络数据面系统、数据交互方法及存储介质,能够拉通不同网络层的数据模型和标准化流程,提升了网络数据一致性和有效性,同时也提高了不同网络层之间基于数据交互的功能协作成功率。
第一方面,本发明实施例提供了一种网络数据面系统,包括第一层级数据面系统,所述第一层级数据面系统包括第一应用代理模块和第一数据服务模块,所述第一应用代理模块用于将数据消费者发送的标准数据订阅需求和标准数据提取请求发送到所述第一数据服务模块;
所述第一数据服务模块设置有第一数据模型,所述第一数据服务模块用于根据所述标准数据订阅需求向第二层级数据面系统发送所述标准数据订阅需求,并根据所述第一数据模型和所述标准数据订阅需求得到第一订阅数据;所述第一数据服务模块还用于根据所述标准数据提取请求向所述第二层级数据面系统发送所述标准数据提取请求以获取所述第二层级数据面系统根据所述标准数据订阅需求得到的第二订阅数据,且将所述第一订阅数据和所述第二订阅数据发送到所述第一应用代理模块,以使所述第一应用代理模块根据所述第一订阅数据和所述第二订阅数据得到定制数据并将所述定制数据发送给所述数据消费者。
第二方面,本发明实施例还提供了一种网络数据面系统,包括与第一层级数据面系统通信连接的第二层级数据面系统,所述第二层级数据面系统包括:
第二数据服务模块,设置有第二数据模型,所述第二数据服务模块与所述第一层级数据面系统中的第一数据服务模块连接以接收所述第一数据服务模块发送的标准数据订阅需求和标准数据提取请求,所述第二数据服务模块用于根据所述标准数据订阅需求和所述第二数据模型得到第二订阅数据,并根据所述标准数据提取请求将所述第二订阅数据发送到所述第一数据服务模块。
第三方面,本发明实施例还提供了一种网络数据面系统的数据交互方法,应用于所述网络数据面系统中的第一层级数据面系统,所述第一层级数据面系统包括第一应用代理模块和第一数据服务模块,所述第一数据服务模块设置有第一数据模型,所述第一数据服务模块与所述第一应用代理模块连接;
所述数据交互方法包括:
通过所述第一应用代理模块将数据消费者发送的标准数据订阅需求发送到所述第一数据服务模块;
通过所述第一数据服务模块接收所述标准数据订阅需求并根据所述标准数据订阅需求向第二层级数据面系统发送所述标准数据订阅需求,且根据所述第一数据模型和所述标准数据订阅需求得到第一订阅数据;
通过所述第一应用代理模块将所述数据消费者发送的标准数据提取请求发送到所述第一数据服务模块;
通过所述第一数据服务模块接收所述标准数据提取请求并根据所述标准数据提取请求向所述第二层级数据面系统发送标准数据提取请求以获取所述第二层级数据面系统根据所述标准数据订阅需求得到的第二订阅数据,且将所述第一订阅数据和所述第二订阅数据发送到所述第一应用代理模块;
通过所述第一应用代理模块接收所述第一订阅数据和所述第二订阅数据并根据所述第一订阅数据和所述第二订阅数据得到定制数据,且将所述定制数据发送给所述数据消费者。
第四方面,本发明实施例还提供了一种网络数据面系统的数据交互方法,应用于所述网络数据面系统中的与第一层级数据面系统通信连接的第二层级数据面系统,所述第二层级数据面系统包括第二数据服务模块,所述第二数据服务模块设置有第二数据模型,所述第二数据服务模块与所述第一层级数据面系统中的第一数据服务模块连接;
所述数据交互方法包括:
通过所述第二数据服务模块接收所述第一数据服务模块发送的标准数据订阅需求并根据所述标准数据订阅需求和所述第二数据模型得到第二订阅数据;
通过所述第二数据服务模块接收所述第一数据服务模块发送的标准数据提取请求并根据所述标准数据提取请求将所述第二订阅数据发送到所述第一数据服务模块。
第五方面,本发明实施例还提供了一种网络数据面系统,包括:存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序,所述处理器执行所述程序时实现:
如第三方面所述的网络数据面系统的数据交互方法;
或者,
如第四方面所述的网络数据面系统的数据交互方法。
第六方面,本发明实施例还提供了一种计算机可读存储介质,存储有计算机可执行指令,所述计算机可执行指令用于:
执行第三方面所述的网络数据面系统的数据交互方法;
或者,
执行第四方面所述的网络数据面系统的数据交互方法。
本发明实施例中提供的一个或多个技术方案,至少具有如下有益效果:本发明实施例包括:第一层级数据面系统中的第一数据服务模块根据第一应用代理模块发送的标准数据订阅需求向第二层级数据面系统发送标准数据订阅需求,并根据第一数据模型和标准数据订阅需求得到第一订阅数据,第一数据服务模块还根据第一应用代理模块发送的标准数据提取请求向第二层级数据面系统发送标准数据提取请求以获取第二层级数据面系统根据标准数据订阅需求得到的第二订阅数据,且将第一订阅数据和第二订阅数据发送到第一应用代理模块,以使第一应用代理模块根据第一订阅数据和第二订阅数据得到定制数据并将定制数据发送给数据消费者。根据本发明实施例提供的方案,对齐网络不同层级数据面系统对相同数据的理解,能够拉通不同网络层的数据模型和标准化流程,提升了网络数据一致性和有效性,提高了不同网络层之间基于数据交互的功能协作成功率。
本发明的附加方面和/或优点将在下面的描述中部分给出,部分将从下面的描述中变得明显,或通过本发明的实践了解到。
附图说明
本发明的上述和/或附加的方面和优点从结合下面附图对实施例的描述中将变得明显和容易理解,其中:
图1是本发明一个实施例提供的提供的网络数据面系统的结构示意图;
图2是本发明一个实施例提供的提供的网络数据面系统的流程示意图;
图3是本发明一个实施例提供的提供的网络数据面系统进行数据订阅和采集的流程示意图;
图4是本发明一个实施例提供的所提供的网络数据面系统进行数据定制和提取的流程示意图;
图5是本发明另一实施例提供的所提供的网络数据面系统的示意图;
图6是本发明第三方面实施例提供的网络数据面系统的数据交互方法的流程示意图;
图7是本发明第三方面实施例提供的获取第一订阅数据的流程示意图;
图8是本发明第三方面实施例提供的获取第一订阅数据的具体流程示意图;
图9是本发明第三方面实施例提供的获取标准数据订阅需求的流程示意图;
图10是本发明第三方面实施例提供的获取标准数据提取请求的流程示意图;
图11是本发明第三方面实施例提供的获取第一数据定制规则的流程示意图;
图12是本发明第三方面实施例提供的获取定制数据的流程示意图;
图13是本发明第四方面实施例提供的网络数据面系统的数据交互方法的流程示意图;
图14是本发明第四方面实施例提供的获取第二订阅数据的流程示意图;
图15是本发明第四方面实施例提供的获取第二订阅数据的具体流程示意图。
具体实施方式
为了使本发明的目的、技术方案及优点更加清楚明白,以下结合附图及实施例,对本发明进行进一步详细说明。应当理解,此处所描述的具体实施例仅用以解释本发明,并不用于限定本发明。
需要说明的是,虽然在系统示意图中进行了功能模块划分,在流程图中示出了逻辑顺序,但是在某些情况下,可以以不同于系统中的模块划分,或流程图中的顺序执行所示出或描述的步骤。说明书和权利要求书及上述附图中的术语等是用于区别类似的对象,而不必用于描述特定的顺序或先后次序。
需要说明的是,虽然在装置示意图中进行了功能模块划分,在流程图中示出了逻辑顺序,但是在某些情况下,可以以不同于装置中的模块划分,或流程图中的顺序执行所示出或描述的步骤。说明书和权利要求书及上述附图中的术语“第一”、“第二”等是用于区别类似的对象,而不必用于描述特定的顺序或先后次序。
相关技术中,在4G和5G网络架构中没有设计跨网络协议栈或跨网络设备的数据面系统,网络中不同协议层之间或不同设备间的数据没有标准化、数据缺乏生命周期管理及数据协作缺少标准流程。具体地,数据没有标准化即指网络中不同的设备各自使用自身的数据标准,不同的协议层也各自使用自身的数据标准;当有网络功能需要跨设备协作时,各个设备采集的数据含义、量纲、颗粒度不统一,数据种类少,数据存在缺失、无标签、时间不对齐等质量问题,导致基于数据交互的功能由于数据内容对不齐而协作失败。数据缺乏生命周期管理即指网络中不同设备、不同协议层的数据生产能力和保存能力都不同,导致网络设备功能协作时,数据量无法对齐而协作失败。数据的协作缺少标准流程即指不同设备、不同协议层的数据处理相关流程各异,数据维护复杂度随着数据协作波及方的增多而急剧增加,导致不同网络层之间基于数据交互的功能协作成功率较低。
基于上述情况,本发明实施例提供了一种网络数据面系统、数据交互方法及存储介质,其中,网络数据面系统包括第一层级数据面系统和第二层级数据面系统,第一层级数据面系统中的第一数据服务模块根据第一应用代理模块发送的标准数据订阅需求向第二层级数据面系统发送标准数据订阅需求,并根据第一数据模型和标准数据订阅需求得到第一订阅数据,第一数据服务模块还根据第一应用代理模块发送的标准数据提取请求向第二层级数据面系统发送标准数据提取请求以获取第二层级数据面系统根据标准数据订阅需求得到的第二订阅数据,且将第一订阅数据和第二订阅数据发送到第一应用代理模块,以使第一应用代理模块根据第一订阅数据和第二订阅数据得到定制数据并将定制数据发送给数据消费者。根据本发明实施例提供的方案,对齐网络不同层级数据面系统对相同数据的理解,能够拉通不同网络层的数据模型和标准化流程,提升了网络数据一致性和有效性,提高了不同网络层之间基于数据交互的功能协作成功率。
下面结合附图,对本发明实施例作进一步阐述。
本发明第一方面实施例具体提供一种网络数据面系统,参照图1,图1是本发明一个实施例提供的网络数据面系统的结构示意图,网络数据面系统包括第一层级数据面系统,第一层级数据面系统包括第一应用代理模块和第一数据服务模块,第一应用代理模块用于将数据消费者发送的标准数据订阅需求和标准数据提取请求发送到第一数据服务模块;第一数据服务模块设置有第一数据模型,第一数据服务模块用于根据标准数据订阅需求向第二层级数据面系统发送标准数据订阅需求,并根据第一数据模型和标准数据订阅需求得到第一订阅数据;第一数据服务模块还用于根据标准数据提取请求向第二层级数据面系统发送标准数据提取请求以获取第二层级数据面系统根据标准数据订阅需求得到的第二订阅数据,且将第一订阅数据和第二订阅数据发送到第一应用代理模块,以使第一应用代理模块根据第一订阅数据和第二订阅数据得到定制数据并将定制数据发送给数据消费者。
需要说明的是,首先,第一应用代理模块接收数据消费者发送的数据订阅需求并根据数据订阅需求生成标准数据订阅需求,且将标准数据订阅需求发送到第一数据服务模块,以使第一数据服务模块根据标准数据订阅需求判断是否向第二层级数据面系统发送标准数据订阅需求,并根据第一数据模型和标准数据订阅需求得到第一订阅数据,且将第一订阅数据发送到第一应用代理模块;其次,第一应用代理模块接收所述数据消费者发送的数据定制需求并根据所述数据定制需求生成标准数据定制需求,且将所述标准数据定制需求发送到所述第一数据服务模块,以使第一数据服务模块接收标准数据定制需求并根据标准数据定制需求和第一数据模型生成第一数据定制规则,且将第一数据定制规则发送到第一应用代理模块;最后,第一应用代理模块接收数据消费者发送的数据提取请求并根据数据提取请求生成标准数据提取请求,且将标准数据提取请求发送到第一数据服务模块,以使第一数据服务模块还用于根据标准数据提取请求判断是否向第二层级数据面系统发送标准数据提取请求以获取第二层级数据面系统根据标准数据订阅需求得到的第二订阅数据,且将第二订阅数据发送到第一应用代理模块;第一应用代理模块接收第一订阅数据和第二订阅数据并根据第一数据定制规则对第一订阅数据和第二订阅数据进行加工处理,进而得到定制数据并将定制数据发送给数据消费者。
具体地,第一数据服务模块根据标准数据订阅需求生成数据采集任务,判断数据采集任务是否本层级也即第一层级数据面系统中的数据即可满足,是否需要下一层级数据面系统也即第二层级数据面系统中的数据,若本层级中的数据即可满足,则根据第一数据模型和标准数据订阅需求得到第一订阅数据,且将第一订阅数据发送到第一应用代理模块;若需要下一层级数据面系统也即第二层级数据面系统中的数据,则需向第二层级数据面系统发送标准数据订阅需求,并根据第一数据模型和标准数据订阅需求得到第一订阅数据,且将第一订阅数据发送到第一应用代理模块。第一数据服务模块根据标准数据提取请求生成数据提取任务,判断数据提取任务是否本层级数据面系统中的数据即可满足,是否需要下一层级数据面系统中的数据,若本层级中的数据即可满足,则根据数据提取任务组织所有所需数据并将所有所需数据发送到第一应用代理模块,第一应用代理模块根据第一数据定制规则加工处理该所需数据,并将加工处理后的数据发送给数据消费者;若需要下一层级数据面系统中的数据,则需向第二层级数据面系统发送标准数据提取请求以获取第二层级数据面系统中数据提取任务中所有需要的数据,再将该数据以及本层级数据面系统中的所需数据均发送到第一应用代理模块,由第一应用代理模块根据第一数据定制规则加工处理该所需数据,并将加工处理后的数据发送给数据消费者。
在一些实施例中,第一数据服务模块根据标准数据定制需求生成数据定制任务并保存数据定制任务,无论数据定制任务是否需要下一层级数据面系统中的数据,均不需向下一层级数据面系统发送标准数据定制需求,直接根据标准数据定制需求和第一数据模型生成第一数据定制规则,再将第一数据定制规则发送到第一应用代理模块。在另一些实施例中,第一数据服务模块根据标准数据定制需求生成数据定制任务并保存数据定制任务,判断数据定制任务是否本层级数据面系统中的数据即可满足,是否需要下一层级数据面系统中的数据,若本层级中的数据即可满足,则根据标准数据定制需求和第一数据模型生成第一数据定制规则,且将第一数据定制规则发送到第一应用代理模块;若需要下一层级数据面系统中的数据,则还需向第二层级数据面系统发送标准数据定制需求。
需要说明的是,第一层级数据面系统为较高层级网络设备数据面模块,第二层级数据面系统为较低层级网络设备数据面模块;第二层级数据面系统包括第二应用代理模块和第二数据服务模块,第一应用代理模块和第一数据服务模块连接,第二应用代理模块和第二数据服务模块连接,第一数据服务模块与第二数据服务模块连接。第二数据服务模块设置有第二数据模型和第二数据内容,第一数据服务模块中也设置有第一数据模型和第一数据内容,其中,第一数据模型与第二数据模型相同,第一数据内容与第二数据内容不同,通过这种设置,能够基于统一的数据模型对齐网络不同层级数据面系统对相同数据的理解;并且在网络数据面系统中定义统一的数据模型数据面统一了网络中数据的生产、存储、访问、使用标准,为网络智能化和网络数字孪生构建提供了高效的数据服务,为网络智慧内生架构提供了数据基础。其中,第一层级数据面系统和第二层级数据面系统可以是同一设备的不同层级数据面系统,也可以是不同设备的不同层级数据面系统。
需要说明的是,在定义网络数据面系统时,数据面贯穿不同设备层次以及不同协议栈,在每层设备中均提供数据服务模块来管理本层级数据面系统生产或存储的数据,并为本层级数据消费者以及更高层级的网络节点提供数据能力。该数据服务模块包括数据采集、数据预处理、数据存储、数据访问、数据开放与协同等。
需要说明的是,网络数据面系统不仅可以包括第一层级数据面系统和第二层级数据面系统,还可以包括更多层级数据面系统,本发明实施例不作限定。示例性的,参照图5,网络数据面系统由运营商平台大数据中心、基站网管/核心网网管及基站/核心网三个层级的数据面系统构成。
需要说明的是,第一应用代理模块用于转发和适配数据服务与数据消费者的接口,还用于将标准化数据如第一订阅数据和第二订阅数据加工转换为数据消费者所需的数据结构和内容。
示例性的,参照图2,第①控制流表示在网络中较高层网络设备的数据面模块即第一层级数据面系统的第一数据服务模块和较低层网络设备的数据面模块即第二层级数据面系统的第二数据服务模块之间交互数据模型来对齐不同数据面系统对数据结构和内容的解释,通过交互数据生产需求、数据定制需求、数据提取需求来统一跨层网络设备的数据协作处理过程,通过交互数据内容来满足不同网络层级数据面系统数据消费者的数据需求。第③数据流表示第一应用代理模块与不同的数据消费者交互,来适配不同数据消费者的不同数据结构、格式、内容的差异化需求,负责差异化数据与标准化数据的转换工作。
参照图1,可以理解的是,第一层级数据面系统还包括第一数据执行模块,第一数据执行模块与第一数据服务模块连接,第一数据服务模块还用于根据第一数据模型和标准数据订阅需求生成第一数据生产规则、第一数据加工转换规则,且将第一数据生产规则和第一数据加工转换规则发送到第一数据执行模块;第一数据执行模块用于根据第一数据生产规则和第一数据加工转换规则生成第一订阅数据并将第一订阅数据发送到第一数据服务模块。
需要说明的是,第一数据服务模块用于管理第一数据模型、数据的生产和标准化处理、存储和管理数据标准化数据内容、处理数据的订阅和采集任务、处理数据的定制和提取任务以及网络不同层设备的数据服务之间交互数据模型、数据生产需求、数据定制需求、数据提取需求、数据内容。第一数据执行模块将加工后的标准化数据即第一订阅数据发送到第一数据服务模块后,第一数据服务模块根据第一数据模型存储和管理第一订阅数据。
参照图1至图3,可以理解的是,第一数据执行模块包括第一数据服务代理模块和第一数据生产模块,第一数据服务模块分别与第一数据生产模块、第一数据服务代理模块连接,第一数据生产模块与第一数据服务代理模块连接;第一数据生产模块用于接收第一数据生产规则并根据第一数据生产规则生成第一原始数据,且将第一原始数据发送到第一数据服务代理模块;第一数据服务代理模块用于接收第一数据加工转换规则和第一原始数据并根据第一数据加工转换规则对第一原始数据进行加工处理得到第一订阅数据,且将第一订阅数据发送到第一数据服务模块。
需要说明的是,本发明实施例提供的网络数据面系统针对不同层级的数据面,建立了统一的网络数据面系统,针对网络中的数据全生命周期,网络数据面系统定义了各层级数据面中的功能实体、功能实体对数据的处理过程、标准的数据模型的设计以及数据处理的标准协作过程设计。例如,在第一层级数据面系统中,定义支撑数据面的功能实体包括:第一数据生产模块、第一数据服务代理模块及第一数据服务模块等。
需要说明的是,第一数据生产模块用于生产网络设备的数据,生产者按照数据服务模块下发的数据生产规则来生产原始数据。第一数据服务代理模块根据第一数据加工转换规则对第一原始数据进行加工处理,得到第一订阅数据也即标准化数据;其中,第一数据加工转换规则根据第一数据模型来定义,以约定数据的结构、量纲、时间精度等信息。
示例性的,参照图2,第②控制流表示第一层级数据面系统内的第一数据服务模块与本层级的第一数据生产者模块、第一数据服务代理模块、第一应用代理模块交互,控制本层级数据面系统内的数据生产、存储、提取的处理过程。
示例性的,参照图3,数据订阅和采集过程为:第①控制流表示数据消费者向第一应用代理模块发送数据订阅需求,其中,数据订阅需求包括数据采集的对象、内容等;第②控制流表示第一应用代理模块将数据订阅需求适配成第一数据服务模块的标准数据订阅需求并发送到第一数据服务模块;第③控制流表示第一数据服务模块根据标准数据订阅需求生成数据采集任务,判断数据采集任务是否本层级也即第一层级数据面系统中的数据即可满足,是否需要下一层级数据面系统也即第二层级数据面系统中的数据,若需要下一层级数据面系统也即第二层级数据面系统中的数据,则需向第二层级数据面系统发送标准数据订阅需求;第④控制流表示根据第一数据模型和标准数据订阅需求生成第一数据生产规则并将第一数据生产规则发送到第一数据生产模块;第⑤控制流表示第一数据服务模块根据第一数据模型和标准数据订阅需求生成第一数据加工转换规则并将第一数据加工转换规则发送到第一数据服务代理模块;第⑥数据流表示第一数据生产模块根据第一数据生产规则生成第一原始数据,并将第一原始数据发送到第一数据服务代理模块;第⑦数据流表示第一数据服务代理模块根据第一数据加工转换规则对第一原始数据进行加工处理得到第一订阅数据,且将第一订阅数据发送到第一数据服务模块,第一数据服务模块根据第一数据模型存储和管理第一订阅数据。
示例性的,参照图4,数据定制和提取过程为:第①控制流表示数据消费者向第一应用代理模块发送数据定制需求,数据定制需求包含数据对象、结构、时间,量纲等;第②控制流表示第一应用代理模块将数据定制需求适配成第一数据服务模块的标准数据定制需求并发送到第一数据服务模块;第③控制流表示第一数据服务模块根据标准数据定制需求生成数据定制任务并保存数据定制任务,判断数据定制任务是否本层级数据面系统中的数据即可满足,是否需要下一层级数据面系统中的数据,若需要下一层级数据面系统中的数据,则还需向第二层级数据面系统发送标准数据定制需求;第④控制流表示第一数据服务模块根据标准数据定制需求和第一数据模型生成第一数据定制规则,且将第一数据定制规则发送到第一应用代理模块;第⑤控制流表示数据消费者向第一应用代理模块发送数据提取请求;第⑥控制流表示第一应用代理模块根据数据提取请求适配成第一数据服务模块的标准数据提取请求,且将标准数据提取请求发送到第一数据服务模块;第⑦控制流表示第一数据服务模块根据标准数据提取请求生成数据提取任务,判断数据提取任务是否本层级数据面系统中的数据即可满足,是否需要下一层级数据面系统中的数据,若需要下一层级数据面系统中的数据,则需向第二层级数据面系统发送标准数据提取请求;第⑧数据流表示第二层级数据面系统的第二数据服务模块若收到第一数据服务模块发送的标准数据提取请求,则组织所需数据即第二订阅数据发送到第一数据服务模块;第⑨数据流表示第一数据服务模块根据数据提取任务组织所有所需数据,并将所有所需数据即第一订阅数据和第二订阅数据发送到第一应用代理模块;第⑩数据流表示第一应用代理模块根据第一数据定制规则对第一订阅数据和第二订阅数据进行加工处理,进而得到定制数据并将定制数据发送给数据消费者。
需要说明的是,第二层级数据面系统包括第二数据服务代理模块和第二数据生产模块,第二数据服务模块分别与第二数据生产模块、第二数据服务代理模块连接,第二数据生产模块与第二数据服务代理模块连接。
第二方面,参照图1,本发明实施例还提供了一种网络数据面系统,网络数据面系统包括与第一层级数据面系统通信连接的第二层级数据面系统,第二层级数据面系统包括第二数据服务模块,第二数据服务模块设置有第二数据模型,第二数据服务模块与第一层级数据面系统中的第一数据服务模块连接以接收第一数据服务模块发送的标准数据订阅需求和标准数据提取请求,第二数据服务模块用于根据标准数据订阅需求和第二数据模型得到第二订阅数据,并根据标准数据提取请求将第二订阅数据发送到第一数据服务模块。
需要说明的是,第二数据服务模块根据标准数据提取请求将第二订阅数据发送到第一数据服务模块后,以使第一数据服务模块将本层级数据面系统的第一订阅数据和第二层级数据面系统的第二订阅数据发送到第一应用代理模块,以使第一应用代理模块根据第一订阅数据和第二订阅数据得到定制数据并将定制数据发送给数据消费者。
需要说明的是,第一层级数据面系统包括第一应用代理模块和第一数据服务模块,第二层级数据面系统还包括第二应用代理模块,第一应用代理模块和第一数据服务模块连接,第一应用代理模块和第一数据服务模块连接,第二应用代理模块和第二数据服务模块连接,第一数据服务模块与第二数据服务模块连接。
需要说明的是,首先,第一应用代理模块接收数据消费者发送的数据订阅需求并根据数据订阅需求生成标准数据订阅需求,且将标准数据订阅需求发送到第一数据服务模块,以使第一数据服务模块根据标准数据订阅需求判断是否向第二层级数据面系统的第二数据服务模块发送标准数据订阅需求,以使第二数据服务模块用于根据标准数据订阅需求和第二数据模型得到第二订阅数据;第一数据服务模块还根据第一数据模型和标准数据订阅需求得到第一订阅数据,且将第一订阅数据发送到第一应用代理模块;其次,第一应用代理模块接收所述数据消费者发送的数据定制需求并根据所述数据定制需求生成标准数据定制需求,且将所述标准数据定制需求发送到所述第一数据服务模块,以使第一数据服务模块接收标准数据定制需求并根据标准数据定制需求和第一数据模型生成第一数据定制规则,且将第一数据定制规则发送到第一应用代理模块;最后,第一应用代理模块接收数据消费者发送的数据提取请求并根据数据提取请求生成标准数据提取请求,且将标准数据提取请求发送到第一数据服务模块,以使第一数据服务模块还用于根据标准数据提取请求判断是否向第二层级数据面系统的第二数据服务模块发送标准数据提取请求以获取第二数据服务模块根据标准数据订阅需求得到的第二订阅数据,且将第二订阅数据发送到第一应用代理模块;第一应用代理模块接收第一订阅数据和第二订阅数据并根据第一数据定制规则对第一订阅数据和第二订阅数据进行加工处理,进而得到定制数据并将定制数据发送给数据消费者。
具体地,第一层级数据面系统的第一数据服务模块根据标准数据订阅需求生成数据采集任务,判断数据采集任务是否本层级也即第一层级数据面系统中的数据即可满足,是否需要下一层级数据面系统也即第二层级数据面系统中的数据,若本层级中的数据即可满足,则根据第一数据模型和标准数据订阅需求得到第一订阅数据,且将第一订阅数据发送到第一应用代理模块;若需要下一层级数据面系统也即第二层级数据面系统中的数据,则需向第二层级数据面系统发送标准数据订阅需求,并根据第一数据模型和标准数据订阅需求得到第一订阅数据,且将第一订阅数据发送到第一应用代理模块。第一数据服务模块根据标准数据提取请求生成数据提取任务,判断数据提取任务是否本层级数据面系统中的数据即可满足,是否需要下一层级数据面系统中的数据,若本层级中的数据即可满足,则根据数据提取任务组织所有所需数据并将所有所需数据发送到第一应用代理模块,第一应用代理模块根据第一数据定制规则加工处理该所需数据,并将加工处理后的数据发送给数据消费者;若需要下一层级数据面系统中的数据,则需向第二层级数据面系统发送标准数据提取请求以获取第二层级数据面系统中数据提取任务中所有需要的数据,再将该数据以及本层级数据面系统中的所需数据均发送到第一应用代理模块,由第一应用代理模块根据第一数据定制规则加工处理该所需数据,并将加工处理后的数据发送给数据消费者。根据本发明实施例提供的方案,基于统一的数据模型对齐网络不同层级数据面系统对相同数据的理解,能够拉通不同网络层的数据模型和标准化流程,提升了网络数据一致性和有效性,提高了不同网络层之间基于数据交互的功能协作成功率。
在一些实施例中,第一数据服务模块根据标准数据定制需求生成数据定制任务并保存数据定制任务,无论数据定制任务是否需要下一层级数据面系统中的数据,均不需向下一层级数据面系统发送标准数据定制需求,直接根据标准数据定制需求和第一数据模型生成第一数据定制规则,再将第一数据定制规则发送到第一应用代理模块。在另一些实施例中,第一数据服务模块根据标准数据定制需求生成数据定制任务并保存数据定制任务,判断数据定制任务是否本层级数据面系统中的数据即可满足,是否需要下一层级数据面系统中的数据,若本层级中的数据即可满足,则根据标准数据定制需求和第一数据模型生成第一数据定制规则,且将第一数据定制规则发送到第一应用代理模块;若需要下一层级数据面系统中的数据,则还需向第二层级数据面系统发送标准数据定制需求。
需要说明的是,第二数据服务模块设置有第二数据模型和第二数据内容,第一数据服务模块中也设置有第一数据模型和第一数据内容,其中,第一数据模型与第二数据模型相同,第一数据内容与第二数据内容不同,通过这种设置,能够基于统一的数据模型对齐网络不同层级数据面系统对相同数据的理解;并且在网络数据面系统中定义统一的数据模型数据面统一了网络中数据的生产、存储、访问、使用标准,为网络智能化和网络数字孪生构建提供了高效的数据服务,为网络智慧内生架构提供了数据基础。其中,第一层级数据面系统和第二层级数据面系统可以是同一设备的不同层级数据面系统,也可以是不同设备的不同层级数据面系统。
需要说明的是,网络数据面系统不仅可以包括第一层级数据面系统和第二层级数据面系统,还可以包括更多层级数据面系统,本发明实施例不作限定。示例性的,参照图5,网络数据面系统由运营商平台大数据中心、基站网管/核心网网管及基站/核心网三个层级的数据面系统构成。
示例性的,参照图2,第①控制流表示在网络中较高层网络设备的数据面模块即第一层级数据面系统的第一数据服务模块和较低层网络设备的数据面模块即第二层级数据面系统的第二数据服务模块之间交互数据模型来对齐不同数据面系统对数据结构和内容的解释,通过交互数据生产需求、数据定制需求、数据提取需求来统一跨层网络设备的数据协作处理过程,通过交互数据内容来满足不同网络层级数据面系统数据消费者的数据需求。第③数据流表示第二应用代理模块与不同的数据消费者交互,来适配不同数据消费者的不同数据结构、格式、内容的差异化需求,负责差异化数据与标准化数据的转换工作。
需要说明的是,数据消费者也可以从第二层级数据面系统向第二应用代理模块发送数据订阅需求、数据定制需求及数据订阅需求,第二应用代理模块分别根据数据订阅需求、数据定制需求及数据订阅需求生成标准数据订阅需求、标准数据定制需求及标准数据订阅需求,并将标准数据订阅需求、标准数据定制需求及标准数据订阅需求分别发送到第二数据服务模块;同理,第二数据服务模块得到数据消费者的所需数据并将所需数据发送到第二应用代理模块,以使第二应用代理模块根据所需数据得到定制数据并将定制数据发送给数据消费者。也即第二应用代理模块也用于转发和适配数据服务与数据消费者的接口,还用于将标准化数据加工转换为数据消费者所需的数据结构和内容。
参照图1,可以理解的是,第二层级数据面系统还包括第二数据执行模块,第二数据执行模块与第二数据服务模块连接,第二数据服务模块还用于根据第二数据模型和标准数据订阅需求生成第二数据生产规则、第二数据加工转换规则,且将第二数据生产规则和第二数据加工转换规则发送到第一数据执行模块;第二数据执行模块用于根据第二数据生产规则和第二数据加工转换规则生成第二订阅数据并将第二订阅数据发送到第二数据服务模块。
需要说明的是,第二数据服务模块用于管理第二数据模型、数据的生产和标准化处理、存储和管理数据标准化数据内容、处理数据的订阅和采集任务、处理数据的定制和提取任务以及网络不同层设备的数据服务之间交互数据模型、数据生产需求、数据定制需求、数据提取需求、数据内容。第二数据执行模块将加工后的标准化数据即第二订阅数据发送到第二数据服务模块后,第二数据服务模块根据第二数据模型存储和管理第二订阅数据。
参照图1至图3,可以理解的是,第二数据执行模块包括第二数据服务代理模块和第二数据生产模块,第二数据服务模块分别与第二数据生产模块、第二数据服务代理模块连接,第二数据生产模块与第二数据服务代理模块连接;第二数据生产模块用于接收第二数据生产规则并根据第二数据生产规则生成第二原始数据,且将第二原始数据发送到第二数据服务代理模块;第二数据服务代理模块用于接收第二数据加工转换规则和第二原始数据并根据第二数据加工转换规则对第二原始数据进行加工处理得到第二订阅数据,且将第二订阅数据发送到第二数据服务模块。
需要说明的是,本发明实施例提供的网络数据面系统针对不同层级的数据面,建立了统一的网络数据面系统,针对网络中的数据全生命周期,网络数据面系统定义了各层级数据面中的功能实体、功能实体对数据的处理过程、标准的数据模型的设计以及数据处理的标准协作过程设计。例如,在第二层级数据面系统中,定义支撑数据面的功能实体包括:第二数据生产模块、第二数据服务代理模块及第二数据服务模块等。
需要说明的是,第二数据生产模块用于生产网络设备的数据,生产者按照数据服务模块下发的数据生产规则来生产原始数据。第二数据服务代理模块根据第二数据加工转换规则对第二原始数据进行加工处理,得到第二订阅数据也即标准化数据;其中,第二数据加工转换规则根据第二数据模型来定义,以约定数据的结构、量纲、时间精度等信息。
需要说明的是,第一层级数据面系统还包括第一数据服务代理模块和第一数据生产模块,第一数据服务模块分别与第一数据生产模块、第一数据服务代理模块连接,第一数据生产模块与第一数据服务代理模块连接。
示例性的,参照图2,第②控制流表示第二层级数据面系统内的第二数据服务模块与本层级的第二数据生产者模块、第二数据服务代理模块、第二应用代理模块交互,控制本层级数据面系统内的数据生产、存储、提取的处理过程。
在一些实施例中,参照图3,数据消费者从第二层级数据面系统进行数据订阅和采集过程为:第①控制流表示数据消费者向第二应用代理模块发送数据订阅需求,其中,数据订阅需求包括数据采集的对象、内容等;第②控制流表示第二应用代理模块将数据订阅需求适配成第二数据服务模块的标准数据订阅需求并发送到第二数据服务模块;第③控制流表示第二数据服务模块根据标准数据订阅需求生成数据采集任务,判断数据采集任务是否本层级也即第二层级数据面系统中的数据即可满足,是否需要上一层级数据面系统也即第以层级数据面系统中的数据,若需要上一层级数据面系统也即第一层级数据面系统中的数据,则需向第一层级数据面系统发送标准数据订阅需求;第④控制流表示根据第二数据模型和标准数据订阅需求生成第二数据生产规则并将第二数据生产规则发送到第二数据生产模块;第⑤控制流表示第二数据服务模块根据第二数据模型和标准数据订阅需求生成第二数据加工转换规则并将第二数据加工转换规则发送到第二数据服务代理模块;第⑥数据流表示第二数据生产模块根据第二数据生产规则生成第二原始数据,并将第二原始数据发送到第二数据服务代理模块;第⑦数据流表示第二数据服务代理模块根据第二数据加工转换规则对第二原始数据进行加工处理得到第二订阅数据,且将第二订阅数据发送到第二数据服务模块,第二数据服务模块根据第二数据模型存储和管理第二订阅数据。
在一些实施例中,参照图4,数据消费者从第二层级数据面系统进行数据定制和提取过程为:第①控制流表示数据消费者向第二应用代理模块发送数据定制需求,数据定制需求包含数据对象、结构、时间,量纲等;第②控制流表示第二应用代理模块将数据定制需求适配成第二数据服务模块的标准数据定制需求并发送到第二数据服务模块;第③控制流表示第二数据服务模块根据标准数据定制需求生成数据定制任务并保存数据定制任务,判断数据定制任务是否本层级数据面系统中的数据即可满足,是否需要上一层级数据面系统中的数据,若需要上一层级数据面系统中的数据,则还需向第一层级数据面系统发送标准数据定制需求;第④控制流表示第二数据服务模块根据标准数据定制需求和第二数据模型生成第二数据定制规则,且将第二数据定制规则发送到第二应用代理模块;第⑤控制流表示数据消费者向第二应用代理模块发送数据提取请求;第⑥控制流表示第二应用代理模块根据数据提取请求适配成第二数据服务模块的标准数据提取请求,且将标准数据提取请求发送到第二数据服务模块;第⑦控制流表示第二数据服务模块根据标准数据提取请求生成数据提取任务,判断数据提取任务是否本层级数据面系统中的数据即可满足,是否需要上一层级数据面系统中的数据,若需要上一层级数据面系统中的数据,则需向第一层级数据面系统发送标准数据提取请求;第⑧数据流表示第一层级数据面系统的第一数据服务模块若收到第二数据服务模块发送的标准数据提取请求,则组织所需数据即第一订阅数据发送到第二数据服务模块;第⑨数据流表示第二数据服务模块根据数据提取任务组织所有所需数据,并将所有所需数据即第二订阅数据和第一订阅数据发送到第二应用代理模块;第⑩数据流表示第二应用代理模块根据第二数据定制规则对第二订阅数据和第一订阅数据进行加工处理,进而得到定制数据并将定制数据发送给数据消费者。
第三方面,本发明实施例还提供了一种网络数据面系统的数据交互方法,应用于网络数据面系统中的第一层级数据面系统,参照图1至图3、图6,第一层级数据面系统包括第一应用代理模块和第一数据服务模块,第一数据服务模块设置有第一数据模型,第一数据服务模块与第一应用代理模块连接;
数据交互方法包括但不限于以下步骤:
步骤S100,通过第一应用代理模块将数据消费者发送的标准数据订阅需求发送到第一数据服务模块;
步骤S200,通过第一数据服务模块接收标准数据订阅需求并根据标准数据订阅需求向第二层级数据面系统发送标准数据订阅需求,且根据第一数据模型和标准数据订阅需求得到第一订阅数据;
步骤S300,通过第一应用代理模块将数据消费者发送的标准数据提取请求发送到第一数据服务模块;
步骤S400,通过第一数据服务模块接收标准数据提取请求并根据标准数据提取请求向第二层级数据面系统发送标准数据提取请求以获取第二层级数据面系统根据标准数据订阅需求得到的第二订阅数据,且将第一订阅数据和第二订阅数据发送到第一应用代理模块;
步骤S500,通过第一应用代理模块接收第一订阅数据和第二订阅数据并根据第一订阅数据和第二订阅数据得到定制数据,且将定制数据发送给数据消费者。
具体地,第一数据服务模块根据标准数据订阅需求生成数据采集任务,判断数据采集任务是否本层级也即第一层级数据面系统中的数据即可满足,是否需要下一层级数据面系统也即第二层级数据面系统中的数据,若本层级中的数据即可满足,则根据第一数据模型和标准数据订阅需求得到第一订阅数据,且将第一订阅数据发送到第一应用代理模块;若需要下一层级数据面系统也即第二层级数据面系统中的数据,则需向第二层级数据面系统发送标准数据订阅需求,并根据第一数据模型和标准数据订阅需求得到第一订阅数据,且将第一订阅数据发送到第一应用代理模块。第一数据服务模块根据标准数据提取请求生成数据提取任务,判断数据提取任务是否本层级数据面系统中的数据即可满足,是否需要下一层级数据面系统中的数据,若本层级中的数据即可满足,则根据数据提取任务组织所有所需数据并将所有所需数据发送到第一应用代理模块,第一应用代理模块根据第一数据定制规则加工处理该所需数据,并将加工处理后的数据发送给数据消费者;若需要下一层级数据面系统中的数据,则需向第二层级数据面系统发送标准数据提取请求以获取第二层级数据面系统中数据提取任务中所有需要的数据,再将该数据以及本层级数据面系统中的所需数据均发送到第一应用代理模块,由第一应用代理模块根据第一数据定制规则加工处理该所需数据,并将加工处理后的数据发送给数据消费者。
需要说明的是,第一层级数据面系统为较高层级网络设备数据面模块,第二层级数据面系统为较低层级网络设备数据面模块;第二层级数据面系统包括第二应用代理模块和第二数据服务模块,第一应用代理模块和第一数据服务模块连接,第二应用代理模块和第二数据服务模块连接,第一数据服务模块与第二数据服务模块连接。第一数据服务模块设置有第一数据模型和第一数据内容,第二数据服务模块中也设置有第二数据模型和第二数据内容,其中,第一数据模型与第二数据模型相同,第一数据内容与第二数据内容不同,通过这种设置,能够基于统一的数据模型对齐网络不同层级数据面系统对相同数据的理解;并且在网络数据面系统中定义统一的数据模型数据面统一了网络中数据的生产、存储、访问、使用标准,为网络智能化和网络数字孪生构建提供了高效的数据服务,为网络智慧内生架构提供了数据基础。其中,第一层级数据面系统和第二层级数据面系统可以是同一设备的不同层级数据面系统,也可以是不同设备的不同层级数据面系统。
在本发明实施例中,基于统一的数据模型对齐网络不同层级数据面系统对相同数据的理解,能够拉通不同网络层的数据模型和标准化流程,提升了网络数据一致性和有效性,提高了不同网络层之间基于数据交互的功能协作成功率。
需要说明的是,网络数据面系统不仅可以包括第一层级数据面系统和第二层级数据面系统,还可以包括更多层级数据面系统,本发明实施例不作限定。示例性的,参照图5,网络数据面系统由运营商平台大数据中心、基站网管/核心网网管及基站/核心网三个层级的数据面系统构成。
需要说明的是,第一应用代理模块用于转发和适配数据服务与数据消费者的接口,还用于将标准化数据如第一订阅数据和第二订阅数据加工转换为数据消费者所需的数据结构和内容。
参照图1和图7,可以理解的是,第一层级数据面系统还包括第一数据执行模块,第一数据执行模块与第一数据服务模块连接,步骤S200中的根据第一数据模型和标准数据订阅需求得到第一订阅数据,包括但不限于以下步骤:
步骤S210,通过第一数据服务模块接收第一数据服务模块发送的标准数据订阅需求并根据第一数据模型和标准数据订阅需求生成第一数据生产规则、第一数据加工转换规则,且将第一数据生产规则和第一数据加工转换规则发送到第一数据执行模块;
步骤S220,通过第一数据执行模块接收第一数据生产规则和第一数据加工转换规则并根据第一数据生产规则和第一数据加工转换规则得到第一订阅数据,且将第一订阅数据发送到第一数据服务模块。
需要说明的是,第一数据服务模块用于管理第一数据模型、数据的生产和标准化处理、存储和管理数据标准化数据内容、处理数据的订阅和采集任务、处理数据的定制和提取任务以及网络不同层设备的数据服务之间交互数据模型、数据生产需求、数据定制需求、数据提取需求、数据内容。第一数据执行模块将加工后的标准化数据即第一订阅数据发送到第一数据服务模块后,第一数据服务模块根据第一数据模型存储和管理第一订阅数据。
参照图1至图3、图8,可以理解的是,第一数据执行模块包括第一数据服务代理模块和第一数据生产模块,第一数据服务模块分别与第一数据生产模块、第一数据服务代理模块连接,第一数据生产模块与第一数据服务代理模块连接;步骤S220,包括但不限于以下步骤:
步骤S221,通过第一数据服务模块将第一数据生产规则发送到第一数据生产模块,以使第一数据生产模块根据第一数据生产规则生成第一原始数据并将第一原始数据发送到第一数据服务代理模块;
步骤S222,通过第一数据服务模块将第一数据加工转换规则发送到第一数据服务代理模块,以使第一数据服务代理模块根据第一数据加工转换规则对第一原始数据进行加工处理得到第一订阅数据并将第一订阅数据发送到第一数据服务模块。
需要说明的是,本发明实施例提供的网络数据面系统针对不同层级的数据面,建立了统一的网络数据面系统,针对网络中的数据全生命周期,网络数据面系统定义了各层级数据面中的功能实体、功能实体对数据的处理过程、标准的数据模型的设计以及数据处理的标准协作过程设计。例如,在第一层级数据面系统中,定义支撑数据面的功能实体包括:第一数据生产模块、第一数据服务代理模块及第一数据服务模块等。
需要说明的是,第一数据生产模块用于生产网络设备的数据,生产者按照数据服务模块下发的数据生产规则来生产原始数据。第一数据服务代理模块根据第一数据加工转换规则对第一原始数据进行加工处理,得到第一订阅数据也即标准化数据;其中,第一数据加工转换规则根据第一数据模型来定义,以约定数据的结构、量纲、时间精度等信息。
示例性的,参照图2,第②控制流表示第一层级数据面系统内的第一数据服务模块与本层级的第一数据生产者模块、第一数据服务代理模块、第一应用代理模块交互,控制本层级数据面系统内的数据生产、存储、提取的处理过程。
需要说明的是,第二层级数据面系统包括第二数据服务代理模块和第二数据生产模块,第二数据服务模块分别与第二数据生产模块、第二数据服务代理模块连接,第二数据生产模块与第二数据服务代理模块连接。
参照图9,可以理解的是,步骤S100,包括但不限于以下步骤:
步骤S110,通过第一应用代理模块接收数据消费者发送的数据订阅需求并根据数据订阅需求生成标准数据订阅需求,且将标准数据订阅需求发送到第一数据服务模块。
参照图10,步骤S300,包括但不限于以下步骤:
步骤S310,通过第一应用代理模块接收数据消费者发送的数据提取请求并根据数据提取请求生成标准数据提取请求,且将标准数据提取请求发送到第一数据服务模块。
需要说明的是,数据消费者向第一应用代理模块发送的数据订阅需求包含数据采集的对象、内容等。
参照图11,可以理解的是,在步骤S300之前,包括但不限于以下步骤:
步骤S230,通过第一应用代理模块接收数据消费者发送的数据定制需求并根据数据定制需求生成标准数据定制需求,且将标准数据定制需求发送到第一数据服务模块;
步骤S240,通过第一数据服务模块接收标准数据定制需求并根据标准数据定制需求和第一数据模型生成第一数据定制规则,且将第一数据定制规则发送到第一应用代理模块。
需要说明的是,数据消费者向第一应用代理模块发送的数据定制需求包含数据对象、结构、时间,量纲等。
在一些实施例中,第一数据服务模块根据标准数据定制需求生成数据定制任务并保存数据定制任务,无论数据定制任务是否需要下一层级数据面系统中的数据,均不需向下一层级数据面系统发送标准数据定制需求,直接根据标准数据定制需求和第一数据模型生成第一数据定制规则,再将第一数据定制规则发送到第一应用代理模块。在另一些实施例中,第一数据服务模块根据标准数据定制需求生成数据定制任务并保存数据定制任务,判断数据定制任务是否本层级数据面系统中的数据即可满足,是否需要下一层级数据面系统中的数据,若本层级中的数据即可满足,则根据标准数据定制需求和第一数据模型生成第一数据定制规则,且将第一数据定制规则发送到第一应用代理模块;若需要下一层级数据面系统中的数据,则还需向第二层级数据面系统发送标准数据定制需求。
需要说明的是,在定义网络数据面系统时,数据面贯穿不同设备层次以及不同协议栈,在每层设备中均提供数据服务模块来管理本层级数据面系统生产或存储的数据,并为本层级数据消费者以及更高层级的网络节点提供数据能力。该数据服务模块包括数据采集、数据预处理、数据存储、数据访问、数据开放与协同等。
参照图12,可以理解的是,步骤S500中的通过第一应用代理模块接收第一订阅数据和第二订阅数据并根据第一订阅数据和第二订阅数据得到定制数据,包括但不限于以下步骤:
步骤S510,通过第一应用代理模块接收第一订阅数据和第二订阅数据并根据第一数据定制规则对第一订阅数据和第二订阅数据进行加工处理,得到定制数据。
示例性的,参照图3,数据订阅和采集过程为:第①控制流表示数据消费者向第一应用代理模块发送数据订阅需求,其中,数据订阅需求包括数据采集的对象、内容等;第②控制流表示第一应用代理模块将数据订阅需求适配成第一数据服务模块的标准数据订阅需求并发送到第一数据服务模块;第③控制流表示第一数据服务模块根据标准数据订阅需求生成数据采集任务,判断数据采集任务是否本层级也即第一层级数据面系统中的数据即可满足,是否需要下一层级数据面系统也即第二层级数据面系统中的数据,若需要下一层级数据面系统也即第二层级数据面系统中的数据,则需向第二层级数据面系统发送标准数据订阅需求;第④控制流表示根据第一数据模型和标准数据订阅需求生成第一数据生产规则并将第一数据生产规则发送到第一数据生产模块;第⑤控制流表示第一数据服务模块根据第一数据模型和标准数据订阅需求生成第一数据加工转换规则并将第一数据加工转换规则发送到第一数据服务代理模块;第⑥数据流表示第一数据生产模块根据第一数据生产规则生成第一原始数据,并将第一原始数据发送到第一数据服务代理模块;第⑦数据流表示第一数据服务代理模块根据第一数据加工转换规则对第一原始数据进行加工处理得到第一订阅数据,且将第一订阅数据发送到第一数据服务模块,第一数据服务模块根据第一数据模型存储和管理第一订阅数据。
示例性的,参照图4,数据定制和提取过程为:第①控制流表示数据消费者向第一应用代理模块发送数据定制需求,数据定制需求包含数据对象、结构、时间,量纲等;第②控制流表示第一应用代理模块将数据定制需求适配成第一数据服务模块的标准数据定制需求并发送到第一数据服务模块;第③控制流表示第一数据服务模块根据标准数据定制需求生成数据定制任务并保存数据定制任务,判断数据定制任务是否本层级数据面系统中的数据即可满足,是否需要下一层级数据面系统中的数据,若需要下一层级数据面系统中的数据,则还需向第二层级数据面系统发送标准数据定制需求;第④控制流表示第一数据服务模块根据标准数据定制需求和第一数据模型生成第一数据定制规则,且将第一数据定制规则发送到第一应用代理模块;第⑤控制流表示数据消费者向第一应用代理模块发送数据提取请求;第⑥控制流表示第一应用代理模块根据数据提取请求适配成第一数据服务模块的标准数据提取请求,且将标准数据提取请求发送到第一数据服务模块;第⑦控制流表示第一数据服务模块根据标准数据提取请求生成数据提取任务,判断数据提取任务是否本层级数据面系统中的数据即可满足,是否需要下一层级数据面系统中的数据,若需要下一层级数据面系统中的数据,则需向第二层级数据面系统发送标准数据提取请求;第⑧数据流表示第二层级数据面系统的第二数据服务模块若收到第一数据服务模块发送的标准数据提取请求,则组织所需数据即第二订阅数据发送到第一数据服务模块;第⑨数据流表示第一数据服务模块根据数据提取任务组织所有所需数据,并将所有所需数据即第一订阅数据和第二订阅数据发送到第一应用代理模块;第⑩数据流表示第一应用代理模块根据第一数据定制规则对第一订阅数据和第二订阅数据进行加工处理,进而得到定制数据并将定制数据发送给数据消费者。
第四方面,本发明实施例还提供了一种网络数据面系统的数据交互方法,应用于网络数据面系统中的与第一层级数据面系统通信连接的第二层级数据面系统,参照图1至图3、图13,第二层级数据面系统包括第二数据服务模块,第二数据服务模块设置有第二数据模型,第二数据服务模块与第一层级数据面系统中的第一数据服务模块连接;
数据交互方法包括但不限于以下步骤:
步骤S600,通过第二数据服务模块接收第一数据服务模块发送的标准数据订阅需求并根据标准数据订阅需求和第二数据模型得到第二订阅数据;
步骤S700,通过第二数据服务模块接收第一数据服务模块发送的标准数据提取请求并根据标准数据提取请求将第二订阅数据发送到第一数据服务模块。
需要说明的是,第一层级数据面系统包括第一应用代理模块和第一数据服务模块,第二层级数据面系统还包括第二应用代理模块,第一应用代理模块和第一数据服务模块连接,第一应用代理模块和第一数据服务模块连接,第二应用代理模块和第二数据服务模块连接,第一数据服务模块与第二数据服务模块连接。
在本实施例中,第一层级数据面系统中的第一数据服务模块根据第一应用代理模块发送的标准数据订阅需求向第二层级数据面系统发送标准数据订阅需求,并根据第一数据模型和所述标准数据订阅需求得到第一订阅需求;第二层级数据面系统的第二数据服务模块根据标准数据订阅需求和第二数据模型得到第二订阅需求,第二数据服务模块根据标准数据提取请求将第二订阅数据发送到第一数据服务模块;第一数据服务模块再根据第一应用代理模块发送的标准数据提取请求向第二层级数据面系统发送标准数据提取请求以从第二层级数据面系统中获取第二订阅数据,且将第一订阅数据和第二订阅数据发送到第一应用代理模块,以使第一应用代理模块根据第一数据定制规则对第一订阅数据和第二订阅数据进行加工处理生成定制数据并将定制数据发送给数据消费者。根据本发明实施例提供的方案,基于统一的数据模型对齐网络不同层级数据面系统对相同数据的理解,能够拉通不同网络层的数据模型和标准化流程,提升了网络数据一致性和有效性,提高了不同网络层之间基于数据交互的功能协作成功率。
需要说明的是,第一数据定制规则的获取流程为:在第一应用代理模块向第一数据服务模块发送标准数据提取请求之前:通过第一应用代理模块接收数据消费者发送的数据定制需求并根据数据定制需求生成标准数据定制需求,且将标准数据定制需求发送到第一数据服务模块;通过第一数据服务模块接收标准数据定制需求并根据标准数据定制需求和第一数据模型生成第一数据定制规则,且将第一数据定制规则发送到第一应用代理模块。
需要说明的是,第二数据服务模块设置有第二数据模型和第二数据内容,第一数据服务模块中也设置有第一数据模型和第一数据内容,其中,第一数据模型与第二数据模型相同,第一数据内容与第二数据内容不同,通过这种设置,能够基于统一的数据模型对齐网络不同层级数据面系统对相同数据的理解;并且在网络数据面系统中定义统一的数据模型数据面统一了网络中数据的生产、存储、访问、使用标准,为网络智能化和网络数字孪生构建提供了高效的数据服务,为网络智慧内生架构提供了数据基础。其中,第一层级数据面系统和第二层级数据面系统可以是同一设备的不同层级数据面系统,也可以是不同设备的不同层级数据面系统。
需要说明的是,网络数据面系统不仅可以包括第一层级数据面系统和第二层级数据面系统,还可以包括更多层级数据面系统,本发明实施例不作限定。示例性的,参照图5,网络数据面系统由运营商平台大数据中心、基站网管/核心网网管及基站/核心网三个层级的数据面系统构成。
示例性的,参照图2,第①控制流表示在网络中较高层网络设备的数据面模块即第一层级数据面系统的第一数据服务模块和较低层网络设备的数据面模块即第二层级数据面系统的第二数据服务模块之间交互数据模型来对齐不同数据面系统对数据结构和内容的解释,通过交互数据生产需求、数据定制需求、数据提取需求来统一跨层网络设备的数据协作处理过程,通过交互数据内容来满足不同网络层级数据面系统数据消费者的数据需求。第③数据流表示第二应用代理模块与不同的数据消费者交互,来适配不同数据消费者的不同数据结构、格式、内容的差异化需求,负责差异化数据与标准化数据的转换工作。
需要说明的是,数据消费者也可以从第二层级数据面系统向第二应用代理模块发送数据订阅需求、数据定制需求及数据订阅需求,第二应用代理模块分别根据数据订阅需求、数据定制需求及数据订阅需求生成标准数据订阅需求、标准数据定制需求及标准数据订阅需求,并将标准数据订阅需求、标准数据定制需求及标准数据订阅需求分别发送到第二数据服务模块;同理,第二数据服务模块得到数据消费者的所需数据并将所需数据发送到第二应用代理模块,以使第二应用代理模块根据所需数据得到定制数据并将定制数据发送给数据消费者。也即第二应用代理模块也用于转发和适配数据服务与数据消费者的接口,还用于将标准化数据加工转换为数据消费者所需的数据结构和内容。
参照图1和图14,可以理解的是,第二层级数据面系统还包括第二数据执行模块,第二数据执行模块与第二数据服务模块连接,步骤S600中的根据标准数据订阅需求和第二数据模型得到第二订阅数据,包括但不限于以下步骤:
步骤S610,通过第二数据服务模块接收第一数据服务模块发送的标准数据订阅需求并根据标准数据订阅需求和第二数据模型生成第二数据生产规则、第二数据加工转换规则,且将第二数据生产规则和第二数据加工转换规则发送到第二数据执行模块;
步骤S620,通过第二数据执行模块接收第二数据生产规则和第二数据加工转换规则并根据第二数据生产规则和第二数据加工转换规则得到第二订阅数据,且将第二订阅数据发送到第二数据服务模块。
需要说明的是,第一层级数据面系统还包括第一数据执行模块,第一数据执行模块与第一数据服务模块连接。
具体地,第一层级数据面系统中的第一数据服务模块根据第一应用代理模块发送的标准数据订阅需求向第二层级数据面系统发送标准数据订阅需求,并根据第一数据模型和所述标准数据订阅需求生成第一数据生产规则、第一数据加工转换规则,且将第一数据生产规则和第一数据加工转换规则发送到第一数据执行模块,第一数据执行模块根据第一数据生产规则和所述第一数据加工转换规则得到第一订阅数据并将第一订阅数据发送到第一数据服务模块;第二层级数据面系统的第二数据服务模块根据标准数据订阅需求和第二数据模型生成第二数据生产规则、第二数据加工转换规则,且将第二数据生产规则和第二数据加工转换规则发送到第二数据执行模块,第二数据执行模块用于根据第二数据生产规则和第二数据加工转换规得到第二订阅数据并将第二订阅数据发送到第二数据服务模块,以使第二数据服务模块根据标准数据提取请求将第二订阅数据发送到第一数据服务模块;第一数据服务模块再根据第一应用代理模块发送的标准数据提取请求向第二层级数据面系统发送标准数据提取请求以从第二层级数据面系统中获取第二订阅数据,且将第一订阅数据和第二订阅数据发送到第一应用代理模块,以使第一应用代理模块根据第一数据定制规则对第一订阅数据和第二订阅数据进行加工处理生成定制数据并将定制数据发送给数据消费者。
需要说明的是,第二数据服务模块用于管理第二数据模型、数据的生产和标准化处理、存储和管理数据标准化数据内容、处理数据的订阅和采集任务、处理数据的定制和提取任务以及网络不同层设备的数据服务之间交互数据模型、数据生产需求、数据定制需求、数据提取需求、数据内容。第二数据执行模块将加工后的标准化数据即第二订阅数据发送到第二数据服务模块后,第二数据服务模块根据第二数据模型存储和管理第二订阅数据。
参照图1至图3、图15,可以理解的是,第二数据执行模块包括第二数据服务代理模块和第二数据生产模块,第二数据服务模块分别与第二数据生产模块、第二数据服务代理模块连接,第二数据生产模块与第二数据服务代理模块连接;步骤S620,包括但不限于以下步骤:
步骤S621,通过第二数据服务模块将第二数据生产规则发送到第二数据生产模块,以使第二数据生产模块根据第二数据生产规则生成第二原始数据并将第二原始数据发送到第二数据服务代理模块;
步骤S622,通过第二数据服务模块将第二数据加工转换规则发送到第二数据服务代理模块,以使第二数据服务代理模块根据第二数据加工转换规则对第二原始数据进行加工处理得到第二订阅数据并将第二订阅数据发送到第二数据服务模块。
需要说明的是,本发明实施例提供的网络数据面系统针对不同层级的数据面,建立了统一的网络数据面系统,针对网络中的数据全生命周期,网络数据面系统定义了各层级数据面中的功能实体、功能实体对数据的处理过程、标准的数据模型的设计以及数据处理的标准协作过程设计。例如,在第二层级数据面系统中,定义支撑数据面的功能实体包括:第二数据生产模块、第二数据服务代理模块及第二数据服务模块等。
需要说明的是,第二数据生产模块用于生产网络设备的数据,生产者按照数据服务模块下发的数据生产规则来生产原始数据。第二数据服务代理模块根据第二数据加工转换规则对第二原始数据进行加工处理,得到第二订阅数据也即标准化数据;其中,第二数据加工转换规则根据第二数据模型来定义,以约定数据的结构、量纲、时间精度等信息。
需要说明的是,第一层级数据面系统还包括第一数据服务代理模块和第一数据生产模块,第一数据服务模块分别与第一数据生产模块、第一数据服务代理模块连接,第一数据生产模块与第一数据服务代理模块连接。
本发明实施例还提供了一种网络数据面系统的数据交互方法,应用于网络数据面系统,参照图1至图3,网络数据面系统包括第一层级数据面系统和第二层级数据面系统,第一层级数据面系统和第二层级数据面系统通信连接,第一层级数据面系统包括第一应用代理模块和第一数据服务模块,第一数据服务模块设置有第一数据模型,第一数据服务模块与第一应用代理模块连接;第二层级数据面系统包括第二数据服务模块,第二数据服务模块设置有第二数据模型,第二数据服务模块与第一层级数据面系统中的第一数据服务模块连接;数据交互方法包括:
第一层级数据面系统执行第三方面的网络数据面系统的数据交互方法;对应的,第二层级数据面系统执行第四方面的网络数据面系统的数据交互方法。
另外,本发明第五方面实施例还提供了一种网络数据面系统,该网络数据面系统包括:存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序。
处理器和存储器可以通过总线或者其他方式连接。
存储器作为一种非暂态计算机可读存储介质,可用于存储非暂态软件程序以及非暂态性计算机可执行程序。此外,存储器可以包括高速随机存取存储器,还可以包括非暂态存储器,例如至少一个磁盘存储器件、闪存器件、或其他非暂态固态存储器件。在一些实施方式中,存储器可选包括相对于处理器远程设置的存储器,这些远程存储器可以通过网络连接至该处理器。上述网络的实例包括但不限于互联网、企业内部网、局域网、移动通信网及其组合。
实现上述第三方面实施例的网络数据面系统的数据交互方法所需的非暂态软件程序以及指令存储在存储器中,当被处理器执行时,执行上述实施例中的网络数据面系统的数据交互方法,例如,执行以上描述的图6中的方法步骤S100至S500、图7中的方法步骤S210至S220、图8中的方法步骤S221至S222、图9中的方法步骤S110、图10中的方法步骤S310、图11中的方法步骤S230至S240、图12中的方法步骤S510。
实现上述第四方面实施例的网络数据面系统的数据交互方法所需的非暂态软件程序以及指令存储在存储器中,当被处理器执行时,执行上述实施例中的网络数据面系统的数据交互方法,例如,执行以上描述的图13中的方法步骤S600至S700、图14中的方法步骤S610至S620、图15中的方法步骤S621至S622。
以上所描述的设备实施例仅仅是示意性的,其中作为分离部件说明的单元可以是或者也可以不是物理上分开的,即可以位于一个地方,或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部模块来实现本实施例方案的目的。
此外,本发明的一个实施例还提供了一种计算机可读存储介质,该计算机可读存储介质存储有计算机可执行指令,该计算机可执行指令被一个处理器或控制器执行,例如,被上述设备实施例中的一个处理器执行,可使得上述处理器执行上述第三方面实施例中的网络数据面系统的数据交互方法,或者执行上述第四方面实施例中的网络数据面系统的数据交互方法;例如,执行以上描述的图6中的方法步骤S100至S500、图7中的方法步骤S210至S220、图8中的方法步骤S221至S222、图9中的方法步骤S110、图10中的方法步骤S310、图11中的方法步骤S230至S240、图12中的方法步骤S510、图13中的方法步骤S600至S700、图14中的方法步骤S610至S620、图15中的方法步骤S621至S622。
本领域普通技术人员可以理解,上文中所公开方法中的全部或某些步骤、系统可以被实施为软件、固件、硬件及其适当的组合。某些物理组件或所有物理组件可以被实施为由处理器,如中央处理器、数字信号处理器或微处理器执行的软件,或者被实施为硬件,或者被实施为集成电路,如专用集成电路。这样的软件可以分布在计算机可读介质上,计算机可读介质可以包括计算机存储介质(或非暂时性介质)和通信介质(或暂时性介质)。如本领域普通技术人员公知的,术语计算机存储介质包括在用于存储信息(诸如计算机可读指令、数据结构、程序模块或其他数据)的任何方法或技术中实施的易失性和非易失性、可移除和不可移除介质。计算机存储介质包括但不限于RAM、ROM、EEPROM、闪存或其他存储器技术、CD-ROM、数字多功能盘(DVD)或其他光盘存储、磁盒、磁带、磁盘存储或其他磁存储装置、或者可以用于存储期望的信息并且可以被计算机访问的任何其他的介质。此外,本领域普通技术人员公知的是,通信介质通常包含计算机可读指令、数据结构、程序模块或者诸如载波或其他传输机制之类的调制数据信号中的其他数据,并且可包括任何信息递送介质。
以上是对本发明的较佳实施进行了具体说明,但本发明并不局限于上述实施方式,熟悉本领域的技术人员在不违背本发明精神的前提下还可作出种种的等同变形或替换,这些等同的变形或替换均包含在本发明权利要求所限定的范围内。
Claims (17)
1.一种网络数据面系统,包括第一层级数据面系统,其特征在于,所述第一层级数据面系统包括第一应用代理模块和第一数据服务模块,所述第一应用代理模块用于将数据消费者发送的标准数据订阅需求和标准数据提取请求发送到所述第一数据服务模块;
所述第一数据服务模块设置有第一数据模型,所述第一数据服务模块用于根据所述标准数据订阅需求向第二层级数据面系统发送所述标准数据订阅需求,并根据所述第一数据模型和所述标准数据订阅需求得到第一订阅数据;所述第一数据服务模块还用于根据所述标准数据提取请求向所述第二层级数据面系统发送所述标准数据提取请求以获取所述第二层级数据面系统根据所述标准数据订阅需求得到的第二订阅数据,且将所述第一订阅数据和所述第二订阅数据发送到所述第一应用代理模块,以使所述第一应用代理模块根据所述第一订阅数据和所述第二订阅数据得到定制数据并将所述定制数据发送给所述数据消费者。
2.根据权利要求1所述的网络数据面系统,其特征在于,所述第一层级数据面系统还包括第一数据执行模块,所述第一数据执行模块与所述第一数据服务模块连接,所述第一数据服务模块还用于根据所述第一数据模型和所述标准数据订阅需求生成第一数据生产规则、第一数据加工转换规则,且将所述第一数据生产规则和所述第一数据加工转换规则发送到所述第一数据执行模块;所述第一数据执行模块用于根据所述第一数据生产规则和所述第一数据加工转换规则生成第一订阅数据并将所述第一订阅数据发送到所述第一数据服务模块。
3.根据权利要求2所述的网络数据面系统,其特征在于,所述第一数据执行模块包括第一数据服务代理模块和第一数据生产模块,所述第一数据服务模块分别与所述第一数据生产模块、所述第一数据服务代理模块连接,所述第一数据生产模块与所述第一数据服务代理模块连接;所述第一数据生产模块用于接收所述第一数据生产规则并根据所述第一数据生产规则生成第一原始数据,且将所述第一原始数据发送到所述第一数据服务代理模块;所述第一数据服务代理模块用于接收所述第一数据加工转换规则和所述第一原始数据并根据所述第一数据加工转换规则对所述第一原始数据进行加工处理得到第一订阅数据,且将所述第一订阅数据发送到所述第一数据服务模块。
4.一种网络数据面系统,包括与第一层级数据面系统通信连接的第二层级数据面系统,其特征在于,所述第二层级数据面系统包括:
第二数据服务模块,设置有第二数据模型,所述第二数据服务模块与所述第一层级数据面系统中的第一数据服务模块连接以接收所述第一数据服务模块发送的标准数据订阅需求和标准数据提取请求,所述第二数据服务模块用于根据所述标准数据订阅需求和所述第二数据模型得到第二订阅数据,并根据所述标准数据提取请求将所述第二订阅数据发送到所述第一数据服务模块。
5.根据权利要求4所述的网络数据面系统,其特征在于,所述第二层级数据面系统还包括第二数据执行模块,所述第二数据执行模块与所述第二数据服务模块连接,所述第二数据服务模块还用于根据所述第二数据模型和所述标准数据订阅需求生成第二数据生产规则、第二数据加工转换规则,且将所述第二数据生产规则和所述第二数据加工转换规则发送到所述第一数据执行模块;所述第二数据执行模块用于根据所述第二数据生产规则和所述第二数据加工转换规则生成第二订阅数据并将所述第二订阅数据发送到所述第二数据服务模块。
6.根据权利要求5所述的网络数据面系统,其特征在于,所述第二数据执行模块包括第二数据服务代理模块和第二数据生产模块,所述第二数据服务模块分别与所述第二数据生产模块、所述第二数据服务代理模块连接,所述第二数据生产模块与所述第二数据服务代理模块连接;所述第二数据生产模块用于接收所述第二数据生产规则并根据所述第二数据生产规则生成第二原始数据,且将所述第二原始数据发送到所述第二数据服务代理模块;所述第二数据服务代理模块用于接收所述第二数据加工转换规则和所述第二原始数据并根据所述第二数据加工转换规则对所述第二原始数据进行加工处理得到第二订阅数据,且将所述第二订阅数据发送到所述第二数据服务模块。
7.一种网络数据面系统的数据交互方法,其特征在于,应用于所述网络数据面系统中的第一层级数据面系统,所述第一层级数据面系统包括第一应用代理模块和第一数据服务模块,所述第一数据服务模块设置有第一数据模型,所述第一数据服务模块与所述第一应用代理模块连接;
所述数据交互方法包括:
通过所述第一应用代理模块将数据消费者发送的标准数据订阅需求发送到所述第一数据服务模块;
通过所述第一数据服务模块接收所述标准数据订阅需求并根据所述标准数据订阅需求向第二层级数据面系统发送所述标准数据订阅需求,且根据所述第一数据模型和所述标准数据订阅需求得到第一订阅数据;
通过所述第一应用代理模块将所述数据消费者发送的标准数据提取请求发送到所述第一数据服务模块;
通过所述第一数据服务模块接收所述标准数据提取请求并根据所述标准数据提取请求向所述第二层级数据面系统发送标准数据提取请求以获取所述第二层级数据面系统根据所述标准数据订阅需求得到的第二订阅数据,且将所述第一订阅数据和所述第二订阅数据发送到所述第一应用代理模块;
通过所述第一应用代理模块接收所述第一订阅数据和所述第二订阅数据并根据所述第一订阅数据和所述第二订阅数据得到定制数据,且将所述定制数据发送给所述数据消费者。
8.根据权利要求7所述的方法,其特征在于,所述第一层级数据面系统还包括第一数据执行模块,所述第一数据执行模块与所述第一数据服务模块连接,所述根据所述第一数据模型和所述标准数据订阅需求得到第一订阅数据,包括:
通过所述第一数据服务模块接收所述第一数据服务模块发送的标准数据订阅需求并根据所述第一数据模型和所述标准数据订阅需求生成第一数据生产规则、第一数据加工转换规则,且将所述第一数据生产规则和所述第一数据加工转换规则发送到所述第一数据执行模块;
通过所述第一数据执行模块接收所述第一数据生产规则和所述第一数据加工转换规则并根据所述第一数据生产规则和所述第一数据加工转换规则得到第一订阅数据,且将所述第一订阅数据发送到所述第一数据服务模块。
9.根据权利要求8所述的方法,其特征在于,所述第一数据执行模块包括第一数据服务代理模块和第一数据生产模块,所述第一数据服务模块分别与所述第一数据生产模块、所述第一数据服务代理模块连接,所述第一数据生产模块与所述第一数据服务代理模块连接;所述通过所述第一数据执行模块接收所述第一数据生产规则和所述第一数据加工转换规则并根据所述第一数据生产规则和所述第一数据加工转换规则得到第一订阅数据,且将所述第一订阅数据发送到所述第一数据服务模块,包括:
通过所述第一数据服务模块将所述第一数据生产规则发送到所述第一数据生产模块,以使所述第一数据生产模块根据所述第一数据生产规则生成第一原始数据并将所述第一原始数据发送到所述第一数据服务代理模块;
通过所述第一数据服务模块将所述第一数据加工转换规则发送到所述第一数据服务代理模块,以使所述第一数据服务代理模块根据所述第一数据加工转换规则对所述第一原始数据进行加工处理得到第一订阅数据并将所述第一订阅数据发送到所述第一数据服务模块。
10.根据权利要求7所述的方法,其特征在于,所述通过所述第一应用代理模块将数据消费者发送的标准数据订阅需求发送到所述第一数据服务模块,包括:
通过所述第一应用代理模块接收数据消费者发送的数据订阅需求并根据所述数据订阅需求生成标准数据订阅需求,且将所述标准数据订阅需求发送到所述第一数据服务模块;
所述通过所述第一应用代理模块将所述数据消费者发送的标准数据提取请求发送到所述第一数据服务模块,包括:
通过所述第一应用代理模块接收所述数据消费者发送的数据提取请求并根据所述数据提取请求生成标准数据提取请求,且将所述标准数据提取请求发送到所述第一数据服务模块。
11.根据权利要求7所述的方法,其特征在于,在所述通过所述第一应用代理模块将所述数据消费者发送的标准数据提取请求发送到所述第一数据服务模块之前,包括:
通过所述第一应用代理模块接收所述数据消费者发送的数据定制需求并根据所述数据定制需求生成标准数据定制需求,且将所述标准数据定制需求发送到所述第一数据服务模块;
通过所述第一数据服务模块接收所述标准数据定制需求并根据所述标准数据定制需求和所述第一数据模型生成第一数据定制规则,且将所述第一数据定制规则发送到所述第一应用代理模块。
12.根据权利要求11所述的方法,其特征在于,所述通过所述第一应用代理模块接收所述第一订阅数据和所述第二订阅数据并根据所述第一订阅数据和所述第二订阅数据得到定制数据,包括:
通过所述第一应用代理模块接收所述第一订阅数据和所述第二订阅数据并根据所述第一数据定制规则对所述第一订阅数据和所述第二订阅数据进行加工处理,得到定制数据。
13.一种网络数据面系统的数据交互方法,其特征在于,应用于所述网络数据面系统中的与第一层级数据面系统通信连接的第二层级数据面系统,所述第二层级数据面系统包括第二数据服务模块,所述第二数据服务模块设置有第二数据模型,所述第二数据服务模块与所述第一层级数据面系统中的第一数据服务模块连接;
所述数据交互方法包括:
通过所述第二数据服务模块接收所述第一数据服务模块发送的标准数据订阅需求并根据所述标准数据订阅需求和所述第二数据模型得到第二订阅数据;
通过所述第二数据服务模块接收所述第一数据服务模块发送的标准数据提取请求并根据所述标准数据提取请求将所述第二订阅数据发送到所述第一数据服务模块。
14.根据权利要求13所述的方法,其特征在于,所述第二层级数据面系统还包括第二数据执行模块,所述第二数据执行模块与所述第二数据服务模块连接,所述根据所述标准数据订阅需求和所述第二数据模型得到第二订阅数据,包括:
通过所述第二数据服务模块接收所述第一数据服务模块发送的标准数据订阅需求并根据所述标准数据订阅需求和所述第二数据模型生成第二数据生产规则、第二数据加工转换规则,且将所述第二数据生产规则和所述第二数据加工转换规则发送到所述第二数据执行模块;
通过所述第二数据执行模块接收所述第二数据生产规则和所述第二数据加工转换规则并根据所述第二数据生产规则和所述第二数据加工转换规则得到第二订阅数据,且将所述第二订阅数据发送到所述第二数据服务模块。
15.根据权利要求14所述的方法,其特征在于,所述第二数据执行模块包括第二数据服务代理模块和第二数据生产模块,所述第二数据服务模块分别与所述第二数据生产模块、所述第二数据服务代理模块连接,所述第二数据生产模块与所述第二数据服务代理模块连接;所述通过所述第二数据执行模块接收所述第二数据生产规则和所述第二数据加工转换规则并根据所述第二数据生产规则和所述第二数据加工转换规则得到第二订阅数据,且将所述第二订阅数据发送到所述第二数据服务模块,包括:
通过所述第二数据服务模块将所述第二数据生产规则发送到所述第二数据生产模块,以使所述第二数据生产模块根据所述第二数据生产规则生成第二原始数据并将所述第二原始数据发送到所述第二数据服务代理模块;
通过所述第二数据服务模块将所述第二数据加工转换规则发送到所述第二数据服务代理模块,以使所述第二数据服务代理模块根据所述第二数据加工转换规则对所述第二原始数据进行加工处理得到第二订阅数据并将所述第二订阅数据发送到所述第二数据服务模块。
16.一种网络数据面系统,其特征在于,包括:存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序,所述处理器执行所述程序时实现:
如权利要求7至12中任一项所述的网络数据面系统的数据交互方法;
或者,
如权利要求13至15任一项所述的网络数据面系统的数据交互方法。
17.一种计算机可读存储介质,其特征在于,所述计算机可读存储介质存储有计算机可执行指令,所述计算机可执行指令用于:
执行权利要求7至12中任一项所述的网络数据面系统的数据交互方法;
或者,
执行权利要求13至15任一项所述的网络数据面系统的数据交互方法。
Priority Applications (2)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202210907497.XA CN117527894A (zh) | 2022-07-29 | 2022-07-29 | 网络数据面系统、数据交互方法及存储介质 |
PCT/CN2023/077224 WO2024021582A1 (zh) | 2022-07-29 | 2023-02-20 | 网络数据面系统、数据交互方法及存储介质 |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202210907497.XA CN117527894A (zh) | 2022-07-29 | 2022-07-29 | 网络数据面系统、数据交互方法及存储介质 |
Publications (1)
Publication Number | Publication Date |
---|---|
CN117527894A true CN117527894A (zh) | 2024-02-06 |
Family
ID=89705211
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN202210907497.XA Pending CN117527894A (zh) | 2022-07-29 | 2022-07-29 | 网络数据面系统、数据交互方法及存储介质 |
Country Status (2)
Country | Link |
---|---|
CN (1) | CN117527894A (zh) |
WO (1) | WO2024021582A1 (zh) |
Family Cites Families (5)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
WO2004072800A2 (en) * | 2003-02-06 | 2004-08-26 | Progress Software Corporation | Dynamic subscription and message routing on a topic between a publishing node and subscribing nodes |
US20160029278A1 (en) * | 2013-03-07 | 2016-01-28 | Nokia Solutions And Networks Oy | Handover of mobility management entity for load balancing |
CN110366144B (zh) * | 2018-04-09 | 2024-09-17 | 华为技术有限公司 | 一种订阅服务的方法及装置 |
CN110557744B (zh) * | 2018-05-31 | 2022-08-19 | 华为技术有限公司 | 订阅事件的方法与网络功能网元 |
CN111917814B (zh) * | 2019-05-10 | 2022-09-06 | 北京百度网讯科技有限公司 | 数据发布、订阅方法、装置、设备、系统及可读存储介质 |
-
2022
- 2022-07-29 CN CN202210907497.XA patent/CN117527894A/zh active Pending
-
2023
- 2023-02-20 WO PCT/CN2023/077224 patent/WO2024021582A1/zh unknown
Also Published As
Publication number | Publication date |
---|---|
WO2024021582A1 (zh) | 2024-02-01 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN102014403B (zh) | 一种传输网络拓扑信息的方法及系统 | |
CN112511586B (zh) | 一种基于云边协同的高速铁路智能行车调度安全卡控系统 | |
CN115002681A (zh) | 一种算力感知网络及其使用方法、存储介质 | |
CN101894348A (zh) | 一种自扩展的联机交易系统及其实现方法 | |
US20010025308A1 (en) | Data transmission management apparatus and data transmission system, and methods thereof | |
CN111669372B (zh) | 一种用电采集主站物联网协议融合方法 | |
CN109656210A (zh) | 工业数据采集方法、系统及主系统 | |
CN114615096B (zh) | 基于事件驱动架构的电信计费方法、系统及相关设备 | |
CN113573150A (zh) | 视频流处理方法、装置、电子设备和存储介质 | |
CN115237077A (zh) | 一种基于5g边缘计算的工业数字孪生系统 | |
CN101884197B (zh) | 在通用即插即用网络中控制服务质量的方法和装置 | |
CN109901885A (zh) | 一种数据交互方法、插件管理器与计算机可读存储介质 | |
CN112433759A (zh) | 用于列控中心系统的标准化维护终端及其实现方法 | |
CN117527894A (zh) | 网络数据面系统、数据交互方法及存储介质 | |
CN111146868A (zh) | 一种电力通信机房动环监控标准化接入方法及系统 | |
CN101179450B (zh) | 网络性能监测方法和系统及其主控单板和业务单板 | |
CN114090230A (zh) | 一种面向海量异构资源的物联网北向中间件服务治理方法 | |
CN110932393B (zh) | 一种变电站保信主站系统及其数据初始化方法 | |
CA2682951C (en) | Message mechanism for workflow interfacing | |
CN111654671A (zh) | 视频数据的存储方法、装置、设备及存储介质 | |
CN115065702B (zh) | 一种适用于新一代调度主站的新能源数据接入系统及方法 | |
CN114024822B (zh) | 基于区块链的物联网设备管理方法、设备、服务器及介质 | |
CN115719189A (zh) | 物料管理方法、平台、介质及系统 | |
CN213126061U (zh) | 一种基于控制器的神经网络流量预测装置 | |
CN114024976B (zh) | 一种基于5g的大数据服务架构及构建大数据业务的方法 |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
PB01 | Publication | ||
PB01 | Publication |