[go: up one dir, main page]

CN115002117B - Content distribution network dynamic scheduling method, system, device and storage medium - Google Patents

Content distribution network dynamic scheduling method, system, device and storage medium Download PDF

Info

Publication number
CN115002117B
CN115002117B CN202210601212.XA CN202210601212A CN115002117B CN 115002117 B CN115002117 B CN 115002117B CN 202210601212 A CN202210601212 A CN 202210601212A CN 115002117 B CN115002117 B CN 115002117B
Authority
CN
China
Prior art keywords
scheduling
node
trigger
content distribution
distribution network
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.)
Active
Application number
CN202210601212.XA
Other languages
Chinese (zh)
Other versions
CN115002117A (en
Inventor
戚剑锋
王广伟
谢庄淳
陈宽
张阳平
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
China Mobile Communications Group Co Ltd
China Mobile Hangzhou Information Technology Co Ltd
Original Assignee
China Mobile Communications Group Co Ltd
China Mobile Hangzhou Information Technology Co Ltd
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by China Mobile Communications Group Co Ltd, China Mobile Hangzhou Information Technology Co Ltd filed Critical China Mobile Communications Group Co Ltd
Priority to CN202210601212.XA priority Critical patent/CN115002117B/en
Publication of CN115002117A publication Critical patent/CN115002117A/en
Application granted granted Critical
Publication of CN115002117B publication Critical patent/CN115002117B/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Classifications

    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00Network arrangements or protocols for supporting network services or applications
    • H04L67/01Protocols
    • H04L67/10Protocols in which an application is distributed across nodes in the network
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L43/00Arrangements for monitoring or testing data switching networks
    • H04L43/08Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters
    • H04L43/0876Network utilisation, e.g. volume of load or congestion level
    • H04L43/0888Throughput

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Environmental & Geological Engineering (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)

Abstract

本申请公开了一种内容分发网络动态调度方法、系统、设备及存储介质,所述内容分发网络动态调度方法包括:获取根据业务需求配置的触发指标项和自定义调度规则,基于所述触发指标项以及所述自定义调度规则,生成若干个调度策略,其中,所述调度策略包括调度业务服务、指标触发条件和调入节点范围,若检测到目标节点对应的触发指标项满足触发条件时,触发并执行所述触发条件对应的调度策略,以将所述目标节点的调度业务服务调度至所述调入节点范围中的调入节点中。本申请解决了当业务服务发生变化,需要通过二次开发来调度策略来应对新的故障业务场景,导致用户的访问请求无法得到有效加速,影响用户使用体验的技术问题。

The present application discloses a content distribution network dynamic scheduling method, system, device and storage medium, the content distribution network dynamic scheduling method includes: obtaining trigger indicator items and custom scheduling rules configured according to business needs, generating several scheduling strategies based on the trigger indicator items and the custom scheduling rules, wherein the scheduling strategy includes scheduling business services, indicator trigger conditions and call-in node ranges, and if it is detected that the trigger indicator item corresponding to the target node meets the trigger condition, the scheduling strategy corresponding to the trigger condition is triggered and executed to schedule the scheduling business service of the target node to the call-in node in the call-in node range. The present application solves the technical problem that when business services change, it is necessary to use secondary development to schedule strategies to deal with new fault business scenarios, resulting in the inability to effectively accelerate user access requests, affecting the user experience.

Description

内容分发网络动态调度方法、系统、设备及存储介质Content distribution network dynamic scheduling method, system, device and storage medium

技术领域Technical Field

本申请涉及互联网技术领域,尤其涉及一种内容分发网络动态调度方法、系统、设备及存储介质。The present application relates to the field of Internet technology, and in particular to a content distribution network dynamic scheduling method, system, device and storage medium.

背景技术Background technique

目前,CDN(Content Delivery Network,内容分发网络)提供加速服务。以域名访问服务为例,具体的过程如下:CDN按地理位置或网络运营商规划CDN的边缘节点,用户访问域名时,可以从边缘节点实现域名访问。Currently, CDN (Content Delivery Network) provides acceleration services. Taking domain name access service as an example, the specific process is as follows: CDN plans CDN edge nodes according to geographical locations or network operators. When users access domain names, they can access domain names from edge nodes.

在现有CDN集群中每个边缘节点都由对应的监控设备进行服务监控,并将监控到的边缘节点的运行状态上报给调度系统。当发现某个边缘节点故障或者有个服务的业务量过大时,利用静态固定的调度策略将服务调度至附近其它可用的边缘节点上,然而,静态固定的调度策略无法适应业务服务的变化,可扩展性较差,需要通过二次开发来应对新的故障业务场景,从而导致用户的访问请求无法得到有效加速,影响用户使用体验。In the existing CDN cluster, each edge node is monitored by the corresponding monitoring equipment, and the operating status of the monitored edge node is reported to the scheduling system. When a certain edge node fails or the business volume of a service is too large, the service is scheduled to other available edge nodes nearby using a static fixed scheduling strategy. However, the static fixed scheduling strategy cannot adapt to changes in business services and has poor scalability. It requires secondary development to deal with new failure business scenarios, which results in the inability to effectively accelerate user access requests, affecting the user experience.

发明内容Summary of the invention

本申请的主要目的在于提供一种内容分发网络动态调度方法、系统、设备及存储介质,旨在解决现有技术中的当业务服务发生变化,需要通过二次开发来调度策略来应对新的故障业务场景,导致用户的访问请求无法得到有效加速,影响用户使用体验的技术问题。The main purpose of this application is to provide a content distribution network dynamic scheduling method, system, device and storage medium, aiming to solve the technical problem in the prior art that when business services change, secondary development is needed to schedule strategies to deal with new fault business scenarios, resulting in the inability to effectively accelerate user access requests, affecting the user experience.

为实现上述目的,本申请提供一种内容分发网络动态调度方法,所述内容分发网络动态调度方法包括:To achieve the above-mentioned purpose, the present application provides a content distribution network dynamic scheduling method, the content distribution network dynamic scheduling method comprising:

获取根据业务需求配置的触发指标项和自定义调度规则;Obtain trigger indicators and custom scheduling rules configured according to business needs;

基于所述触发指标项以及所述自定义调度规则,生成若干个调度策略,其中,所述调度策略包括调度业务服务、触发条件和调入节点范围;Based on the trigger indicator item and the custom scheduling rule, a plurality of scheduling strategies are generated, wherein the scheduling strategy includes a scheduling business service, a trigger condition and a call-in node range;

若检测到目标节点对应的触发指标项满足所述触发条件时,触发并执行所述触发条件对应的调度策略,以将所述目标节点的调度业务服务调度至所述调入节点范围中的调入节点中。If it is detected that the trigger indicator item corresponding to the target node meets the trigger condition, the scheduling policy corresponding to the trigger condition is triggered and executed to schedule the scheduling business service of the target node to the incoming node in the incoming node range.

本申请还提供一种内容分发网络动态调度系统,所述内容分发网络动态调度系统为虚拟系统,所述内容分发网络动态调度系统包括:The present application also provides a content distribution network dynamic scheduling system, wherein the content distribution network dynamic scheduling system is a virtual system, and the content distribution network dynamic scheduling system includes:

获取模块,用于获取根据业务需求配置的触发指标项和自定义调度规则;The acquisition module is used to obtain trigger indicator items and custom scheduling rules configured according to business needs;

策略生成模块,用于基于所述触发指标项以及所述自定义调度规则,生成若干个调度策略,其中,所述调度策略包括调度业务服务、指标触发条件和调入节点范围;A strategy generation module, used to generate a plurality of scheduling strategies based on the trigger indicator items and the custom scheduling rules, wherein the scheduling strategies include scheduling business services, indicator trigger conditions and call-in node ranges;

策略执行模块,用于若检测到目标节点对应的触发指标项满足触发条件时,触发并执行所述触发条件对应的调度策略,以将所述目标节点的调度业务服务调度至所述调入节点范围中的调入节点中。The policy execution module is used to trigger and execute the scheduling policy corresponding to the trigger condition if it is detected that the trigger indicator item corresponding to the target node meets the trigger condition, so as to schedule the scheduling business service of the target node to the incoming node in the incoming node range.

本申请还提供一种内容分发网络动态调度设备,所述内容分发网络动态调度设备为实体设备,所述内容分发网络动态调度设备包括:存储器、处理器以及存储在所述存储器上的内容分发网络动态调度程序,所述内容分发网络动态调度程序被所述处理器执行实现如上述的内容分发网络动态调度方法的步骤。The present application also provides a content distribution network dynamic scheduling device, which is a physical device. The content distribution network dynamic scheduling device includes: a memory, a processor, and a content distribution network dynamic scheduling program stored on the memory. The content distribution network dynamic scheduling program is executed by the processor to implement the steps of the content distribution network dynamic scheduling method as described above.

本申请还提供一种存储介质,所述存储介质为计算机可读存储介质,所述计算机可读存储介质上存储内容分发网络动态调度程序,所述内容分发网络动态调度程序被处理器执行实现如上述的内容分发网络动态调度方法的步骤。The present application also provides a storage medium, which is a computer-readable storage medium. The computer-readable storage medium stores a content distribution network dynamic scheduling program, and the content distribution network dynamic scheduling program is executed by a processor to implement the steps of the content distribution network dynamic scheduling method as described above.

本申请提供了一种内容分发网络动态调度方法、系统、设备及存储介质,本申请首先获取根据业务需求配置的触发指标项和自定义调度规则,进而基于所述触发指标项以及所述自定义调度规则,生成若干个调度策略,其中,所述调度策略包括调度业务服务、触发条件和调入节点范围,进一步地,若检测到目标节点对应的触发指标项满足所述触发条件时,触发并执行所述触发条件对应的调度策略,以将所述目标节点的调度业务服务调度至所述调入节点范围中的调入节点中,实现可基于实际的业务需求,自定义设置的调度规则以及自定义设置的触发指标项,从而自动生成调度策略,即使业务需求的服务发生变化时,也能够在线设置新业务所对应的调度规则以及触发指标项,也即,针对不同的业务采用对应的调度规则进行调度,可以满足每种业务的需求,适用场景更为广泛,进而当目标节点的触发指标项满足所述触发条件时,自动触发调度策略,从而将所述目标节点的调度业务服务调度至所述调入节点范围中的调入节点中。The present application provides a content distribution network dynamic scheduling method, system, device and storage medium. The present application first obtains trigger indicator items and custom scheduling rules configured according to business needs, and then generates several scheduling strategies based on the trigger indicator items and the custom scheduling rules, wherein the scheduling strategy includes scheduling business services, trigger conditions and call-in node ranges. Further, if it is detected that the trigger indicator item corresponding to the target node meets the trigger condition, the scheduling strategy corresponding to the trigger condition is triggered and executed to schedule the scheduling business service of the target node to the call-in node in the call-in node range, so that the scheduling rules and trigger indicator items set by the user can be customized based on actual business needs, so as to automatically generate scheduling strategies. Even if the service of the business needs changes, the scheduling rules and trigger indicator items corresponding to the new business can be set online. That is, the corresponding scheduling rules are used for scheduling for different businesses, which can meet the needs of each business and have a wider range of applicable scenarios. Then, when the trigger indicator item of the target node meets the trigger condition, the scheduling strategy is automatically triggered, so that the scheduling business service of the target node is scheduled to the call-in node in the call-in node range.

附图说明BRIEF DESCRIPTION OF THE DRAWINGS

此处的附图被并入说明书中并构成本说明书的一部分,示出了符合本申请的实施例,并与说明书一起用于解释本申请的原理。The accompanying drawings, which are incorporated in and constitute a part of this specification, illustrate embodiments consistent with the present application and, together with the description, serve to explain the principles of the present application.

为了更清楚地说明本申请实施例或现有技术中的技术方案,下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍,显而易见地,对于本领域默认技术人员而言,在不付出创造性劳动性的前提下,还可以根据这些附图获得其他的附图。In order to more clearly illustrate the technical solutions in the embodiments of the present application or the prior art, the drawings required for use in the embodiments or the description of the prior art will be briefly introduced below. Obviously, for those skilled in the art, other drawings can be obtained based on these drawings without any creative work.

图1为本申请内容分发网络动态调度方法第一实施例的流程示意图;FIG1 is a schematic diagram of a flow chart of a first embodiment of a method for dynamic scheduling of a content distribution network of the present application;

图2为本申请内容分发网络动态调度方法第二实施例的流程示意图;FIG2 is a flow chart of a second embodiment of a method for dynamic scheduling of a content distribution network according to the present application;

图3为本申请内容分发网络动态调度方法中进行调度原理图;FIG3 is a schematic diagram of scheduling in the content distribution network dynamic scheduling method of the present application;

图4为本申请实施例方案涉及的硬件运行环境的内容分发网络动态调度设备结构示意图;FIG4 is a schematic diagram of a content distribution network dynamic scheduling device structure in a hardware operating environment involved in an embodiment of the present application;

图5为本申请内容分发网络动态调度系统的功能模块示意图。FIG. 5 is a schematic diagram of the functional modules of the content distribution network dynamic scheduling system of the present application.

本发明目的的实现、功能特点及优点将结合实施例,参照附图做进一步说明。The realization of the purpose, functional features and advantages of the present invention will be further explained in conjunction with embodiments and with reference to the accompanying drawings.

具体实施方式Detailed ways

应当理解,此处所描述的具体实施例仅用以解释本申请,并不用于限定本申请。It should be understood that the specific embodiments described herein are only used to explain the present application and are not used to limit the present application.

本申请实施例提供一种内容分发网络动态调度方法,在本申请内容分发网络动态调度方法的第一实施例中,参照图1,所述内容分发网络动态调度方法包括:The present application provides a content distribution network dynamic scheduling method. In the first embodiment of the content distribution network dynamic scheduling method of the present application, referring to FIG. 1 , the content distribution network dynamic scheduling method includes:

步骤S10,获取根据业务需求配置的触发指标项和自定义调度规则;Step S10, obtaining trigger indicator items and custom scheduling rules configured according to business requirements;

在本实施例中,需要说明的是,所述触发指标项为用户自定义设置的指标信息,所述指标信息包括系统指标信息和业务指标信息以及网络指标信息,其中,所述系统指标信息包括CPU、内存以及磁盘等信息,所述业务指标信息包括业务域名的访问次数和访问成功率等信息,所述网络指标信息包括访问时延、下载效率以及吞吐量等网络性能信息。In this embodiment, it should be noted that the trigger indicator item is indicator information customized by the user, and the indicator information includes system indicator information, business indicator information and network indicator information, wherein the system indicator information includes information such as CPU, memory and disk, the business indicator information includes information such as the number of visits and access success rate of the business domain name, and the network indicator information includes network performance information such as access delay, download efficiency and throughput.

进一步需要说明的是,所述自定义调度规则包括触发指标项对应的指标阈值(也即,触发条件)、持续时间、策略影响范围以及调度业务服务,其中,策略影响范围为调度规则应用到的区域范围,例如,策略影响范围可设置大区(由相邻省份划分区域)、省份、区域中具体节点,例如,当策略影响范围为深圳市时,则实时检测深圳市内预设调度系统中各个节点的触发指标项,进一步地,所述调度业务服务可以理解为服务类型相同或不相同的每个具体服务,例如,一个业务域名对应一个域名访问服务,则不同服务可以指不同域名访问服务。It should be further explained that the custom scheduling rules include the indicator threshold (that is, triggering condition) corresponding to the trigger indicator item, duration, policy impact range and scheduling business service, wherein the policy impact range is the regional scope to which the scheduling rules are applied. For example, the policy impact range can be set to a large region (divided by adjacent provinces), a province, or a specific node in the region. For example, when the policy impact range is Shenzhen City, the trigger indicator items of each node in the preset scheduling system in Shenzhen City are detected in real time. Furthermore, the scheduling business service can be understood as each specific service with the same or different service types. For example, a business domain name corresponds to a domain name access service, and different services can refer to different domain name access services.

其中,所述获取根据业务需求配置的触发指标项和自定义调度规则的步包括:The step of obtaining trigger indicator items and custom scheduling rules configured according to business requirements includes:

步骤S11,获取预设调度系统中各节点对应的历史指标信息,其中,所述历史指标信息包括不同业务服务的系统指标信息、业务指标信息以及网络指标信息;Step S11, obtaining historical indicator information corresponding to each node in the preset scheduling system, wherein the historical indicator information includes system indicator information, business indicator information and network indicator information of different business services;

步骤S12,对所述系统指标信息、所述业务指标信息以及所述网络指标信息进行统计聚合处理,得到各整合指标信息,并将各所述整合指标信息存储在预设时序数据库中;Step S12, performing statistical aggregation processing on the system indicator information, the business indicator information and the network indicator information to obtain each integrated indicator information, and storing each integrated indicator information in a preset time series database;

步骤S13,根据所述业务需求,在所述时序数据库的各整合指标信息中至少选取一个指标项作为所述触发指标项,并获取根据所述触发指标项设置的自定义调度规则。Step S13: According to the business needs, at least one indicator item is selected from each integrated indicator information in the time series database as the trigger indicator item, and a custom scheduling rule set according to the trigger indicator item is obtained.

在本实施例中,作为一种可实施方式,具体地,为了预设调度系统中各个节点的指标信息,为每个节点至少设置一个监控指标信息的监控设备,其中,一个节点可以理解为CDN集群中对外提供网络服务的具备独立IP地址的一台边缘服务器,或者共用一个IP地址对外提供服务的一组服务器,进而收集通过所述监控设备监控到的历史指标信息,其中,所述历史指标信息包括不同业务服务的系统指标信息、业务指标信息以及网络指标信息,进而按照预设指标处理策略,分别对所述系统指标信息、所述业务指标信息以及所述网络指标信息进行统计聚合处理,得到各整合指标信息,并将各所述整合指标信息存储在预设时序数据库中,从而可在所述预设时序数据库中快速查询到整合指标信息,例如,统计节点上具体某一个业务服务每一小时的访问次数,访问流量、访问成功率以及访问时延等信息,也可将统计聚合每一天对应的访问次数,访问成功率以及访问时延等信息。In this embodiment, as a feasible implementation method, specifically, in order to preset the indicator information of each node in the scheduling system, at least one monitoring device for monitoring the indicator information is set for each node, wherein a node can be understood as an edge server with an independent IP address that provides network services to the outside in the CDN cluster, or a group of servers that share an IP address to provide services to the outside, and then collect historical indicator information monitored by the monitoring device, wherein the historical indicator information includes system indicator information, business indicator information and network indicator information of different business services, and then according to the preset indicator processing strategy, the system indicator information, the business indicator information and the network indicator information are statistically aggregated and processed respectively to obtain each integrated indicator information, and each integrated indicator information is stored in a preset time series database, so that the integrated indicator information can be quickly queried in the preset time series database, for example, the number of visits per hour, access traffic, access success rate and access delay of a specific business service on the statistical node, and the number of visits, access success rate and access delay corresponding to each day can also be statistically aggregated.

进一步地,根据实际的业务需求,在所述时序数据库的各整合指标信息中至少选取一个指标项作为所述触发指标项,并获取根据所述触发指标项设置的自定义调度规则,从而实现根据不同的业务需求,配置对应的触发指标项以及对应的调度规则,例如,选取具体业务服务的内存、访问流量以及访问时延三个指标项作为触发指标项,进而为三个指标项分别设置对应的调度规则。Furthermore, according to actual business needs, at least one indicator item is selected from each integrated indicator information of the time series database as the trigger indicator item, and a custom scheduling rule set according to the trigger indicator item is obtained, so as to configure corresponding trigger indicator items and corresponding scheduling rules according to different business needs. For example, three indicator items of memory, access traffic and access latency of a specific business service are selected as trigger indicator items, and then corresponding scheduling rules are set for the three indicator items respectively.

步骤S20,基于所述触发指标项以及所述自定义调度规则,生成若干个调度策略,其中,所述调度策略包括调度业务服务、触发条件和调入节点范围;Step S20, generating a plurality of scheduling strategies based on the trigger indicator item and the custom scheduling rule, wherein the scheduling strategy includes scheduling business services, trigger conditions and a call-in node range;

在本实施例中,需要说明的是,所述调入节点范围为将调度业务服务调入的区域范围,所述调度策略具体包括触发指标项、数值判断(等于、大于、小于等条件)、条件判断(且、或、非等条件)、条件的持续时间(例如,连续N个统计周期都满足触发条件)、指标项统计维度(节点、域名、通信线路等)。In this embodiment, it should be noted that the node range to be transferred in is the regional range to which the scheduling business service is transferred in, and the scheduling strategy specifically includes trigger indicator items, numerical judgments (equal to, greater than, less than, etc.), condition judgments (and, or, not, etc.), duration of conditions (for example, the trigger conditions are met for N consecutive statistical periods), and indicator item statistical dimensions (nodes, domain names, communication lines, etc.).

作为一种可实施方式,具体地,例如,选取某个具体业务服务的系统指标信息中的内存、业务指标信息中的访问流量以及网络指标信息中的访问时延三个指标项作为触发指标项,进而为三个指标项分别设置对应的调度规则,可基于将三个指标项与其对应的调度规则组合形成一个调度策略,也可将每一个指标项和其对应的调度规则生成一个调度策略,也可将一个节点中多个或全部业务服务,从而实现了针对不同的业务采用对应的调度规则进行调度,从而可以满足每种业务的需求,同时也可根据多种指标,即网络指标信息、系统指标信息和业务指标信息共同确定是否需要调度服务。As a feasible implementation method, specifically, for example, three indicator items, namely, memory in the system indicator information of a specific business service, access traffic in the business indicator information, and access delay in the network indicator information, are selected as trigger indicator items, and then corresponding scheduling rules are set for the three indicator items respectively. A scheduling strategy can be formed based on combining the three indicator items with their corresponding scheduling rules, or a scheduling strategy can be generated for each indicator item and its corresponding scheduling rule, or multiple or all business services in a node can be combined, thereby realizing scheduling according to corresponding scheduling rules for different businesses, so as to meet the needs of each business. At the same time, it can also be determined whether a scheduling service is needed based on multiple indicators, namely, network indicator information, system indicator information and business indicator information.

另外地,在确定调度策略之后,对各所述调度策略进行解析,得到对应的条件表达式,并将各所述条件表达式存储至预设规则数据库中,后续可直接在所述预设规则数据库中扫描执行对应的条件表达式。In addition, after determining the scheduling strategy, each scheduling strategy is parsed to obtain a corresponding conditional expression, and each conditional expression is stored in a preset rule database, and subsequently the corresponding conditional expression can be directly scanned and executed in the preset rule database.

步骤S30,若检测到目标节点对应的触发指标项满足所述触发条件时,触发并执行所述触发条件对应的调度策略,以将所述目标节点的调度业务服务调度至所述调入节点范围中的调入节点中。Step S30: If it is detected that the trigger indicator item corresponding to the target node meets the trigger condition, the scheduling strategy corresponding to the trigger condition is triggered and executed to schedule the scheduling business service of the target node to the incoming node in the incoming node range.

在本实施例中,需要说明的是,所述目标节点为所述自定义调度规则中策略影响范围内且满足触发条件的调离节点,具体地,在生成调度策略后,实时检测策略影响范围内各个目标节点的触发指标项,当存在目标节点上调度业务服务的触发指标项均满足所述触发条件时,触发并执行所述触发条件对应的调度策略,进一步地,当检测到存在多个目标节点的触发指标项均满足各所述条件表达式中的触发条件时,按照预设优先级排序规则将各所述调度策略进行排序,得到优先级排序序列,将按照所述优先级排序序列依次执行各个调度策略,例如,将节点故障的调度策略优先级设置为1,将业务流量超出的调度策略优先级设置为2,将业务服务网络质量差的调度策略优先级设置3,数字越小代表优先级最高。In this embodiment, it should be noted that the target node is a node that is within the policy influence range in the custom scheduling rule and that meets the trigger conditions. Specifically, after the scheduling policy is generated, the trigger indicator items of each target node within the policy influence range are detected in real time. When the trigger indicator items for scheduling business services on the target node all meet the trigger conditions, the scheduling policy corresponding to the trigger conditions is triggered and executed. Furthermore, when it is detected that the trigger indicator items of multiple target nodes all meet the trigger conditions in each of the conditional expressions, each of the scheduling policies is sorted according to a preset priority sorting rule to obtain a priority sorting sequence, and each scheduling policy is executed in sequence according to the priority sorting sequence. For example, the scheduling policy priority for node failure is set to 1, the scheduling policy priority for business traffic excess is set to 2, and the scheduling policy priority for poor business service network quality is set to 3. The smaller the number, the higher the priority.

进一步地,在触发并执行调度策略过程中,将所述目标节点的调度业务服务调度至所述调入节点范围中的调入节点中,在一种可实施方式中,由于调入节点范围中存在多个节点,可计算各个节点的剩余承载业务容量,进而根据各个剩余承载业务容量的大小,选取剩余承载业务容量最大的节点作为调入节点,从而将调度业务服务调度至所述调入节点中,其中,需要说明的是,所述调入节点范围可与所述目标节点同属于一个区域范围,也可与所述目标节点不属于一个区域范围,例如,将满足触发条件的目标节点属于深圳市,调入节点范围可设置在深圳市,从而将满足触发条件的目标节点的调度业务服务调度至深圳市的其他节点中,当将调入节点范围设置在广州市,将满足触发条件的目标节点的调度业务服务调度至广州市的其节点中。Furthermore, in the process of triggering and executing the scheduling strategy, the scheduling business service of the target node is scheduled to the call-in node in the call-in node range. In one feasible implementation mode, since there are multiple nodes in the call-in node range, the remaining carrying business capacity of each node can be calculated, and then according to the size of each remaining carrying business capacity, the node with the largest remaining carrying business capacity is selected as the call-in node, thereby scheduling the scheduling business service to the call-in node. It should be noted that the call-in node range may belong to the same regional range as the target node, or may not belong to the same regional range as the target node. For example, if the target node that meets the trigger condition belongs to Shenzhen City, the call-in node range may be set in Shenzhen City, thereby scheduling the scheduling business service of the target node that meets the trigger condition to other nodes in Shenzhen City. When the call-in node range is set in Guangzhou City, the scheduling business service of the target node that meets the trigger condition is scheduled to its node in Guangzhou City.

其中,若检测到目标节点对应的触发指标项满足所述触发条件时,触发并执行所述触发条件对应的调度策略,具体包括:If it is detected that the trigger indicator item corresponding to the target node meets the trigger condition, the scheduling strategy corresponding to the trigger condition is triggered and executed, specifically including:

步骤S31,采集所述策略影响范围内各个目标节点的触发指标项;Step S31, collecting trigger indicator items of each target node within the influence range of the strategy;

步骤S32,当检测到存在若干个目标节点的触发指标项均满足各所述条件表达式中的触发条件时,按照预设优先级排序规则将各所述调度策略进行排序,得到优先级排序序列;Step S32, when it is detected that the trigger indicator items of the plurality of target nodes all satisfy the trigger conditions in the conditional expressions, sorting the scheduling strategies according to a preset priority sorting rule to obtain a priority sorting sequence;

步骤S33,将按照所述优先级排序序列依次执行各个调度策略。Step S33, executing each scheduling strategy in sequence according to the priority sorting sequence.

在本实施例中,具体地,通过监控设备实时检测所述策略影响范围内各个目标节点的触发指标项所对应的信息,当检测到存在目标节点的触发指标项满足条件表达式中的触发条件,则直接触发执行所述触发条件对的调度策略,当检测到存在多个目标节点的触发指标项满足条件表达式中的触发条件,则需将对应的各个调度策略进行优先级排序,进而按照优先级排序序列依次执行各个调度策略。In this embodiment, specifically, the information corresponding to the trigger indicator items of each target node within the influence range of the strategy is detected in real time by a monitoring device. When it is detected that the trigger indicator items of the target node meet the trigger conditions in the conditional expression, the scheduling strategy for the trigger condition pair is directly triggered to execute. When it is detected that the trigger indicator items of multiple target nodes meet the trigger conditions in the conditional expression, the corresponding scheduling strategies need to be prioritized, and then each scheduling strategy is executed in sequence according to the priority sorting sequence.

本申请实施例通过上述方案,也即,获取根据业务需求配置的触发指标项和自定义调度规则,进而基于所述触发指标项以及所述自定义调度规则,生成若干个调度策略,其中,所述调度策略包括调度业务服务、触发条件和调入节点范围,进一步地,若检测到目标节点对应的触发指标项满足所述触发条件时,触发并执行所述触发条件对应的调度策略,以将所述目标节点的调度业务服务调度至所述调入节点范围中的调入节点中,实现可基于自定义设置的调度规则以及自定义设置的触发指标项,自动生成调度策略,即使业务服务发生变化时,也能够在线设置新的调度规则以及触发指标项,适用场景较为广泛,进而当目标节点的触发指标项满足所述触发条件时,自动触发调度策略,从而将所述目标节点的调度业务服务调度至所述调入节点范围中的调入节点中。The embodiment of the present application adopts the above scheme, that is, obtains trigger indicator items and custom scheduling rules configured according to business needs, and then generates several scheduling strategies based on the trigger indicator items and the custom scheduling rules, wherein the scheduling strategy includes scheduling business services, trigger conditions and call-in node ranges. Furthermore, if it is detected that the trigger indicator item corresponding to the target node satisfies the trigger condition, the scheduling strategy corresponding to the trigger condition is triggered and executed to schedule the scheduling business service of the target node to the call-in node in the call-in node range, so that the scheduling strategy can be automatically generated based on the custom-set scheduling rules and the custom-set trigger indicator items. Even if the business service changes, new scheduling rules and trigger indicator items can be set online, and the applicable scenarios are relatively wide. When the trigger indicator item of the target node satisfies the trigger condition, the scheduling strategy is automatically triggered, so that the scheduling business service of the target node is scheduled to the call-in node in the call-in node range.

进一步地,参照图2,基于本申请中第一实施例,在本申请的另一实施例中,在所述将所述目标节点的调度业务服务调度至所述调入节点范围中的调入节点中的步骤之后,还包括:Further, referring to FIG. 2 , based on the first embodiment of the present application, in another embodiment of the present application, after the step of scheduling the scheduling service of the target node to the incoming node in the incoming node range, it also includes:

步骤A10,基于所述目标节点的历史指标信息,计算在预选时间内所述目标节点上的调度业务服务的历史访问流量峰值;Step A10, calculating the historical access traffic peak value of the scheduling business service on the target node within a preselected time based on the historical indicator information of the target node;

在本实施例中,需要说明的是,所述历史指标信息为通过监控设备检测到的系统指标信息、业务指标信息以及网络指标信息,所述预设时间为人工根据实际情况设置的,例如,将所述预设时间设置为7天,具体地,基于所述目标节点的历史指标信息,确定在预选时间内每一天所述目标节点上的调度业务服务的流量峰值,进一步地,选取峰值最高的流量峰值作为所述目标节点上的调度业务服务的历史访问流量峰值。In this embodiment, it should be noted that the historical indicator information is system indicator information, business indicator information and network indicator information detected by the monitoring equipment, and the preset time is set manually according to the actual situation. For example, the preset time is set to 7 days. Specifically, based on the historical indicator information of the target node, the traffic peak of the scheduling business service on the target node is determined every day within the preselected time, and further, the traffic peak with the highest peak value is selected as the historical access traffic peak of the scheduling business service on the target node.

步骤A20,在执行所述动态调度策略后,检测所述调入节点的节点实时带宽,以及确定调入节点的剩余承载业务容量;Step A20, after executing the dynamic scheduling strategy, detecting the node real-time bandwidth of the incoming node, and determining the remaining bearer service capacity of the incoming node;

步骤A30,基于所述历史访问流量峰值以及所述节点实时带宽之间的大小,确定所述调出访问流量;Step A30, determining the outgoing access traffic based on the historical access traffic peak value and the node real-time bandwidth;

步骤A40,基于所述剩余承载业务容量,判断所述调入节点是否能够承载所述调度业务服务的调出访问流量;Step A40, based on the remaining bearer service capacity, determining whether the incoming node can bear the outgoing access traffic of the scheduling service;

步骤A50,若是,则确定调度成功;Step A50, if yes, then determine that the scheduling is successful;

步骤A60,若是,则基于所述调入节点范围中的其他调入节点,确定加入调度节点;按照预设流量调度方法将所述目标节点的调度业务服务调度至所述加入调度节点,并返回执行步骤:在执行所述动态调度策略后,检测所述调入节点的节点实时带宽,以及确定所述调入节点的剩余承载业务容量。Step A60, if yes, determine the joining scheduling node based on other joining nodes in the joining node range; schedule the scheduling business service of the target node to the joining scheduling node according to the preset traffic scheduling method, and return to the execution step: after executing the dynamic scheduling strategy, detect the node real-time bandwidth of the joining node, and determine the remaining carrying business capacity of the joining node.

在本实施例中,具体地,将所述目标节点的调度业务服务调度至所述调入节点范围中的调入节点中之后,实时检测所述调入节点上调度业务服务调度的节点实时带宽,基于所述历史访问流量峰值以及所述节点实时带宽之间的大小,确定所述调出访问流量,进一步地,基于所述剩余承载业务容量和预设剩余比例,判断所述调入节点是否能够承载所述调度业务服务的调出访问流量,若是,则确定调度成功,进而将所述调度业务服务调度至所述调入节点中,若否,则基于所述调入节点范围中的其他调入节点,选取加入调度节点,按照预设流量调度方法将所述目标节点的调度业务服务调度分别至所述新加入的加入调度节点以及调度节点中,例如,将所述调度业务服务的调出访问流量平均分配给加入调度节点以及调度节点,或者按照预设分配比例将所述调度业务服务的调出访问流量平均分配给加入调度节点以及调度节点,所述预设分配比例可按照实际情况设置,在此不做具体限制,进而返回执行步骤:在执行所述动态调度策略后,检测所述调入节点的节点实时带宽,以及确定所述调入节点的剩余承载业务容量,从而进一步判断所述调入节点以及所述加入调度节点是否能够承载所述调度业务服务的调出访问流量,直至加入了所述调入节点范围的全部调入节点或者确定承载所述调度业务服务的调出访问流量,例如,历史访问流量峰值为A,所述节点实时带宽为B,调入节点的剩余承载业务容量记为C,需要预留的比例(预设剩余比例)为a(0<=a<=1),若max(A,B)<=C*(1-a),则表示能够承载所述调度业务服务的调出访问流量。In this embodiment, specifically, after the scheduling business service of the target node is scheduled to the call-in node in the call-in node range, the node real-time bandwidth of the scheduling business service on the call-in node is detected in real time, and the outgoing access traffic is determined based on the size between the historical access traffic peak and the node real-time bandwidth. Further, based on the remaining carrying business capacity and the preset remaining ratio, it is determined whether the call-in node can carry the outgoing access traffic of the scheduling business service. If so, it is determined that the scheduling is successful, and then the scheduling business service is scheduled to the call-in node. If not, based on other call-in nodes in the call-in node range, a joining scheduling node is selected, and the scheduling business service of the target node is scheduled to the newly added joining scheduling node and the scheduling node respectively according to the preset traffic scheduling method. For example, the outgoing access traffic of the scheduling business service is evenly distributed to the joining scheduling node and the scheduling node, or according to The preset allocation ratio evenly distributes the outgoing access traffic of the scheduling business service to the joining scheduling node and the scheduling node. The preset allocation ratio can be set according to the actual situation and is not specifically limited here. Then return to the execution step: after executing the dynamic scheduling strategy, detect the node real-time bandwidth of the calling-in node, and determine the remaining carrying service capacity of the calling-in node, so as to further judge whether the calling-in node and the joining scheduling node can carry the outgoing access traffic of the scheduling business service, until all the calling-in nodes in the calling-in node range are added or the calling-in access traffic carrying the scheduling business service is determined. For example, the historical access traffic peak is A, the node real-time bandwidth is B, and the remaining carrying service capacity of the calling-in node is recorded as C. The proportion to be reserved (the preset remaining proportion) is a (0<=a<=1). If max(A, B)<=C*(1-a), it means that the calling-in node and the joining scheduling node can carry the calling-out access traffic of the scheduling business service.

其中,在所述按照预设流量调度方法将所述目标节点的调度业务服务调度至所述加入调度节点,并返回执行步骤:在执行所述动态调度策略后,检测所述调入节点的节点实时带宽,以及确定调入节点的剩余承载业务容量的步骤之后,还包括;Wherein, after the step of dispatching the dispatching service of the target node to the joining dispatching node according to the preset traffic dispatching method and returning to the execution step: after executing the dynamic dispatching strategy, detecting the node real-time bandwidth of the incoming node, and determining the remaining bearer service capacity of the incoming node, it also includes;

步骤b,若检测到所述调入节点范围中的全部调入节点对应的剩余承载业务容量无法承载所述调度业务服务的调出访问流量,则确定所述调度策略调度失败,并发出警告信息。Step b: If it is detected that the remaining bearer service capacity corresponding to all the incoming nodes in the incoming node range cannot bear the outgoing access traffic of the scheduling service, it is determined that the scheduling policy scheduling fails and a warning message is issued.

在本实施例中,具体地,方检测到加入了全部调入节点均无法承载所述调度业务服务的调出访问流量,确定所述调度策略调度失败,并发出警告信息,从而提醒用户进行修改调度策略。In this embodiment, specifically, the party detects that all incoming nodes cannot carry the outgoing access traffic of the scheduling business service, determines that the scheduling policy scheduling fails, and issues a warning message to remind the user to modify the scheduling policy.

本申请实施例通过上述方案,实现了在执行调度策略时,充分考虑调入节点的承载能力,避免故障调入超出调入节点承载能力后,导致用户访问服务时发生响应失败或响应慢、故障节点扩散的连锁问题。Through the above scheme, the embodiment of the present application fully considers the carrying capacity of the incoming node when executing the scheduling strategy, avoiding the chain problem of response failure or slow response and the spread of faulty nodes when users access the service due to the faulty incoming node exceeding the carrying capacity of the incoming node.

参照图3,图3为本申请内容分发网络动态调度方法中进行调度原理图,其中,01为策略影响范围,策略影响范围中包括A、B和C三个节点,02为调入节点范围,调入节点范围包括D、E、F和G四个调入节点,实时检测策略影响范围内各个节点的触发指标项,当检测到C节点的触发指标项满足触发条件时,触发并执行对应的调度策略,可随机选取调入节点范围内的C节点作为调入节点,进而将A节点的调度业务服务调度至所述C节点上,或者基于调入节点范围内各个节点的剩余承载容量,选取剩余承载容量最高的节点作为调入节点,假设剩余承载容量大小关系为:D>E>F>G,进一步地,在进行调度过程中,判断当前调入节点的剩余承载容量是否能够承载A节点上调度业务服务的调出业务流量,若能够承载,则确定调度成功,若无法承载,则继续从调入节点范围中选取E节点,进而将A节点上调度业务服务调度至C和E节点上,返回判断是否能够承载A节点上调度业务服务的调出业务流量的步骤,直至加入调入节点范围内的全部节点,若调入节点范围内的全部节点仍无法承载A节点上调度业务服务的调出业务流量,则确定调度失败,进而发出警报信息。Refer to Figure 3, which is a scheduling principle diagram for the content distribution network dynamic scheduling method of the present application, wherein 01 is the policy influence range, which includes three nodes A, B and C, 02 is the call-in node range, which includes four call-in nodes D, E, F and G, and the trigger index items of each node within the policy influence range are detected in real time. When it is detected that the trigger index item of the C node meets the trigger condition, the corresponding scheduling strategy is triggered and executed. The C node within the call-in node range can be randomly selected as the call-in node, and then the scheduling business service of the A node can be scheduled to the C node, or based on the remaining carrying capacity of each node within the call-in node range, the node with the highest remaining carrying capacity is selected as the call-in node. Node, assuming that the relationship between the remaining carrying capacity is: D>E>F>G. Further, during the scheduling process, determine whether the remaining carrying capacity of the current incoming node can carry the outgoing business traffic of the scheduled business service on node A. If it can, the scheduling is determined to be successful. If it cannot, continue to select E node from the incoming node range, and then schedule the scheduled business service on node A to nodes C and E, and return to the step of determining whether it can carry the outgoing business traffic of the scheduled business service on node A, until all nodes within the incoming node range are added. If all nodes within the incoming node range still cannot carry the outgoing business traffic of the scheduled business service on node A, the scheduling is determined to have failed, and an alarm message is issued.

参照图4,图4是本申请实施例方案涉及的硬件运行环境的内容分发网络动态调度设备结构示意图。Refer to Figure 4, which is a schematic diagram of the structure of a content distribution network dynamic scheduling device in a hardware operating environment involved in an embodiment of the present application.

如图4所示,该内容分发网络动态调度设备可以包括:处理器1001,例如CPU,存储器1005,通信总线1002。其中,通信总线1002用于实现处理器1001和存储器1005之间的连接通信。存储器1005可以是高速RAM存储器,也可以是稳定的存储器(non-volatile memory),例如磁盘存储器。存储器1005可选的还可以是独立于前述处理器1001的存储设备。As shown in FIG4 , the content distribution network dynamic scheduling device may include: a processor 1001, such as a CPU, a memory 1005, and a communication bus 1002. The communication bus 1002 is used to realize the connection and communication between the processor 1001 and the memory 1005. The memory 1005 may be a high-speed RAM memory or a stable memory (non-volatile memory), such as a disk memory. The memory 1005 may also be a storage device independent of the aforementioned processor 1001.

可选地,该内容分发网络动态调度设备还可以包括矩形用户接口、网络接口、相机、RF(Radio Frequency,射频)电路,传感器、音频电路、WiFi模块等等。矩形用户接口可以包括显示屏(Display)、输入子模块比如键盘(Keyboard),可选矩形用户接口还可以包括标准的有线接口、无线接口。网络接口可选的可包括标准的有线接口、无线接口(如WIFI接口)。Optionally, the content distribution network dynamic scheduling device may also include a rectangular user interface, a network interface, a camera, an RF (Radio Frequency) circuit, a sensor, an audio circuit, a WiFi module, etc. The rectangular user interface may include a display screen (Display), an input submodule such as a keyboard (Keyboard), and the optional rectangular user interface may also include a standard wired interface and a wireless interface. The network interface may optionally include a standard wired interface and a wireless interface (such as a WIFI interface).

本领域技术人员可以理解,图4中示出的内容分发网络动态调度设备结构并不构成对内容分发网络动态调度设备的限定,可以包括比图示更多或更少的部件,或者组合某些部件,或者不同的部件布置。Those skilled in the art will appreciate that the content distribution network dynamic scheduling device structure shown in FIG. 4 does not constitute a limitation on the content distribution network dynamic scheduling device, and may include more or fewer components than shown in the figure, or a combination of certain components, or a different arrangement of components.

如图4所示,作为一种计算机存储介质的存储器1005中可以包括操作系统、网络通信模块以及内容分发网络动态调度程序。操作系统是管理和控制内容分发网络动态调度设备硬件和软件资源的程序,支持内容分发网络动态调度程序以及其它软件和/或程序的运行。网络通信模块用于实现存储器1005内部各组件之间的通信,以及与内容分发网络动态调度系统中其它硬件和软件之间通信。As shown in FIG4 , the memory 1005 as a computer storage medium may include an operating system, a network communication module, and a content distribution network dynamic scheduling program. The operating system is a program that manages and controls the hardware and software resources of the content distribution network dynamic scheduling device, and supports the operation of the content distribution network dynamic scheduling program and other software and/or programs. The network communication module is used to realize the communication between the components inside the memory 1005, and to communicate with other hardware and software in the content distribution network dynamic scheduling system.

在图4所示的内容分发网络动态调度设备中,处理器1001用于执行存储器1005中存储的内容分发网络动态调度程序,实现上述任一项所述的内容分发网络动态调度方法的步骤。In the content distribution network dynamic scheduling device shown in FIG. 4 , the processor 1001 is used to execute the content distribution network dynamic scheduling program stored in the memory 1005 to implement the steps of any of the above-mentioned content distribution network dynamic scheduling methods.

本申请内容分发网络动态调度设备具体实施方式与上述内容分发网络动态调度方法各实施例基本相同,在此不再赘述。The specific implementation of the content distribution network dynamic scheduling device of the present application is basically the same as the embodiments of the content distribution network dynamic scheduling method described above, and will not be repeated here.

此外,请参照图5,图5是本申请内容分发网络动态调度系统的功能模块示意图,本申请还提供一种内容分发网络动态调度系统,所述内容分发网络动态调度系统包括:In addition, please refer to FIG. 5 , which is a schematic diagram of the functional modules of the content distribution network dynamic scheduling system of the present application. The present application also provides a content distribution network dynamic scheduling system, and the content distribution network dynamic scheduling system includes:

获取模块,用于获取根据业务需求配置的触发指标项和自定义调度规则;The acquisition module is used to obtain trigger indicator items and custom scheduling rules configured according to business needs;

策略生成模块,用于基于所述触发指标项以及所述自定义调度规则,生成若干个调度策略,其中,所述调度策略包括调度业务服务、指标触发条件和调入节点范围;A strategy generation module, used to generate a plurality of scheduling strategies based on the trigger indicator items and the custom scheduling rules, wherein the scheduling strategies include scheduling business services, indicator trigger conditions and call-in node ranges;

策略执行模块,用于若检测到目标节点对应的触发指标项满足触发条件时,触发并执行所述触发条件对应的调度策略,以将所述目标节点的调度业务服务调度至所述调入节点范围中的调入节点中。The policy execution module is used to trigger and execute the scheduling policy corresponding to the trigger condition if it is detected that the trigger indicator item corresponding to the target node meets the trigger condition, so as to schedule the scheduling business service of the target node to the incoming node in the incoming node range.

可选地,所述获取模块还用于:Optionally, the acquisition module is further used for:

获取预设调度系统中各节点对应的历史指标信息,其中,所述历史指标信息包括不同业务服务的系统指标信息、业务指标信息以及网络指标信息;Obtaining historical indicator information corresponding to each node in the preset scheduling system, wherein the historical indicator information includes system indicator information, business indicator information and network indicator information of different business services;

对所述系统指标信息、所述业务指标信息以及所述网络指标信息进行统计聚合处理,得到各整合指标信息,并将各所述整合指标信息存储在预设时序数据库中;Performing statistical aggregation processing on the system indicator information, the service indicator information and the network indicator information to obtain each integrated indicator information, and storing each integrated indicator information in a preset time series database;

根据所述业务需求,在所述时序数据库的各整合指标信息中至少选取一个指标项作为所述触发指标项,并获取根据所述触发指标项设置的自定义调度规则。According to the business requirements, at least one indicator item is selected from each integrated indicator information in the time series database as the trigger indicator item, and a custom scheduling rule set according to the trigger indicator item is obtained.

可选地,所述内容分发网络动态调度系统还用于:Optionally, the content distribution network dynamic scheduling system is further used for:

基于所述目标节点的历史指标信息,计算在预选时间内所述目标节点上的调度业务服务的历史访问流量峰值;Based on the historical indicator information of the target node, calculate the historical access traffic peak value of the scheduling business service on the target node within a preselected time;

在执行所述动态调度策略后,检测所述调入节点的节点实时带宽,以及确定调入节点的剩余承载业务容量;After executing the dynamic scheduling strategy, detecting the node real-time bandwidth of the incoming node, and determining the remaining bearer service capacity of the incoming node;

基于所述历史访问流量峰值以及所述节点实时带宽之间的大小,确定调出访问流量;Determine the outgoing access traffic based on the historical access traffic peak value and the node real-time bandwidth;

基于所述剩余承载业务容量,判断所述调入节点是否能够承载所述调度业务服务的调出访问流量;Based on the remaining bearer service capacity, determining whether the incoming node can bear the outgoing access traffic of the scheduling service;

若是,则确定调度成功;If so, it is determined that the scheduling is successful;

若否,则基于所述调入节点范围中的其他调入节点,确定加入调度节点;按照预设流量调度方法将所述目标节点的调度业务服务调度至所述加入调度节点,并返回执行步骤:在执行所述动态调度策略后,检测所述调入节点的节点实时带宽,以及确定所述调入节点的剩余承载业务容量。If not, determine the joining scheduling node based on other joining nodes in the joining node range; schedule the scheduling business service of the target node to the joining scheduling node according to the preset traffic scheduling method, and return to the execution step: after executing the dynamic scheduling strategy, detect the node real-time bandwidth of the joining node, and determine the remaining carrying business capacity of the joining node.

可选地,所述内容分发网络动态调度系统还用于:Optionally, the content distribution network dynamic scheduling system is further used for:

若检测到所述调入节点范围中的全部调入节点对应的剩余承载业务容量无法承载所述调度业务服务的调出访问流量,则确定所述调度策略调度失败,并发出警告信息。If it is detected that the remaining bearer service capacity corresponding to all the incoming nodes in the incoming node range cannot bear the outgoing access traffic of the scheduling service, it is determined that the scheduling policy scheduling fails and a warning message is issued.

可选地,所述内容分发网络动态调度系统还用于:Optionally, the content distribution network dynamic scheduling system is further used for:

对各所述调度策略进行解析,得到对应的条件表达式,并将各所述条件表达式存储至预设规则数据库中。Each of the scheduling strategies is parsed to obtain a corresponding conditional expression, and each of the conditional expressions is stored in a preset rule database.

可选地,所述策略执行模块还用于:Optionally, the policy execution module is further used to:

采集所述策略影响范围内各个目标节点的触发指标项;Collect trigger indicator items of each target node within the scope of influence of the strategy;

当检测到存在若干个目标节点的触发指标项均满足各所述条件表达式中的触发条件时,按照预设优先级排序规则将各所述调度策略进行排序,得到优先级排序序列;When it is detected that the trigger indicator items of several target nodes all satisfy the trigger conditions in the conditional expressions, sorting the scheduling strategies according to the preset priority sorting rules to obtain a priority sorting sequence;

将按照所述优先级排序序列依次执行各个调度策略。Each scheduling strategy will be executed in turn according to the priority sorting sequence.

本申请内容分发网络动态调度系统的具体实施方式与上述内容分发网络动态调度方法各实施例基本相同,在此不再赘述。The specific implementation of the content distribution network dynamic scheduling system of the present application is basically the same as the various embodiments of the content distribution network dynamic scheduling method described above, and will not be repeated here.

本申请实施例提供了一种存储介质,所述存储介质为计算机可读存储介质,且所述计算机可读存储介质存储有一个或者一个以上程序,所述一个或者一个以上程序还可被一个或者一个以上的处理器执行以用于实现上述任一项所述的内容分发网络动态调度方法的步骤。An embodiment of the present application provides a storage medium, which is a computer-readable storage medium, and the computer-readable storage medium stores one or more programs, and the one or more programs can also be executed by one or more processors to implement the steps of the content distribution network dynamic scheduling method described in any one of the above items.

本申请计算机可读存储介质具体实施方式与上述内容分发网络动态调度方法各实施例基本相同,在此不再赘述。The specific implementation of the computer-readable storage medium of the present application is basically the same as the embodiments of the above-mentioned content distribution network dynamic scheduling method, and will not be repeated here.

以上仅为本申请的优选实施例,并非因此限制本申请的专利范围,凡是利用本申请说明书及附图内容所作的等效结构或等效流程变换,或直接或间接运用在其他相关的技术领域,均同理包括在本申请的专利处理范围内。The above are only preferred embodiments of the present application, and are not intended to limit the patent scope of the present application. Any equivalent structure or equivalent process transformation made using the contents of the present application specification and drawings, or directly or indirectly applied in other related technical fields, are also included in the patent processing scope of the present application.

Claims (9)

1. A method for dynamically scheduling a content distribution network, the method comprising:
acquiring a trigger index item configured according to service requirements and a custom scheduling rule;
generating a plurality of scheduling strategies based on the triggering index items and the self-defined scheduling rules, wherein the scheduling strategies comprise scheduling business services, triggering conditions and scheduling node ranges;
Triggering and executing a scheduling strategy corresponding to the triggering condition when the triggering index item corresponding to the target node is detected to meet the triggering condition, so as to schedule the scheduling service of the target node to a scheduling node in the range of the scheduling node;
the step of obtaining the trigger index item and the custom scheduling rule configured according to the service requirement comprises the following steps:
Acquiring historical index information corresponding to each node in a preset scheduling system, wherein the historical index information comprises system index information, business index information and network index information of different business services;
carrying out statistical aggregation processing on the system index information, the business index information and the network index information to obtain each piece of integrated index information, and storing each piece of integrated index information in a preset time sequence database;
And according to the service demand, at least one index item is selected from the integrated index information of the time sequence database as the trigger index item, and a self-defined scheduling rule set according to the trigger index item is obtained.
2. The method of dynamic scheduling of a content distribution network according to claim 1, further comprising, after the step of scheduling the scheduled traffic service of the target node into a scheduling node in the range of scheduling nodes:
calculating a historical access flow peak of the scheduling business service on the target node in a preselected time based on the historical index information of the target node;
after executing the dynamic scheduling strategy, detecting the node real-time bandwidth of the scheduling node, and determining the residual bearing service capacity of the scheduling node;
determining call-out access flow based on the magnitude between the historical access flow peak value and the node real-time bandwidth;
judging whether the calling-in node can bear calling-out access flow of the dispatching business service or not based on the residual bearing business capacity;
If yes, determining that the dispatching is successful;
If not, determining to add a scheduling node based on other scheduling nodes in the range of the scheduling node; scheduling the scheduling service of the target node to the joining scheduling node according to a preset traffic scheduling method, and returning to the execution step: after executing the dynamic scheduling policy, detecting the node real-time bandwidth of the scheduling node, and determining the residual bearing service capacity of the scheduling node.
3. The dynamic scheduling method of content delivery network according to claim 2, wherein, when the scheduling service of the target node is scheduled to the joining scheduling node according to a preset traffic scheduling method, the execution step is returned to: after the step of detecting the node real-time bandwidth of the scheduling node and determining the remaining bearer service capacity of the scheduling node after executing the dynamic scheduling policy, the method further comprises:
If the residual bearing service capacity corresponding to all the calling nodes in the calling node range is detected to be unable to bear the calling access flow of the dispatching service, determining that the dispatching strategy fails to dispatch, and sending out warning information.
4. The method for dynamic scheduling of a content distribution network according to claim 1, further comprising, after the step of generating a plurality of scheduling policies based on the trigger metrics and the custom scheduling rules:
Analyzing each scheduling strategy to obtain a corresponding conditional expression, and storing each conditional expression into a preset rule database.
5. The method for dynamic scheduling of a content distribution network according to claim 4, wherein the scheduling policy further comprises a policy scope of influence.
6. The method for dynamic scheduling of a content distribution network according to claim 5, wherein when it is detected that the trigger indicator item corresponding to the target node satisfies the trigger condition, the step of triggering and executing the scheduling policy corresponding to the trigger condition includes:
collecting trigger index items of all target nodes in the policy influence range;
When detecting that the trigger index items of a plurality of target nodes all meet the trigger conditions in the conditional expressions, sequencing the scheduling strategies according to a preset priority sequencing rule to obtain a priority sequencing sequence;
And executing each scheduling strategy in turn according to the priority ordering sequence.
7. A content distribution network dynamic scheduling system, the content distribution network dynamic scheduling system comprising:
the acquisition module is used for acquiring the trigger index item configured according to the service requirement and the custom scheduling rule;
The strategy generation module is used for generating a plurality of scheduling strategies based on the trigger index item and the custom scheduling rule, wherein the scheduling strategies comprise scheduling business service, index trigger conditions and a scheduling node range;
the strategy execution module is used for triggering and executing a scheduling strategy corresponding to the triggering condition when the triggering index item corresponding to the target node is detected to meet the triggering condition, so as to schedule the scheduling service of the target node to the scheduling node in the range of the scheduling node;
The acquisition module is further used for acquiring historical index information corresponding to each node in a preset scheduling system, wherein the historical index information comprises system index information, business index information and network index information of different business services;
carrying out statistical aggregation processing on the system index information, the business index information and the network index information to obtain each piece of integrated index information, and storing each piece of integrated index information in a preset time sequence database;
And according to the service demand, at least one index item is selected from the integrated index information of the time sequence database as the trigger index item, and a self-defined scheduling rule set according to the trigger index item is obtained.
8. A content distribution network dynamic scheduling apparatus, characterized in that the content distribution network dynamic scheduling apparatus comprises: memory, a processor and a content distribution network dynamic scheduler stored on the memory,
The content distribution network dynamic scheduling program performs the steps of implementing the content distribution network dynamic scheduling method according to any one of claims 1 to 6 by the processor.
9. A storage medium, which is a computer readable storage medium, wherein a content distribution network dynamic scheduler is stored on the computer readable storage medium, the content distribution network dynamic scheduler being executed by a processor to implement the steps of the content distribution network dynamic scheduling method according to any one of claims 1 to 6.
CN202210601212.XA 2022-05-30 2022-05-30 Content distribution network dynamic scheduling method, system, device and storage medium Active CN115002117B (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202210601212.XA CN115002117B (en) 2022-05-30 2022-05-30 Content distribution network dynamic scheduling method, system, device and storage medium

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202210601212.XA CN115002117B (en) 2022-05-30 2022-05-30 Content distribution network dynamic scheduling method, system, device and storage medium

Publications (2)

Publication Number Publication Date
CN115002117A CN115002117A (en) 2022-09-02
CN115002117B true CN115002117B (en) 2024-06-18

Family

ID=83032104

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202210601212.XA Active CN115002117B (en) 2022-05-30 2022-05-30 Content distribution network dynamic scheduling method, system, device and storage medium

Country Status (1)

Country Link
CN (1) CN115002117B (en)

Families Citing this family (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN116132377A (en) * 2022-09-26 2023-05-16 北京有竹居网络技术有限公司 Flow scheduling method, device, system, terminal equipment and readable storage medium
CN115766876B (en) * 2022-11-22 2024-08-23 中国联合网络通信集团有限公司 Resource scheduling method, device, equipment and storage medium

Citations (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN113301078A (en) * 2020-05-22 2021-08-24 阿里巴巴集团控股有限公司 Network system, service deployment and network division method, device and storage medium

Family Cites Families (11)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US8762304B2 (en) * 2009-11-03 2014-06-24 Hewlett-Packard Development Company, L.P. Policy scheduling
US9195499B2 (en) * 2012-11-27 2015-11-24 International Business Machines Corporation Batch jobs using positional scheduling policies of mobile devices
CN103873587B (en) * 2014-03-26 2017-12-22 中国联合网络通信集团有限公司 A kind of method and device that scheduling is realized based on cloud platform
CN111133484A (en) * 2017-09-28 2020-05-08 北京嘀嘀无限科技发展有限公司 System and method for evaluating a dispatch strategy associated with a specified driving service
CN109982271B (en) * 2017-12-27 2021-06-22 中国移动通信集团上海有限公司 Method and device for resource scheduling of short message service system
CN109067670B (en) * 2018-09-28 2022-07-12 杭州领智云画科技有限公司 CDN scheduling method and CDN scheduling equipment
CN111586134A (en) * 2020-04-29 2020-08-25 新浪网技术(中国)有限公司 CDN node overload scheduling method and system
CN113301085B (en) * 2020-06-30 2022-04-12 阿里巴巴集团控股有限公司 Scheduling method, device, equipment and storage medium
CN114095453A (en) * 2020-07-31 2022-02-25 华为技术有限公司 Method and related device for scheduling data packets
CN112416530B (en) * 2020-12-08 2023-12-22 西藏宁算科技集团有限公司 Method and device for elastically managing cluster physical machine nodes and electronic equipment
CN113064694A (en) * 2021-03-12 2021-07-02 深信服科技股份有限公司 Resource scheduling method and device, electronic equipment and storage medium

Patent Citations (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN113301078A (en) * 2020-05-22 2021-08-24 阿里巴巴集团控股有限公司 Network system, service deployment and network division method, device and storage medium

Also Published As

Publication number Publication date
CN115002117A (en) 2022-09-02

Similar Documents

Publication Publication Date Title
CN110049130B (en) A method and device for service deployment and task scheduling based on edge computing
US12368682B2 (en) Software load balancer to maximize utilization
WO2021233391A1 (en) Routing information sending method, routing information receiving method, network element and node device
CN113037869B (en) Method and apparatus for back-sourcing of content distribution network system
EP3637733A1 (en) Load balancing engine, client, distributed computing system, and load balancing method
CN115002117B (en) Content distribution network dynamic scheduling method, system, device and storage medium
US20150215228A1 (en) Methods, systems, and computer readable media for a cloud-based virtualization orchestrator
US20160216994A1 (en) Method, system, computer program and computer program product for monitoring data packet flows between virtual machines, vms, within a data centre
CN110401657B (en) Processing method and device for access log
WO2018133306A1 (en) Dispatching method and device in content delivery network
CN104991854B (en) A kind of monitoring statisticss method and system of server resource
JP2002245017A (en) Apparatus and method for specifying requested service level for transaction
CN103391206B (en) A kind of method for scheduling task and device thereof
JP2023089891A (en) Cluster capacity expansion method and device
CN110781015A (en) Message queue distribution method, device, equipment and computer readable storage medium
CN114302429B (en) NWDAF network element determination method, device, equipment and storage medium
WO2021057607A1 (en) Method and apparatus for node speed limiting, electronic device, and storage medium
CN108566408A (en) Service processing method, device and storage medium
CN113079062B (en) Resource adjusting method and device, computer equipment and storage medium
CN110995890B (en) Domain name request scheduling method and device
CN106933671A (en) A kind of methods, devices and systems for carrying out flexible treatment
CN118784727A (en) Service node scheduling method, device, computer equipment, storage medium and program product
CN115348251A (en) File download method, device, computer equipment and storage medium
Mao et al. Sharing based virtual network embedding algorithm with dynamic resource block generation
CN113612841B (en) Task scheduling method, device, computer equipment and storage medium

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
GR01 Patent grant
GR01 Patent grant