CN116233256A - Scheduling path configuration method, device, equipment and storage medium - Google Patents
Scheduling path configuration method, device, equipment and storage medium Download PDFInfo
- Publication number
- CN116233256A CN116233256A CN202310080004.4A CN202310080004A CN116233256A CN 116233256 A CN116233256 A CN 116233256A CN 202310080004 A CN202310080004 A CN 202310080004A CN 116233256 A CN116233256 A CN 116233256A
- Authority
- CN
- China
- Prior art keywords
- path
- scheduling
- service
- node
- data
- 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 59
- 230000006870 function Effects 0.000 claims description 24
- 238000004590 computer program Methods 0.000 claims description 15
- 238000012795 verification Methods 0.000 claims description 9
- 238000005538 encapsulation Methods 0.000 claims description 4
- 238000012545 processing Methods 0.000 claims description 4
- 238000004891 communication Methods 0.000 abstract description 11
- 238000005516 engineering process Methods 0.000 abstract description 4
- 238000010586 diagram Methods 0.000 description 14
- 230000008569 process Effects 0.000 description 6
- 230000004913 activation Effects 0.000 description 4
- 230000008859 change Effects 0.000 description 3
- 230000009471 action Effects 0.000 description 2
- 238000012508 change request Methods 0.000 description 2
- 230000000694 effects Effects 0.000 description 2
- 238000000605 extraction Methods 0.000 description 2
- 230000010354 integration Effects 0.000 description 2
- 238000012986 modification Methods 0.000 description 2
- 230000004048 modification Effects 0.000 description 2
- 230000003287 optical effect Effects 0.000 description 2
- 238000012546 transfer Methods 0.000 description 2
- 241000234282 Allium Species 0.000 description 1
- 235000002732 Allium cepa var. cepa Nutrition 0.000 description 1
- 230000009286 beneficial effect Effects 0.000 description 1
- 230000005540 biological transmission Effects 0.000 description 1
- 230000007423 decrease Effects 0.000 description 1
- 238000005070 sampling Methods 0.000 description 1
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L41/00—Arrangements for maintenance, administration or management of data switching networks, e.g. of packet switching networks
- H04L41/06—Management of faults, events, alarms or notifications
- H04L41/0654—Management of faults, events, alarms or notifications using network fault recovery
- H04L41/0668—Management of faults, events, alarms or notifications using network fault recovery by dynamic selection of recovery network elements, e.g. replacement by the most appropriate element after failure
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
- Small-Scale Networks (AREA)
- Cable Transmission Systems, Equalization Of Radio And Reduction Of Echo (AREA)
Abstract
本发明提供一种调度路径配置方法、装置、设备及存储介质,涉及通信技术领域,包括:获取算力资源数据和网络质量数据;将算力资源数据和网络质量数据上报至调度系统,以供调度系统基于用户业务需求、算力资源数据和网络质量数据,对各个边缘网关节点进行路径编排,得到调度策略路径,将调度策略路径下发至边缘网关节点;接收并存储所述调度策略路径。本发明通过根据业务需求,算力资源数据和网络质量数据灵活配置调度路径,进而将调度策略路径下发至边缘网关节点,以边缘网关节点作为基础设施,当调度策略变更时,由于边缘网关节点存储有调度策略路径,无需等待调度系统下发新的调度策略,实现算力下沉,有效提升业务服务质量。
The present invention provides a scheduling path configuration method, device, equipment, and storage medium, relating to the field of communication technology, including: acquiring computing power resource data and network quality data; reporting computing power resource data and network quality data to a scheduling system for Based on user service requirements, computing power resource data and network quality data, the scheduling system arranges paths for each edge gateway node, obtains a scheduling strategy path, and sends the scheduling strategy path to the edge gateway node; receives and stores the scheduling strategy path. The present invention flexibly configures the scheduling path according to business requirements, computing power resource data, and network quality data, and then sends the scheduling policy path to the edge gateway node. The edge gateway node is used as the infrastructure. When the scheduling strategy is changed, the edge gateway node There is a scheduling strategy path stored, so there is no need to wait for the scheduling system to issue a new scheduling strategy, which realizes the sinking of computing power and effectively improves the quality of business services.
Description
技术领域technical field
本发明涉及通信技术领域,尤其涉及一种调度路径配置方法、装置、设备及存储介质。The present invention relates to the field of communication technologies, and in particular to a scheduling path configuration method, device, equipment and storage medium.
背景技术Background technique
算力网络的目的是将算力资源融合通信网络,以一个更整体的形式提供最符合用户需求的算力资源服务。当前,随着云网融合推动发展,利用软件定义的优势把云计算和网络进行结合来实现算力网络。The purpose of the computing power network is to integrate computing power resources into the communication network and provide computing power resource services that best meet the needs of users in a more integrated form. At present, with the promotion of cloud-network integration, the advantages of software definition are used to combine cloud computing and network to realize computing power network.
现阶段,算力网络中的边缘基础设施主要以运营商设备为主,通常是采用集中式管控的方法对各个运营商设备进行管理,具体地,各个运营商设备对应的算力网络调度策略由上层调度系统统一进行调度管理。然而,当调度策略需要变更时,需要发送变更请求至上层调度系统,以获取到上层调度系统下发新的调度策略,调度策略变更执行周期较长,导致提升业务的服务质量较低。At this stage, the edge infrastructure in the computing power network is mainly based on operator equipment, and the centralized management and control method is usually used to manage each operator's equipment. Specifically, the computing power network scheduling strategy corresponding to each operator's equipment is determined by The upper-level scheduling system performs unified scheduling management. However, when the scheduling policy needs to be changed, it is necessary to send a change request to the upper-level scheduling system to obtain a new scheduling policy issued by the upper-level scheduling system. The execution period of the scheduling policy change is long, resulting in low service quality for the improved business.
发明内容Contents of the invention
本发明提供一种调度路径配置方法、装置、设备及存储介质,旨在提升业务的服务质量。The present invention provides a scheduling path configuration method, device, equipment and storage medium, aiming at improving service quality of services.
本发明提供一种调度路径配置方法,包括:The present invention provides a scheduling path configuration method, including:
获取算力资源数据以及网络质量数据;Obtain computing resource data and network quality data;
将所述算力资源数据以及所述网络质量数据上报至所述调度系统,以供所述调度系统基于用户业务需求、所述算力资源数据以及所述网络质量数据,对各个边缘网关节点进行路径编排,得到调度策略路径,以将所述调度策略路径下发至边缘网关节点;Reporting the computing power resource data and the network quality data to the dispatching system, so that the dispatching system can perform an operation on each edge gateway node based on user service requirements, the computing power resource data and the network quality data path arranging to obtain a scheduling policy path, so as to send the scheduling policy path to the edge gateway node;
接收并存储所述调度策略路径。The scheduling policy path is received and stored.
根据本发明提供的一种调度路径配置方法,所述调度策略路径包括主调度路径和至少一条备用调度路径;According to a scheduling path configuration method provided by the present invention, the scheduling strategy path includes a main scheduling path and at least one backup scheduling path;
所述接收并存储所述调度策略路径之后,还包括:After receiving and storing the scheduling policy path, it also includes:
检测所述主调度路径对应的网络状态;Detecting the network status corresponding to the main scheduling path;
若所述主调度路径的网络状态处于故障状态,则切换至所述备用调度路径,以基于所述备用调度路径进行数据转发。If the network state of the main scheduling path is in a failure state, switch to the backup scheduling path to forward data based on the backup scheduling path.
根据本发明提供的一种调度路径配置方法,所述调度策略路径是基于边缘网关节点对应的节点服务ID列表构建得到;According to a scheduling path configuration method provided by the present invention, the scheduling policy path is constructed based on a node service ID list corresponding to an edge gateway node;
所述调度策略路径中的边缘网关节点包括源节点、服务节点、尾节点以及业务功能节点。The edge gateway nodes in the scheduling policy path include source nodes, service nodes, tail nodes and service function nodes.
根据本发明提供的一种调度路径配置方法,所述接收并存储所述调度策略路径之后,还包括:According to a scheduling path configuration method provided by the present invention, after receiving and storing the scheduling policy path, it further includes:
通过所述源节点获取客户端发送的第一业务报文,所述第一业务报文包括所述业务数据;Obtaining, through the source node, a first service message sent by the client, where the first service message includes the service data;
通过所述源节点对所述第一业务报文进行路径分类,得到所述第一业务报文对应的调度策略路径;Classifying the path of the first service message by the source node to obtain a scheduling policy path corresponding to the first service message;
基于预先配置的路由拓展头,通过所述源节点对所述第一业务报文进行封装处理,得到第一封装报文,以将所述第一封装报文转发至所述服务节点,其中,所述路由拓展头包括所述节点服务ID列表;Based on the pre-configured routing extension header, the source node encapsulates the first service message to obtain a first encapsulated message, so as to forward the first encapsulated message to the service node, wherein, The routing extension header includes the node service ID list;
通过所述服务节点对所述第一封装报文进行解封,得到第一解封业务数据;Decapsulating the first encapsulated message by the service node to obtain first decapsulated service data;
基于所述节点服务ID列表,将所述第一解封业务数据转发至业务功能节点;forwarding the first decapsulated service data to a service function node based on the node service ID list;
通过所述业务功能节点对所述第一解封业务数据进行字段校验,以基于校验成功的第一解封业务数据,发送第二业务报文至所述服务节点;Perform field verification on the first decapsulated service data by the service function node, so as to send a second service message to the service node based on the successfully verified first decapsulated service data;
通过所述服务节点对所述第二业务报文进行封装处理,得到第二封装报文,以将所述第二封装报文转发至尾节点;encapsulating the second service message by the service node to obtain a second encapsulated message, so as to forward the second encapsulated message to a tail node;
通过所述尾节点将所述第二封装报文进行报文头解封处理,得到第二解封业务数据,以基于所述节点服务ID列表,将所述第二解封业务数据进行数据转发。Decapsulate the header of the second encapsulated message through the tail node to obtain second decapsulated service data, so as to forward the second decapsulated service data based on the node service ID list .
根据本发明提供的一种调度路径配置方法,所述边缘网关节点与所述调度系统之间配置有控制器;According to a scheduling path configuration method provided by the present invention, a controller is configured between the edge gateway node and the scheduling system;
所述将所述算力资源数据以及所述网络质量数据上报至调度系统,包括:The reporting of the computing power resource data and the network quality data to the scheduling system includes:
将所述算力资源数据以及所述网络质量数据上传至所述控制器,以通过所述控制器将所述算力资源数据以及所述网络质量数据上报至调度系统。uploading the computing power resource data and the network quality data to the controller, so as to report the computing power resource data and the network quality data to a scheduling system through the controller.
本发明还提供一种调度路径配置方法,包括:The present invention also provides a scheduling path configuration method, including:
接收各个边缘网关节点的算力资源数据以及网络质量数据;Receive computing power resource data and network quality data of each edge gateway node;
根据用户业务需求、所述算力资源数据以及所述网络质量数据,对各个边缘网关节点进行路径编排,得到调度策略路径;According to the user's service requirements, the computing power resource data and the network quality data, arrange paths for each edge gateway node to obtain a scheduling strategy path;
将所述调度策略路径下发至边缘网关节点,以供所述边缘网关节点存储所述调度策略路径。Sending the scheduling policy path to the edge gateway node, so that the edge gateway node stores the scheduling policy path.
根据本发明提供的一种调度路径配置方法,所述根据用户业务需求、所述算力资源数据以及所述网络质量数据,对各个边缘网关节点进行路径编排,得到调度策略路径,包括:According to a dispatching path configuration method provided by the present invention, the path arrangement is performed on each edge gateway node according to user service requirements, the computing power resource data, and the network quality data to obtain a dispatching strategy path, including:
根据所述用户业务需求,确定各个业务服务;Determine various business services according to the user business requirements;
基于所述算力资源数据以及所述网络质量数据,对各所述业务服务对应的边缘网关节点进行路径编排,得到所述调度策略路径。Based on the computing power resource data and the network quality data, path arrangement is performed on the edge gateway nodes corresponding to each of the business services to obtain the scheduling policy path.
本发明还提供一种调度路径配置装置,包括:The present invention also provides a scheduling path configuration device, including:
获取模块,获取算力资源数据以及网络质量数据;Obtain module to obtain computing resource data and network quality data;
上报模块,用于将所述算力资源数据以及所述网络质量数据上报至所述调度系统,以供所述调度系统基于用户业务需求、所述算力资源数据以及所述网络质量数据,对各个边缘网关节点进行路径编排,得到调度策略路径,以将所述调度策略路径下发至边缘网关节点;A reporting module, configured to report the computing power resource data and the network quality data to the dispatching system, so that the dispatching system can, based on user service requirements, the computing power resource data and the network quality data, Each edge gateway node performs path arrangement to obtain a scheduling policy path, so as to deliver the scheduling policy path to the edge gateway node;
第一接收模块,用于接收并存储所述调度策略路径。The first receiving module is configured to receive and store the scheduling policy path.
本发明还提供一种调度路径配置装置,包括:The present invention also provides a scheduling path configuration device, including:
第二接收模块,用于接收各个边缘网关节点的算力资源数据以及网络质量数据;The second receiving module is used to receive computing power resource data and network quality data of each edge gateway node;
编排模块,用于根据用户业务需求、所述算力资源数据以及所述网络质量数据,对各个边缘网关节点进行路径编排,得到调度策略路径;An orchestration module, configured to arrange paths for each edge gateway node according to user service requirements, the computing power resource data, and the network quality data, to obtain a scheduling policy path;
下发模块,用于将所述调度策略路径下发至边缘网关节点,以供所述边缘网关节点存储所述调度策略路径。A sending module, configured to send the scheduling policy path to the edge gateway node, so that the edge gateway node stores the scheduling policy path.
本发明还提供一种电子设备,包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序,所述处理器执行所述程序时实现如上述任一种所述调度路径配置方法。The present invention also provides an electronic device, including a memory, a processor, and a computer program stored on the memory and operable on the processor. When the processor executes the program, it implements the scheduling path configuration as described above. method.
本发明还提供一种非暂态计算机可读存储介质,其上存储有计算机程序,该计算机程序被处理器执行时实现如上述任一种所述调度路径配置方法。The present invention also provides a non-transitory computer-readable storage medium, on which a computer program is stored, and when the computer program is executed by a processor, the scheduling path configuration method described in any one of the above-mentioned methods is implemented.
本发明还提供一种计算机程序产品,包括计算机程序,所述计算机程序被处理器执行时实现如上述任一种所述调度路径配置方法。The present invention also provides a computer program product, including a computer program, and when the computer program is executed by a processor, any method for configuring a scheduling path described above is implemented.
本发明提供的调度路径配置方法、装置、设备及存储介质,通过根据业务需求,结合算力资源数据以及网络质量数据灵活调整调度路径,进而通过调度系统将调度策略路径下发至边缘网关节点,从而以边缘网关节点作为基础设施,当调度策略变更时,由于边缘网关节点存储有不同业务需求的调度策略路径,无需等待调度系统下发新的调度策略,实现算力下沉,有效提升业务服务质量。The scheduling path configuration method, device, equipment, and storage medium provided by the present invention flexibly adjust the scheduling path according to business requirements, combined with computing power resource data and network quality data, and then send the scheduling policy path to the edge gateway node through the scheduling system. Therefore, using the edge gateway node as the infrastructure, when the scheduling strategy changes, because the edge gateway node stores scheduling strategy paths with different business requirements, there is no need to wait for the scheduling system to issue a new scheduling strategy, realizing the sinking of computing power and effectively improving business services quality.
附图说明Description of drawings
为了更清楚地说明本发明或现有技术中的技术方案,下面将对实施例或现有技术描述中所需要使用的附图逐一简单地介绍,显而易见地,下面描述中的附图是本发明的一些实施例,对于本领域普通技术人员来讲,在不付出创造性劳动的前提下,还可以根据这些附图获得其他的附图。In order to more clearly illustrate the present invention or the technical solutions in the prior art, the accompanying drawings that need to be used in the description of the embodiments or the prior art will be briefly introduced one by one below. Obviously, the accompanying drawings in the following description are the For some embodiments of the present invention, those of ordinary skill in the art can also obtain other drawings based on these drawings on the premise of not paying creative efforts.
图1是本发明提供的调度路径配置方法的流程示意图之一;Fig. 1 is one of the schematic flow charts of the dispatching path configuration method provided by the present invention;
图2是本发明一个实施例提供的调度路径配置系统的网络组网拓扑图;FIG. 2 is a network topology diagram of a scheduling path configuration system provided by an embodiment of the present invention;
图3是本发明一个实施例提供的服务节点与业务功能节点之间的数据流图;Fig. 3 is a data flow diagram between a service node and a service function node provided by an embodiment of the present invention;
图4是人脸识别业务对应的数据转发流程示意图;Fig. 4 is a schematic diagram of the data forwarding process corresponding to the face recognition service;
图5是本发明提供的调度路径配置方法的流程示意图之二;Fig. 5 is the second schematic flow diagram of the scheduling path configuration method provided by the present invention;
图6是本发明提供的应用于边缘网关节点的调度路径配置装置的结构示意图;FIG. 6 is a schematic structural diagram of a scheduling path configuration device applied to an edge gateway node provided by the present invention;
图7是本发明提供的应用于调度系统的调度路径配置装置的结构示意图;Fig. 7 is a schematic structural diagram of a dispatching path configuration device applied to a dispatching system provided by the present invention;
图8是本发明提供的电子设备的结构示意图。Fig. 8 is a schematic structural diagram of an electronic device provided by the present invention.
具体实施方式Detailed ways
为使本发明的目的、技术方案和优点更加清楚,下面将结合本发明中的附图,对本发明中的技术方案进行清楚、完整地描述,显然,所描述的实施例是本发明一部分实施例,而不是全部的实施例。基于本发明中的实施例,本领域普通技术人员在没有作出创造性劳动前提下所获得的所有其他实施例,都属于本发明保护的范围。In order to make the purpose, technical solutions and advantages of the present invention clearer, the technical solutions in the present invention will be clearly and completely described below in conjunction with the accompanying drawings in the present invention. Obviously, the described embodiments are part of the embodiments of the present invention , but not all examples. Based on the embodiments of the present invention, all other embodiments obtained by persons of ordinary skill in the art without creative efforts fall within the protection scope of the present invention.
在本发明一个或多个实施例中使用的术语是仅仅出于描述特定实施例的目的,而非旨在限制本发明一个或多个实施例。在本发明一个或多个实施例中所使用的单数形式的“一种”、“所述”和“该”也旨在包括多数形式,除非上下文清楚地表示其他含义。还应当理解,本发明一个或多个实施例中使用的术语“和/或”是指并包含一个或多个相关联的列出项目的任何或所有可能组合。Terms used in one or more embodiments of the present invention are for the purpose of describing particular embodiments only, and are not intended to limit the one or more embodiments of the present invention. As used in one or more embodiments of the invention, the singular forms "a", "the", and "the" are also intended to include the plural forms unless the context clearly dictates otherwise. It should also be understood that the term "and/or" used in one or more embodiments of the present invention refers to and includes any and all possible combinations of one or more of the associated listed items.
应当理解,尽管在本发明一个或多个实施例中可能采用术语第一、第二等来描述各种信息,但这些信息不应限于这些术语。这些术语仅用来将同一类型的信息彼此区分开。例如,在不脱离本发明一个或多个实施例范围的情况下,第一也可以被称为第二,类似地,第二也可以被称为第一。取决于语境,如在此所使用的词语“如果”可以被解释成为“在……时”或“当……时”。It should be understood that although the terms first, second, etc. may be used to describe various information in one or more embodiments of the present invention, the information should not be limited to these terms. These terms are only used to distinguish information of the same type from one another. For example, a first could be termed a second, and, similarly, a second could be termed a first, without departing from the scope of one or more embodiments of the present invention. Depending on the context, the word "if" as used herein may be interpreted as "at" or "when".
算力网络的目的是将算力资源融合通信网络,以一个更整体的形式提供最符合用户需求的算力资源服务。当前,随着云网融合推动发展,利用软件定义的优势把云计算和网络进行结合来实现算力网络。The purpose of the computing power network is to integrate computing power resources into the communication network and provide computing power resource services that best meet the needs of users in a more integrated form. At present, with the promotion of cloud-network integration, the advantages of software definition are used to combine cloud computing and network to realize computing power network.
现阶段算力网络中的边缘基础设施主要以运营商设备为主,通常是采用集中式管控的方法对各个运营商设备进行管理,具体地,各个运营商设备对应的算力网络调度策略由上层调度系统统一进行调度管理。然而,当用户业务需求发生变化,调度策略需要变更时,需要发送变更请求至上层调度系统,以获取到上层调度系统下发新的调度策略,调度策略变更执行周期较长,导致提升业务的服务质量较低。At this stage, the edge infrastructure in the computing power network is mainly based on operator equipment, and the centralized management and control method is usually used to manage each operator's equipment. Specifically, the computing power network scheduling strategy corresponding to each operator's equipment is determined by the upper layer The scheduling system performs unified scheduling management. However, when the user's business needs change and the scheduling policy needs to be changed, a change request needs to be sent to the upper-level scheduling system to obtain a new scheduling policy issued by the upper-level scheduling system. The execution cycle of the scheduling policy change is longer, resulting in improved business services lower quality.
针对上述问题,本发明提出了以下实施例。图1是本发明提供的调度路径配置方法的流程示意图之一。如图1所示,该调度路径配置方法应用于边缘网关节点,方法包括:In view of the above problems, the present invention proposes the following embodiments. Fig. 1 is one of the schematic flowcharts of the scheduling path configuration method provided by the present invention. As shown in Figure 1, the scheduling path configuration method is applied to the edge gateway node, and the method includes:
步骤11,获取算力资源数据以及网络质量数据;
需要说明的是,所述算力资源数据包括CPU使用率和内存分配占用率等数据,所述网络质量数据包括时延、丢包、抖动、带宽和链路状态等数据。It should be noted that the computing power resource data includes data such as CPU usage and memory allocation occupancy, and the network quality data includes data such as delay, packet loss, jitter, bandwidth, and link status.
可以理解地,图2是本发明一个实施例提供的调度路径配置系统的网络组网拓扑图,如图2所示,网络组网拓扑图是基于SRv6技术构建的,图中的数字1、2、3、4和5表示各个通信接口,边缘云分布在网络边缘侧,是提供实时数处理、分析决策的小规模云数据中心。SR(Segment Routing,分段路由)域是参与SR协议的节点或网络设备的集合。在SR域内,节点可以执行入口、传输或出口的数据传输过程,源节点和尾节点之间的路径经过SR域。It can be understood that Fig. 2 is a network topology diagram of a scheduling path configuration system provided by an embodiment of the present invention. As shown in Fig. 2, the network topology diagram is constructed based on SRv6 technology, and numbers 1 and 2 in the figure , 3, 4, and 5 represent various communication interfaces, and the edge cloud is distributed on the edge of the network, which is a small-scale cloud data center that provides real-time data processing, analysis and decision-making. An SR (Segment Routing, segment routing) domain is a collection of nodes or network devices participating in the SR protocol. Within the SR domain, nodes can perform ingress, transfer, or egress data transfer processes, and the path between the source node and the tail node passes through the SR domain.
进一步地,图中的PC表示客户端、SF((service function)1和SF2表示业务功能节点,提供VAS的具体设备,常见为SLB和WAF等;CPE(Customer Premise Equipment)表示边缘网关设备上;CPE-SC(service classifier)表示源节点,用于识别流量分类器,匹配要引入的VAS链条;SFF(service function forwarder)服务节点:链接SF的交换机,常见的有TOR(The Onion Router)、网关以及vSwitch(Virtual Switch。虚拟交换机或虚拟网络交换机)等,其中,TOR保护在线活动免遭窃取的技术,CPE-END表示尾节点。Further, the PC in the figure represents the client, SF((service function)1 and SF2 represent service function nodes, and specific devices that provide VAS, such as SLB and WAF, etc.; CPE (Customer Premise Equipment) represents the edge gateway device; CPE-SC (service classifier) represents the source node, which is used to identify the traffic classifier and match the VAS chain to be imported; SFF (service function forwarder) service node: a switch connected to SF, common ones include TOR (The Onion Router), gateway And vSwitch (Virtual Switch. Virtual switch or virtual network switch), etc., among them, TOR protects the technology of online activities from being stolen, and CPE-END means the tail node.
在本实施例中,边缘网关节点可获取边缘云中资源池内的资源数据,所述边缘网关节点可采集相邻节点之间的网络质量数据,例如,CPE-SFF1采集CPE-SC与CPE-END之间的网络质量数据。In this embodiment, the edge gateway node can obtain resource data in the resource pool in the edge cloud, and the edge gateway node can collect network quality data between adjacent nodes, for example, CPE-SFF1 collects CPE-SC and CPE-END Network quality data between.
步骤12,将所述算力资源数据以及所述网络质量数据上报至所述调度系统,以供所述调度系统基于用户业务需求、所述算力资源数据以及所述网络质量数据,对各个边缘网关节点进行路径编排,得到调度策略路径,以将所述调度策略路径下发至边缘网关节点;Step 12: Report the computing power resource data and the network quality data to the dispatching system, so that the dispatching system can assign each edge The gateway node arranges the path to obtain the scheduling policy path, so as to deliver the scheduling policy path to the edge gateway node;
需要说明的是,所述边缘网关节点与所述调度系统之间配置有控制器。进一步地,所述调度策略路径是一个SR源节点连接到SR尾节点的网络段的有序列表,在本实施例中,有序列表表示SRv6中的各个SID形成的节点服务ID列表,其中,SID由Locator和Function两部分组成,Locator表示标识路由能力,指导业务流量在指定的节点转发,Locator在SR域内唯一;Function表示标识设备的网络功能,例如转发报文、执行特定业务等。SR域内的节点收到业务流量后,根据SRv6 SID的Funciton字段执行相关操作。It should be noted that a controller is configured between the edge gateway node and the scheduling system. Further, the scheduling policy path is an ordered list of network segments connected from an SR source node to an SR tail node. In this embodiment, the ordered list represents a node service ID list formed by each SID in SRv6, wherein, The SID is composed of two parts: Locator and Function. Locator indicates the identification routing capability and guides service traffic to be forwarded at the specified node. Locator is unique in the SR domain. Function indicates the network function of the identification device, such as forwarding packets and executing specific services. After the nodes in the SR domain receive the service traffic, they perform related operations according to the Funciton field of the SRv6 SID.
具体地,将所述算力资源数据以及所述网络质量数据上传至所述控制器,从而可通过所述控制器将所述算力资源数据以及所述网络质量数据上报至调度系统。进一步地,当所述调度系统接收到客户端发送注册申请的开通资源请求时,基于所述开通资源请求,确定用户业务需求,进而确定所述户业务需求对应的各个业务服务,例如,若开通资源请求是对视频业务对于的开通请求,则确定用户业务需求是视频业务,视频业务可包括抽帧服务、校验推送服务以及人脸识别服务。进一步地,基于各个边缘网关节点的算力资源数据以及网络质量数据,对各所述业务服务对应的边缘网关节点进行路径编排,得到所述调度策略路径。可以理解地,根据边缘网关节点的算力资源数据以及网络质量数据,计算得到最优的调度策略路径。可选地,所述调度策略路径包括主调度路径和至少一条备用调度路径,更为具体地:根据各个调度路径中边缘节点的算力资源数据以及网络质量数据,确定各个调度路径的优先级,进而将优先级最高的调度路径作为所述主调度路径,将其余各个调度路径作为备用调度路径,其余各个调度路径表示除了优先级最高的调度路径之外的各个调度路径。Specifically, the computing power resource data and the network quality data are uploaded to the controller, so that the computing power resource data and the network quality data can be reported to a scheduling system through the controller. Further, when the dispatching system receives a resource activation request sent by a registration application from a client, based on the resource activation request, it determines the user's business needs, and then determines each business service corresponding to the user's business needs, for example, if the If the resource request is a request for opening a video service, it is determined that the user service requirement is a video service, and the video service may include frame sampling service, verification push service, and face recognition service. Further, based on the computing power resource data and network quality data of each edge gateway node, path arrangement is performed on the edge gateway nodes corresponding to each of the business services to obtain the scheduling strategy path. Understandably, the optimal scheduling policy path is calculated according to the computing power resource data and network quality data of the edge gateway node. Optionally, the scheduling policy path includes a main scheduling path and at least one backup scheduling path, more specifically: determining the priority of each scheduling path according to computing resource data and network quality data of edge nodes in each scheduling path, Furthermore, the scheduling path with the highest priority is used as the main scheduling path, and the remaining scheduling paths are used as backup scheduling paths, and the remaining scheduling paths represent scheduling paths except the scheduling path with the highest priority.
进一步地,在调度系统计算得到调度策略路径后,将所述调度策略路径下发至控制器,控制器在接收到调度下发的调度策略路径后,将所述调度策略路径对应的节点服务ID列表分发至各个边缘网关节点,可选地,以SRv6 policy形式分发至各个边缘网关节点。Further, after the dispatching system calculates the dispatching strategy path, it sends the dispatching strategy path to the controller, and the controller sends the node service ID corresponding to the dispatching strategy path to The list is distributed to each edge gateway node, optionally, distributed to each edge gateway node in the form of SRv6 policy.
步骤13,接收并存储所述调度策略路径。
需要说明的是,所述业务数据是客户端发送的业务数据,调度策略路径下发至源节点进行存储,服务节点和尾节点维护节点服务ID列表。具体地,源节点、服务节点和尾节点接收并存储控制器分发的调度策略路径,进而使得当接收客户端发送的业务数据时,基于所述调度策略路径,对业务数据进行数据转发。It should be noted that the service data is the service data sent by the client, the scheduling policy path is delivered to the source node for storage, and the service node and the tail node maintain a list of node service IDs. Specifically, the source node, the service node and the tail node receive and store the scheduling policy path distributed by the controller, so that when receiving the service data sent by the client, the service data is forwarded based on the scheduling policy path.
本发明实施例通过根据业务需求,结合算力资源数据以及网络质量数据灵活调整调度路径,进而通过调度系统将调度策略路径下发至边缘网关节点,从而以边缘网关节点作为基础设施,当调度策略变更时,由于边缘网关节点存储有不同业务需求的调度策略路径,无需等待调度系统下发新的调度策略,实现算力下沉,有效提升业务服务质量。The embodiment of the present invention flexibly adjusts the scheduling path according to business requirements, combined with computing power resource data and network quality data, and then sends the scheduling policy path to the edge gateway node through the scheduling system, so that the edge gateway node is used as the infrastructure. When changing, because the edge gateway node stores scheduling strategy paths with different business requirements, there is no need to wait for the scheduling system to issue new scheduling strategies, realizing the sinking of computing power and effectively improving the quality of business services.
在本发明的一个实施例中,所述接收并存储所述调度策略路径之后,还包括:In an embodiment of the present invention, after receiving and storing the scheduling strategy path, further includes:
检测所述主调度路径对应的网络状态;若所述主调度路径的网络状态处于故障状态,则切换至所述备用调度路径,以基于所述备用调度路径进行数据转发。Detecting the network state corresponding to the main scheduling path; if the network state of the main scheduling path is in a failure state, switching to the backup scheduling path to forward data based on the backup scheduling path.
具体地,在配置部署得到调度策略路径后,通过源节点检测所述主调度路径中端对端对应的网络数据,以根据网络数据确定调度策略路径对应的端对端的网络状态,所述网络数据包括中服务节点和尾节点分别对应的时延、丢包、抖动、带宽和链路状态等数据,以及边缘云中资源池的CPU使用率和内存分配占用率等数据,作为一种可实施方式,若网络数据低于预先设置的参数阈值,则判定所述主调度路径的网络状态处于故障状态,参数阈值可按照实际情况设定,在次不作具体限制。进一步地,直接将路径切换至所述备用调度路径,以基于所述备用调度路径进行数据转发。Specifically, after the scheduling policy path is obtained through configuration and deployment, the network data corresponding to the end-to-end in the main scheduling path is detected by the source node, so as to determine the end-to-end network status corresponding to the scheduling policy path according to the network data, and the network data Including data such as delay, packet loss, jitter, bandwidth, and link status corresponding to the middle service node and tail node, as well as data such as CPU usage and memory allocation occupancy of the resource pool in the edge cloud, as an implementable method , if the network data is lower than the preset parameter threshold, it is determined that the network status of the main scheduling path is in a fault state, and the parameter threshold can be set according to the actual situation, and there is no specific limit for this time. Further, the path is directly switched to the standby scheduling path, so as to perform data forwarding based on the standby scheduling path.
另外地,当所述主调度路径故障恢复后,可重新将路径切回至该主调度路径对业务数据进行转发操作。In addition, after the failure of the main scheduling path recovers, the path can be switched back to the main scheduling path to forward service data.
本发明实施例通过实时探测主调度路径的网络数据,当主调度路径发生故障后能够及时完成策略路径的切换,整个切换过程由设备节点独立完成,无需经过上层调度系统重新发起调用,有效提高路径切换的效率,从而提升业务服务质量。The embodiment of the present invention detects the network data of the main scheduling path in real time, and when the main scheduling path fails, the switching of the policy path can be completed in time. The entire switching process is completed independently by the device node without re-initiating the call through the upper-level scheduling system, effectively improving path switching. efficiency, thereby improving the quality of business services.
在本发明的一个实施例中,所述接收并存储所述调度策略路径之后,包括:In an embodiment of the present invention, after receiving and storing the scheduling strategy path, it includes:
通过所述源节点获取客户端发送的第一业务报文,所述第一业务报文包括所述业务数据;Obtaining, through the source node, a first service message sent by the client, where the first service message includes the service data;
通过所述源节点对所述第一业务报文进行路径分类,得到所述第一业务报文对应的调度策略路径;Classifying the path of the first service message by the source node to obtain a scheduling policy path corresponding to the first service message;
基于预先配置的路由拓展头,通过所述源节点对所述第一业务报文进行封装处理,得到第一封装报文,以将所述第一封装报文转发至所述服务节点,其中,所述路由拓展头包括所述节点服务ID列表;Based on the pre-configured routing extension header, the source node encapsulates the first service message to obtain a first encapsulated message, so as to forward the first encapsulated message to the service node, wherein, The routing extension header includes the node service ID list;
需要说明的是,所述路由拓展头包括所述节点服务ID列表;所述第一封装报文表示IPv6报文;所述封装处理表示将第一业务报文封装成IPv6 SR格式的报文,需要第一业务报文添加上SRH(Segment Identifier Header,IPv6 SR报文头)路由拓展头。SRH是路由类型取值为4的一种路由扩展头,其中,SRH主要包含以下几个字段部分:Next Header:8bits,用来标识下一个报文头的类型。Hdr Ext Len:8bits,表示以8个字节为单位的SRH头的长度,不包括前8个字节;Routing Type:8bits,路由类型字段,取值为4,表示携带的是SRH。Segments Left:8bits,标识需要查看的下一个SID的编号,初始取值为n-1(n表示路由扩展头中SID的数目),每经过一个节点减1;Last Entry:8bits,SRH头中调度策略路径中最后一个SID的编号,取值为0;Segment List:SID列表,Segment List是按照调度策略路径上节点从远到近的顺序进行排列,例如:Segment List[0]表示路径的最后一个SID,Segment List[1]表示调度路径的倒数第二个SID。It should be noted that the routing extension header includes the node service ID list; the first encapsulated packet represents an IPv6 packet; the encapsulation process represents encapsulating the first service packet into a packet in IPv6 SR format, It is necessary to add an SRH (Segment Identifier Header, IPv6 SR packet header) routing extension header to the first service packet. SRH is a routing extension header with a routing type value of 4. The SRH mainly includes the following fields: Next Header: 8 bits, used to identify the type of the next packet header. Hdr Ext Len: 8bits, indicating the length of the SRH header in units of 8 bytes, excluding the first 8 bytes; Routing Type: 8bits, the routing type field, with a value of 4, indicating that the SRH is carried. Segments Left: 8bits, identifies the number of the next SID to be checked, the initial value is n-1 (n indicates the number of SIDs in the routing extension header), and decreases by 1 every time a node passes; Last Entry: 8bits, scheduled in the SRH header The number of the last SID in the strategy path, the value is 0; Segment List: SID list, the Segment List is arranged according to the order of the nodes on the scheduling strategy path from far to near, for example: Segment List[0] means the last of the path SID, Segment List[1] indicates the penultimate SID of the scheduling path.
具体地,对于源节点:当接收到客户端发送的第一业务请求中的第一业务报文时,通过源节点根据所述第一业务报文的任播地址,识别得到所述第一业务报文对应的调度策略路径,进而基于预先配置的路由拓展头,通过所述源节点对所述第一业务报文进行封装处理,得到第一封装报文,所述路由拓展头包括所述节点服务ID列表。进一步地,根据第一封装报文中的目的地址查找路由表,从而将第一封装报文进行转发,例如,调度策略路径依次经过节点A、节点B和节点C,封装的Segment List列表信息为Segment List[0]=D、Segment List[1]=C、Segment List[2]=B,基于Segment List列表信息,节点A将第一封装报文转发至节点B。Specifically, for the source node: when receiving the first service packet in the first service request sent by the client, the source node identifies the first service packet according to the anycast address of the first service packet The scheduling policy path corresponding to the message, and then based on the pre-configured routing extension header, the source node encapsulates the first service message to obtain the first encapsulated message, and the routing extension header includes the node A list of service IDs. Further, look up the routing table according to the destination address in the first encapsulated message, so as to forward the first encapsulated message, for example, the scheduling policy path passes through node A, node B and node C in sequence, and the encapsulated Segment List list information is Segment List[0]=D, Segment List[1]=C, Segment List[2]=B, based on the Segment List list information, node A forwards the first encapsulated packet to node B.
通过所述服务节点对所述第一封装报文进行解封,得到第一解封业务数据;Decapsulating the first encapsulated message by the service node to obtain first decapsulated service data;
基于所述节点服务ID列表,将所述第一解封业务数据转发至业务功能节点;forwarding the first decapsulated service data to a service function node based on the node service ID list;
通过所述业务功能节点对所述第一解封业务数据进行字段校验,以基于校验成功的第一解封业务数据,发送第二业务报文至所述服务节点;Perform field verification on the first decapsulated service data by the service function node, so as to send a second service message to the service node based on the successfully verified first decapsulated service data;
具体地,服务节点接收到第一封装报文后,通过所述服务节点对所述第一封装报文进行解封,得到第一解封业务数据,进而基于所述节点服务ID列表,将所述第一解封业务数据转发至业务功能节点,可选地,参照图3,图3是本发明一个实施例提供的服务节点与业务功能节点之间的数据流图,服务节点对第一封装报文执行End.AD动作,以将第一封装报文中的IPv6 Inner Header(头部)和Payload(负载)转发至API接口网关,进而通过API接口网关将IPv6 Inner Header(头部)和Payload(负载)发送至业务功能节点。进一步地,通过业务功能节点对所述第一解封业务数据进行字段校验,若校验失败,则将第一解封业务数据丢弃,不再转发,若校验成功,则基于校验成功的第一解封业务数据,生成第二业务请求,进而通过业务功能节点会重新向所述服务节点发起第二业务请求,以将第二业务请求中的第二业务报文下发至所述服务节点。Specifically, after receiving the first encapsulated message, the service node decapsulates the first encapsulated message through the service node to obtain the first decapsulated service data, and then based on the node service ID list, the The first decapsulated service data is forwarded to the service function node. Optionally, referring to FIG. 3, FIG. The message executes the End.AD action to forward the IPv6 Inner Header (header) and Payload (load) in the first encapsulated message to the API interface gateway, and then through the API interface gateway, the IPv6 Inner Header (header) and Payload (payload) is sent to the service function node. Further, the field verification is performed on the first decapsulated service data through the service function node, if the verification fails, the first decapsulated service data is discarded, and no longer forwarded, and if the verification is successful, based on the successful verification The first decapsulated business data, generate a second business request, and then re-initiate the second business request to the service node through the business function node, so as to send the second business message in the second business request to the service node.
通过所述服务节点对所述第二业务报文进行封装处理,得到第二封装报文,以将所述第二封装报文转发至尾节点;encapsulating the second service message by the service node to obtain a second encapsulated message, so as to forward the second encapsulated message to a tail node;
具体地,服务节点接收到第二业务报文后,重新添加缓存的IPv6头和SRH路由拓展头,以通过所述服务节点对所述第二业务报文进行封装处理,得到第二封装报文,进一步地,将所述第二封装报文转发至尾节点。Specifically, after receiving the second service message, the service node re-adds the cached IPv6 header and SRH routing extension header, so that the service node can encapsulate the second service message to obtain the second encapsulated message , further, forwarding the second encapsulated packet to the tail node.
通过所述尾节点将所述第二封装报文进行报文头解封处理,得到第二解封业务数据,以基于所述节点服务ID列表,将所述第二解封业务数据进行数据转发。Decapsulate the header of the second encapsulated message through the tail node to obtain second decapsulated service data, so as to forward the second decapsulated service data based on the node service ID list .
具体地,所述尾节点在接收到第二封装报文后,通过所述尾节点对所述第二封装报文进行报文头解封处理,得到第二解封业务数据,可选地,对所述第二封装报文执行End.DT动作弹出SRH路由拓展头,得到第二解封业务数据,也即,第二解封业务数据不存在SRH路由拓展头。进而基于所述节点服务ID列表,将所述第二解封业务数据进行数据转发至对应的业务服务中。Specifically, after the tail node receives the second encapsulated message, the tail node decapsulates the header of the second encapsulated message to obtain the second decapsulated service data. Optionally, Executing the End.DT action on the second encapsulated packet pops up the SRH routing extension header to obtain the second decapsulated service data, that is, the second decapsulated service data does not have the SRH routing extension header. Further, based on the node service ID list, the second decapsulated service data is forwarded to the corresponding service service.
在本实施例中,以图像人脸识别业务为例,图4是人脸识别业务对应的数据转发流程示意图,如图4所示,业务数据转发流程如下:In this embodiment, taking the image face recognition service as an example, FIG. 4 is a schematic diagram of the data forwarding process corresponding to the face recognition service. As shown in FIG. 4 , the service data forwarding process is as follows:
首先,客户端的摄像头采集到原始视频流数据,进而将第一业务报文发送至源节点,第一业务报文包括原始视频流数据,经过源节点上部署的拉流抽帧应用服务,对原始视频流数据进行抽帧,抽帧后的采样数据经源节点进行分类,得到调度策略路径,进而基于SRH路由拓展头,将对所述第一业务报文进行封装,得到IPv6第一封装报文,从而在SRv6网络域中进行传输报文数据。First, the camera on the client side collects the original video stream data, and then sends the first service message to the source node. The first service message includes the original video stream data. Frame extraction is performed on the video stream data, and the sampled data after frame extraction is classified by the source node to obtain a scheduling policy path, and then based on the SRH routing extension header, the first service message is encapsulated to obtain the first IPv6 encapsulated message , so as to transmit packet data in the SRv6 network domain.
其次,服务节点对第一封装报文进行解封装SRv6数据头,将解封后的第一解封业务数据转发至服务节点对应的推送服务,该推送服务对第一解封业务数据进行数据协议内容等关键字段校验,若校验失败,则作丢弃不再转发,若校验通过,则重新发送第二业务报文至服务节点,从而基于缓存的SRv6数据头,通过服务节点再次对第二业务报文进行封装,得到第二封装数据,进而将第二封装数据转发至尾节点。Secondly, the service node decapsulates the SRv6 data header of the first encapsulated message, and forwards the decapsulated first decapsulated business data to the push service corresponding to the service node, and the push service performs data agreement on the first decapsulated business data Content and other key fields are checked. If the check fails, it will be discarded and not forwarded. If the check is passed, the second service message will be resent to the service node, so that based on the cached SRv6 data header, the service node will send the message again. The second service message is encapsulated to obtain the second encapsulated data, and then the second encapsulated data is forwarded to the tail node.
最后,尾节点接收第二封装数据后,对第二封装数据进行解封处理,进而将解封得到的数据转发给节点上部署的人脸识别服务,以人脸识别服务进行识别处理,从而完成对人脸图像的鉴别。Finally, after the tail node receives the second encapsulated data, it decapsulates the second encapsulated data, and then forwards the decapsulated data to the face recognition service deployed on the node, and uses the face recognition service for recognition processing, thus completing Identification of face images.
本发明实施例通过根据源节点分别识别得到业务数据对应的调度策略路径,从而根据调度策略路径对应的节点服务ID列表,通过源节点、服务节点、尾节点将业务数据进行转发,从而实现端到端的数据传输。According to the embodiment of the present invention, the scheduling policy path corresponding to the service data is respectively identified according to the source node, so that according to the node service ID list corresponding to the scheduling policy path, the service data is forwarded through the source node, service node, and tail node, thereby realizing end-to-end terminal data transmission.
图5是本发明提供的调度路径配置方法的流程示意图之二。如图5所示,该调度路径配置方法应用于调度系统,方法包括:FIG. 5 is the second schematic flow diagram of the scheduling path configuration method provided by the present invention. As shown in Figure 5, the scheduling path configuration method is applied to the scheduling system, and the methods include:
步骤51,接收各个边缘网关节点的算力资源数据以及网络质量数据;
步骤52,根据用户业务需求、所述算力资源数据以及所述网络质量数据,对各个边缘网关节点进行路径编排,得到调度策略路径;Step 52, according to the user's service requirements, the computing power resource data and the network quality data, perform path arrangement for each edge gateway node to obtain a scheduling strategy path;
步骤53,将所述调度策略路径下发至边缘网关节点,以供所述边缘网关节点存储所述调度策略路径。
具体地,接收控制器发送的各个边缘网关节点采集到的算力资源数据以及网络质量数据,所述算力资源数据包括CPU使用率和内存分配占用率等数据,所述网络质量数据包括时延、丢包、抖动、带宽和链路状态等数据,进而响应于客户端发送的开通资源请求时,基于所述开通资源请求,确定用户业务需求,进而确定所述户业务需求对应的各个业务服务,进一步地,基于所述算力资源数据以及所述网络质量数据,对各所述业务服务对应的边缘网关节点进行路径编排,得到所述调度策略路径,调度策略路径的数量可按照实际情况设置,优选地,所述调度策略路径包括主调度路径和至少一条备用调度路径。进一步地,将所述调度策略路径下发至控制器,进而通过控制器将调度策略路径分发至边缘网关节点,可选地,调度策略路径下发至源节点进行存储,服务节点和尾节点维护节点服务ID列表。从而当接收客户端发送的业务数据时,基于所述调度策略路径中的源节点、服务节点、尾节点以及业务功能节点,对业务数据进行数据转发。Specifically, the computing power resource data and network quality data collected by each edge gateway node sent by the receiving controller, the computing power resource data includes data such as CPU usage and memory allocation occupancy, and the network quality data includes time delay , packet loss, jitter, bandwidth, link status and other data, and then respond to the resource activation request sent by the client, based on the resource activation request, determine the user's business needs, and then determine the corresponding business services of the user's business needs , further, based on the computing power resource data and the network quality data, path arrangement is performed on the edge gateway nodes corresponding to each of the business services to obtain the scheduling strategy path, and the number of scheduling strategy paths can be set according to the actual situation , preferably, the scheduling strategy path includes a main scheduling path and at least one backup scheduling path. Further, the scheduling strategy path is sent to the controller, and then the scheduling strategy path is distributed to the edge gateway node through the controller. Optionally, the scheduling strategy path is sent to the source node for storage, and the service node and the tail node maintain A list of node service IDs. Therefore, when receiving the service data sent by the client, the service data is forwarded based on the source node, the service node, the tail node and the service function node in the scheduling policy path.
本发明实施例通过根据业务需求,结合算力资源数据以及网络质量数据灵活调整调度路径,进而通过调度系统将调度策略路径下发至边缘网关节点,从而以边缘网关节点作为基础设施,当调度策略变更时,由于边缘网关节点存储有调度策略路径,无需等待调度系统下发新的调度策略,实现算力下沉,有效提升业务服务质量。The embodiment of the present invention flexibly adjusts the scheduling path according to business requirements, combined with computing power resource data and network quality data, and then sends the scheduling policy path to the edge gateway node through the scheduling system, so that the edge gateway node is used as the infrastructure. When changing, because the edge gateway node stores the scheduling strategy path, there is no need to wait for the scheduling system to issue a new scheduling strategy, which realizes the sinking of computing power and effectively improves the quality of business services.
本发明还提供了调度路径配置系统,参照图2,该调度路径配置系统包括:The present invention also provides a scheduling path configuration system, with reference to Figure 2, the scheduling path configuration system includes:
边缘设备节点,用于获取算力资源数据以及网络质量数据,以将所述算力资源数据以及所述网络质量数据发送至控制器;An edge device node, configured to acquire computing power resource data and network quality data, so as to send the computing power resource data and the network quality data to the controller;
所述控制器,用于将所述算力资源数据以及所述网络质量数据上报至调度系统;The controller is configured to report the computing power resource data and the network quality data to a scheduling system;
所述调度系统,用于获取用户业务需求,以基于所述用户业务需求、所述算力资源数据以及所述网络质量数据,对各个边缘网关节点进行路径编排,得到调度策略路径,将所述调度策略路径下发至所述控制器;The dispatching system is configured to obtain user service requirements, and to arrange paths for each edge gateway node based on the user service requirements, the computing power resource data, and the network quality data, to obtain a dispatch policy path, and to dispatching the policy path to the controller;
所述控制器,还用于将所述调度策略路径下发至所述边缘设备节点;The controller is further configured to send the scheduling policy path to the edge device node;
所述边缘设备节点,还用于接收并存储所述调度策略路径。The edge device node is further configured to receive and store the scheduling policy path.
可选地,所述边缘设备节点包括源节点、服务节点、尾节点以及业务功能节点。Optionally, the edge device nodes include source nodes, service nodes, tail nodes, and service function nodes.
可选地,所述源节点,用于检测所述主调度路径对应的网络状态;Optionally, the source node is configured to detect a network state corresponding to the main scheduling path;
所述源节点,还用于若所述主调度路径的网络状态处于故障状态,则切换至所述备用调度路径,以基于所述备用调度路径进行数据转发。The source node is further configured to switch to the standby scheduling path if the network state of the main scheduling path is in a failure state, so as to perform data forwarding based on the standby scheduling path.
可选地,所述源节点,还用于获取客户端发送的第一业务报文,所述第一业务报文包括所述业务数据;Optionally, the source node is further configured to obtain a first service message sent by the client, where the first service message includes the service data;
所述源节点,还用于对所述第一业务报文进行路径分类,得到所述第一业务报文对应的调度策略路径;The source node is further configured to perform path classification on the first service message to obtain a scheduling policy path corresponding to the first service message;
所述源节点,还用于基于预先配置的路由拓展头,对所述第一业务报文进行封装处理,得到第一封装报文,以将所述第一封装报文转发至所述服务节点,其中,所述路由拓展头包括所述节点服务ID列表;The source node is further configured to encapsulate the first service message based on a pre-configured routing extension header to obtain a first encapsulated message, so as to forward the first encapsulated message to the service node , wherein, the routing extension header includes the node service ID list;
所述服务节点,用于对所述第一封装报文进行解封,得到第一解封业务数据;The service node is configured to decapsulate the first encapsulated message to obtain first decapsulated service data;
所述服务节点,还用于基于所述节点服务ID列表,将所述第一解封业务数据转发至业务功能节点;The service node is further configured to forward the first decapsulated service data to a service function node based on the node service ID list;
所述业务功能节点,用于对所述解封业务数据进行字段校验,以基于校验成功的第一解封业务数据,发送第二业务报文至所述服务节点;The service function node is configured to perform field verification on the decapsulated service data, so as to send a second service message to the service node based on the successfully verified first decapsulated service data;
所述服务节点,还用于对所述第二业务报文进行封装处理,得到第二封装报文,以将所述第二封装报文转发至尾节点;The service node is further configured to encapsulate the second service message to obtain a second encapsulated message, so as to forward the second encapsulated message to the tail node;
所述尾节点,用于基于所述节点服务ID列表,将所述第二封装报文进行报文头解封处理,得到第二解封业务数据,以将所述第二解封业务数据进行数据转发。The tail node is configured to decapsulate the header of the second encapsulated message based on the node service ID list to obtain second decapsulated service data, so as to decapsulate the second decapsulated service data data forwarding.
下面对本发明提供的调度路径配置装置进行描述,下文描述的调度路径配置装置与上文描述的调度路径配置方法可相互对应参照。The scheduling path configuration device provided by the present invention is described below, and the scheduling path configuration device described below and the scheduling path configuration method described above can be referred to in correspondence.
图6是本发明提供的应用于边缘网关节点的调度路径配置装置的结构示意图,如图6所示,本发明实施例的一种调度路径配置装置,该装置包括:FIG. 6 is a schematic structural diagram of a scheduling path configuration device applied to an edge gateway node provided by the present invention. As shown in FIG. 6, a scheduling path configuration device according to an embodiment of the present invention includes:
获取模块61,获取算力资源数据以及网络质量数据;Obtaining
上报模块62,用于将所述算力资源数据以及所述网络质量数据上报至所述调度系统,以供所述调度系统基于用户业务需求、所述算力资源数据以及所述网络质量数据,对各个边缘网关节点进行路径编排,得到调度策略路径,以将所述调度策略路径下发至边缘网关节点;A reporting
第一接收模块63,用于接收并存储所述调度策略路径。The first receiving module 63 is configured to receive and store the scheduling policy path.
图7是本发明提供的应用于调度系统的调度路径配置装置的结构示意图,如图7所示,本发明实施例的一种调度路径配置装置,该装置包括:Fig. 7 is a schematic structural diagram of a dispatching path configuration device applied to a dispatching system provided by the present invention. As shown in Fig. 7, a dispatching path configuration device according to an embodiment of the present invention includes:
第二接收模块71,用于接收各个边缘网关节点的算力资源数据以及网络质量数据;The
编排模块72,用于根据用户业务需求、所述算力资源数据以及所述网络质量数据,对各个边缘网关节点进行路径编排,得到调度策略路径;The
下发模块73,用于将所述调度策略路径下发至边缘网关节点,以供所述边缘网关节点存储所述调度策略路径。The sending
在此需要说明的是,本发明实施例提供的上述装置,能够实现上述方法实施例所实现的所有方法步骤,且能够达到相同技术效果,在此不再对本实施例中与方法实施例相同部分及有益效果进行具体赘述。What needs to be explained here is that the above-mentioned device provided by the embodiment of the present invention can realize all the method steps realized by the above-mentioned method embodiment, and can achieve the same technical effect. and beneficial effects are described in detail.
图8是本发明提供的电子设备的结构示意图,如图8所示,该电子设备可以包括:处理器(processor)810、存储器(memory)820、通信接口(Communications Interface)830和通信总线840,其中,处理器810,存储器820,通信接口830通过通信总线840完成相互间的通信。处理器810可以调用存储器820中的逻辑指令,以执行调度路径配置方法,该方法包括:获取算力资源数据以及网络质量数据;将所述算力资源数据以及所述网络质量数据上报至所述调度系统,以供所述调度系统基于用户业务需求、所述算力资源数据以及所述网络质量数据,对各个边缘网关节点进行路径编排,得到调度策略路径,以将所述调度策略路径下发至边缘网关节点;接收并存储所述调度策略路径。FIG. 8 is a schematic structural diagram of an electronic device provided by the present invention. As shown in FIG. 8, the electronic device may include: a processor (processor) 810, a memory (memory) 820, a communication interface (Communications Interface) 830 and a
此外,上述的存储器820中的逻辑指令可以通过软件功能单元的形式实现并作为独立的产品销售或使用时,可以存储在一个计算机可读取存储介质中。基于这样的理解,本发明的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的部分可以以软件产品的形式体现出来,该计算机软件产品存储在一个存储介质中,包括若干指令用以使得一台计算机设备(可以是个人计算机,服务器,或者网络设备等)执行本发明各个实施例所述方法的全部或部分步骤。而前述的存储介质包括:U盘、移动硬盘、只读存储器(ROM,Read-Only Memory)、随机存取存储器(RAM,Random Access Memory)、磁碟或者光盘等各种可以存储程序代码的介质。In addition, the above logic instructions in the
又一方面,本发明还提供一种非暂态计算机可读存储介质,其上存储有计算机程序,该计算机程序被处理器执行时实现以执行上述各方法提供的调度路径配置方法,该方法包括:获取算力资源数据以及网络质量数据;将所述算力资源数据以及所述网络质量数据上报至所述调度系统,以供所述调度系统基于用户业务需求、所述算力资源数据以及所述网络质量数据,对各个边缘网关节点进行路径编排,得到调度策略路径,以将所述调度策略路径下发至边缘网关节点;接收并存储所述调度策略路径。In yet another aspect, the present invention also provides a non-transitory computer-readable storage medium, on which a computer program is stored, and when the computer program is executed by a processor, it is implemented to execute the scheduling path configuration method provided by the above-mentioned methods, the method includes : Acquiring computing power resource data and network quality data; reporting the computing power resource data and the network quality data to the dispatching system, so that the dispatching system can be based on user business needs, the computing power resource data and the The above network quality data is used to arrange paths for each edge gateway node to obtain a scheduling policy path, so as to send the scheduling policy path to the edge gateway node; receive and store the scheduling policy path.
另一方面,本发明还提供一种计算机程序产品,所述计算机程序产品包括计算机程序,计算机程序可存储在非暂态计算机可读存储介质上,所述计算机程序被处理器执行时,计算机能够执行上述各方法所提供的调度路径配置方法,该方法包括:获取算力资源数据以及网络质量数据;将所述算力资源数据以及所述网络质量数据上报至所述调度系统,以供所述调度系统基于用户业务需求、所述算力资源数据以及所述网络质量数据,对各个边缘网关节点进行路径编排,得到调度策略路径,以将所述调度策略路径下发至边缘网关节点;接收并存储所述调度策略路径。On the other hand, the present invention also provides a computer program product. The computer program product includes a computer program that can be stored on a non-transitory computer-readable storage medium. When the computer program is executed by a processor, the computer can Executing the scheduling path configuration method provided by the above methods, the method includes: acquiring computing power resource data and network quality data; reporting the computing power resource data and the network quality data to the scheduling system for the The dispatching system arranges paths for each edge gateway node based on user service requirements, the computing power resource data, and the network quality data, and obtains a dispatching strategy path, so as to deliver the scheduling strategy path to the edge gateway node; receives and The scheduling policy path is stored.
以上所描述的装置实施例仅仅是示意性的,其中所述作为分离部件说明的单元可以是或者也可以不是物理上分开的,作为单元显示的部件可以是或者也可以不是物理单元,即可以位于一个地方,或者也可以分布到多个网络单元上。可以根据实际的需要选择其中的部分或者全部模块来实现本实施例方案的目的。本领域普通技术人员在不付出创造性的劳动的情况下,即可以理解并实施。The device embodiments described above are only illustrative, and the units described as separate components may or may not be physically separated, and the components shown as units may or may not be physical units, that is, they may be located in One place, or it can be distributed to multiple network elements. Part or all of the modules can be selected according to actual needs to achieve the purpose of the solution of this embodiment. It can be understood and implemented by those skilled in the art without any creative efforts.
通过以上的实施方式的描述,本领域的技术人员可以清楚地了解到各实施方式可借助软件加必需的通用硬件平台的方式来实现,当然也可以通过硬件。基于这样的理解,上述技术方案本质上或者说对现有技术做出贡献的部分可以以软件产品的形式体现出来,该计算机软件产品可以存储在计算机可读存储介质中,如ROM/RAM、磁碟、光盘等,包括若干指令用以使得一台计算机设备(可以是个人计算机,服务器,或者网络设备等)执行各个实施例或者实施例的某些部分所述的方法。Through the above description of the implementations, those skilled in the art can clearly understand that each implementation can be implemented by means of software plus a necessary general-purpose hardware platform, and of course also by hardware. Based on this understanding, the essence of the above technical solution or the part that contributes to the prior art can be embodied in the form of software products, and the computer software products can be stored in computer-readable storage media, such as ROM/RAM, magnetic discs, optical discs, etc., including several instructions to make a computer device (which may be a personal computer, server, or network device, etc.) execute the methods described in various embodiments or some parts of the embodiments.
最后应说明的是:以上实施例仅用以说明本发明的技术方案,而非对其限制;尽管参照前述实施例对本发明进行了详细的说明,本领域的普通技术人员应当理解:其依然可以对前述各实施例所记载的技术方案进行修改,或者对其中部分技术特征进行等同替换;而这些修改或者替换,并不使相应技术方案的本质脱离本发明各实施例技术方案的精神和范围。Finally, it should be noted that: the above embodiments are only used to illustrate the technical solutions of the present invention, rather than to limit them; although the present invention has been described in detail with reference to the foregoing embodiments, those of ordinary skill in the art should understand that: it can still be Modifications are made to the technical solutions described in the foregoing embodiments, or equivalent replacements are made to some of the technical features; and these modifications or replacements do not make the essence of the corresponding technical solutions deviate from the spirit and scope of the technical solutions of the various embodiments of the present invention.
Claims (10)
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202310080004.4A CN116233256A (en) | 2023-01-29 | 2023-01-29 | Scheduling path configuration method, device, equipment and storage medium |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN202310080004.4A CN116233256A (en) | 2023-01-29 | 2023-01-29 | Scheduling path configuration method, device, equipment and storage medium |
Publications (1)
Publication Number | Publication Date |
---|---|
CN116233256A true CN116233256A (en) | 2023-06-06 |
Family
ID=86583794
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN202310080004.4A Pending CN116233256A (en) | 2023-01-29 | 2023-01-29 | Scheduling path configuration method, device, equipment and storage medium |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN116233256A (en) |
Cited By (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN116684418A (en) * | 2023-08-03 | 2023-09-01 | 北京神州泰岳软件股份有限公司 | Calculation power arrangement scheduling method, calculation power network and device based on calculation power service gateway |
CN116863408A (en) * | 2023-09-04 | 2023-10-10 | 成都智慧城市信息技术有限公司 | Parallel acceleration and dynamic scheduling implementation method based on monitoring camera AI algorithm |
CN117014636A (en) * | 2023-10-07 | 2023-11-07 | 中兴通讯股份有限公司 | Data stream scheduling method of audio and video network, storage medium and electronic device |
Citations (4)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN113315700A (en) * | 2020-02-26 | 2021-08-27 | 中国电信股份有限公司 | Computing resource scheduling method, device and storage medium |
WO2022127606A1 (en) * | 2020-12-18 | 2022-06-23 | 微网优联科技(成都)有限公司 | Adaptive cloud rendering system and method based on network communication quality |
CN114980250A (en) * | 2022-04-27 | 2022-08-30 | 山东浪潮科学研究院有限公司 | Computing power routing system and method based on SRv6 |
CN115562879A (en) * | 2022-12-06 | 2023-01-03 | 北京邮电大学 | Computing power sensing method, computing power sensing device, electronic device and storage medium |
-
2023
- 2023-01-29 CN CN202310080004.4A patent/CN116233256A/en active Pending
Patent Citations (4)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN113315700A (en) * | 2020-02-26 | 2021-08-27 | 中国电信股份有限公司 | Computing resource scheduling method, device and storage medium |
WO2022127606A1 (en) * | 2020-12-18 | 2022-06-23 | 微网优联科技(成都)有限公司 | Adaptive cloud rendering system and method based on network communication quality |
CN114980250A (en) * | 2022-04-27 | 2022-08-30 | 山东浪潮科学研究院有限公司 | Computing power routing system and method based on SRv6 |
CN115562879A (en) * | 2022-12-06 | 2023-01-03 | 北京邮电大学 | Computing power sensing method, computing power sensing device, electronic device and storage medium |
Non-Patent Citations (1)
Title |
---|
蔡岳平;李天驰;: "面向算力匹配调度的泛在确定性网络研究", 信息通信技术, no. 04, 15 August 2020 (2020-08-15) * |
Cited By (7)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN116684418A (en) * | 2023-08-03 | 2023-09-01 | 北京神州泰岳软件股份有限公司 | Calculation power arrangement scheduling method, calculation power network and device based on calculation power service gateway |
CN116684418B (en) * | 2023-08-03 | 2023-11-10 | 北京神州泰岳软件股份有限公司 | Calculation power arrangement scheduling method, calculation power network and device based on calculation power service gateway |
CN116863408A (en) * | 2023-09-04 | 2023-10-10 | 成都智慧城市信息技术有限公司 | Parallel acceleration and dynamic scheduling implementation method based on monitoring camera AI algorithm |
CN116863408B (en) * | 2023-09-04 | 2023-11-21 | 成都智慧城市信息技术有限公司 | Parallel acceleration and dynamic scheduling implementation method based on monitoring camera AI algorithm |
CN117014636A (en) * | 2023-10-07 | 2023-11-07 | 中兴通讯股份有限公司 | Data stream scheduling method of audio and video network, storage medium and electronic device |
CN117014636B (en) * | 2023-10-07 | 2024-03-19 | 中兴通讯股份有限公司 | Data stream scheduling method of audio and video network, storage medium and electronic device |
WO2025073205A1 (en) * | 2023-10-07 | 2025-04-10 | 中兴通讯股份有限公司 | Data stream scheduling method of audio and video network, storage medium, and electronic device |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN103746911B (en) | A kind of SDN structure and its communication means | |
EP3958521B1 (en) | Method and apparatus for providing service for service flow | |
CN107005462B (en) | Method, equipment and system for forwarding data in software defined network | |
CN103338150B (en) | Communication network architecture method for building up, device, server and router | |
CN109362085B (en) | Implementing EPC in cloud computer through OPENFLOW data plane | |
US9178831B2 (en) | Methods and apparatus for RBridge hop-by-hop compression and frame aggregation | |
CN116233256A (en) | Scheduling path configuration method, device, equipment and storage medium | |
WO2021207922A1 (en) | Packet transmission method, device, and system | |
US9736085B2 (en) | End-to end lossless Ethernet in Ethernet fabric | |
CN102136959B (en) | Ethernet link management method, device and system | |
US8325733B2 (en) | Method and system for layer 2 manipulator and forwarder | |
CN107306215B (en) | A data processing method, system and node | |
CN105591971A (en) | QoS implementation method and device | |
CN105075191B (en) | Wireless network data processing unit and Radio Network System | |
CN106161275A (en) | Prediction for service quality exports packet classification | |
CN106559302A (en) | Single tunnel method for building up, device and system | |
CN114826918B (en) | A message forwarding method, message processing method and device | |
US20240267324A1 (en) | Packet forwarding method and apparatus | |
CN103391245A (en) | Method and device for constructing multi-state routing in network domain as well as router | |
US20240322952A1 (en) | Packet loss management method and related apparatus | |
CN108092909A (en) | Data flow control method, apparatus and system | |
JP7298606B2 (en) | Communication system and communication method | |
US20220166721A1 (en) | Traffic balancing method, network device, and electronic device | |
EP1766876A4 (en) | METHOD OF TRANSFERRING DATA OVER A PACKET SWITCHED NETWORK | |
CN102918807B (en) | Method and routing equipment for BFD session establishment |
Legal Events
Date | Code | Title | Description |
---|---|---|---|
PB01 | Publication | ||
PB01 | Publication | ||
SE01 | Entry into force of request for substantive examination | ||
SE01 | Entry into force of request for substantive examination |