CN120568091A

CN120568091A - Information processing method and related device

Info

Publication number: CN120568091A
Application number: CN202510940735.0A
Authority: CN
Inventors: 曹望
Original assignee: Hunan MgtvCom Interactive Entertainment Media Co Ltd
Current assignee: Hunan MgtvCom Interactive Entertainment Media Co Ltd
Priority date: 2025-07-08
Filing date: 2025-07-08
Publication date: 2025-08-29

Abstract

The application discloses an information processing method and a related device, relating to the field of networks, comprising the steps of extracting target parameter information from a file request website; the method comprises the steps of determining a target manufacturer node with service performance meeting preset conditions based on target parameter information, generating a fragment download address containing a domain name of the target manufacturer node, and adding the fragment download address to a playlist file so that the client can send a fragment request to the target manufacturer node based on the playlist file. The application can ensure the service quality of the manufacturer node.

Description

Information processing method and related device

Technical Field

The present application relates to the field of network technologies, and in particular, to an information processing method and a related device.

Background

With the explosive growth of internet live services, a video platform integrates multiple CDN vendor resources by using a converged CDN (Content Delivery Network ) mode. The existing CDN scheduling depends on internal optimization of a single manufacturer, so that partial manufacturer nodes are overloaded due to concentrated flow, and the problem of service quality reduction occurs.

Disclosure of Invention

In view of the above, the present application provides an information processing method and related apparatus, so as to ensure the service quality of manufacturer nodes. The specific scheme is as follows:

the first aspect of the present application provides an information processing method, including:

Extracting target parameter information from a file request website, wherein the file request website is a website for requesting a playlist file, the file request website carries the target parameter information, and the target parameter information is obtained by analyzing the playlist file request sent by a client by an edge node of a first manufacturer;

Determining a target manufacturer node with service performance meeting preset conditions based on the target parameter information, wherein the target manufacturer node is an edge node of the first manufacturer or an edge node of a second manufacturer, and the first manufacturer is different from the second manufacturer;

and generating a fragment download address containing the domain name of the target manufacturer node, and adding the fragment download address to the play list file so that the client sends a fragment request to the target manufacturer node based on the play list file.

In one possible implementation, the determining, based on the target parameter information, the target vendor node that the service performance meets the preset condition includes:

Determining edge nodes of each manufacturer matched with the target parameter information, and calculating service performance indexes of the matched manufacturer edge nodes;

carrying out weighted summation operation on the service performance index and the corresponding index weight value to obtain a decision value of the matched manufacturer edge node;

and determining the manufacturer edge node corresponding to the decision value smaller than the preset value as a target manufacturer node of which the service performance meets the preset condition.

In one possible implementation, the determining the edge node of each vendor matching the target parameter information, and calculating the service performance index of the matched edge node of the vendor, includes:

Determining edge nodes of each manufacturer under the identification of a target area, a target operator and a target live stream to obtain the matched edge nodes of the manufacturer;

The method comprises the steps of obtaining a first service performance index in a first preset time length aiming at each matched manufacturer edge node, and obtaining a second service performance index corresponding to a target event based on the times of occurrence of the target event in the first preset time length, wherein the first service performance index comprises a load rate and/or delay, the target event comprises at least one of a blocking event, a packet loss event and a connection failure event, the second service performance index corresponding to the blocking event is a blocking rate, the second service performance index corresponding to the packet loss event is a packet loss rate, and the second service performance index corresponding to the connection failure event is a connection failure rate.

In one possible implementation, the obtaining, based on the number of times of occurrence of the target event within the first preset duration, a second service performance indicator corresponding to the target event includes:

determining an exponential decay weight based on a difference between a current time and the target event occurrence time;

carrying out weighted summation operation on the exponential decay weight and the times of occurrence of the target event to obtain a first weighted summation value;

Carrying out weighted summation operation on the exponential decay weight and the total number of events to obtain a second weighted summation value, wherein the total number of events is the sum of the number of target events and the number of normal events;

And taking the ratio of the first weighted summation value to the second weighted summation value as a second service performance index corresponding to the target event.

In one possible implementation, the performing a weighted summation operation on the service performance index and a corresponding index weight value to obtain a decision value of the matched vendor edge node includes:

Determining an index weight value corresponding to the service performance index according to the live stream type to obtain a target index weight value;

And carrying out weighted summation operation on the service performance index and the target index weight value to obtain the decision value of the matched manufacturer edge node.

In one possible implementation, after the adding the clip download address to the playlist file, the method further includes:

the edge node of the first manufacturer obtains the play list file;

When the target manufacturer node is the edge node of the first manufacturer, the edge node of the first manufacturer obtains the ending time of the current slicing from the playlist file, and sends a new playlist file request within a second preset time period before the ending time of the current slicing.

A second aspect of the present application provides an information processing system including:

The system comprises a parameter acquisition module, a parameter analysis module and a client, wherein the parameter acquisition module is used for extracting target parameter information from a file request website, the file request website is a website for requesting a playlist file, the file request website carries the target parameter information, and the target parameter information is obtained by analyzing a playlist file request sent by a client by an edge node of a first manufacturer;

The manufacturer node determining module is used for determining a target manufacturer node with service performance meeting preset conditions based on the target parameter information, wherein the target manufacturer node is an edge node of the first manufacturer or an edge node of a second manufacturer, and the first manufacturer is different from the second manufacturer;

And the file generation module is used for generating a fragment download address containing the domain name of the target manufacturer node, and adding the fragment download address to the play list file so that the client side sends a fragment request to the target manufacturer node based on the play list file.

A third aspect of the present application provides a computer program product comprising computer readable instructions which, when run on an electronic device, cause the electronic device to implement the information processing method of the first aspect or any implementation of the first aspect.

A fourth aspect of the application provides an electronic device comprising at least one processor and a memory coupled to the processor, wherein:

the memory is used for storing a computer program;

the processor is configured to execute the computer program to enable the electronic device to implement the information processing method of the first aspect or any implementation manner of the first aspect.

A fifth aspect of the present application provides a computer storage medium carrying one or more computer programs which, when executed by an electronic device, enable the electronic device to implement the information processing method of the first aspect or any implementation manner of the first aspect.

The information processing method and the related device provided by the application are used for extracting the target parameter information from the file request website, determining the target manufacturer node with the service performance meeting the preset condition based on the target parameter information, generating the fragment download address containing the domain name of the target manufacturer node, and adding the fragment download address to the play list file so that the client side sends the fragment request to the target manufacturer node based on the play list file. When the service performance of the current manufacturer node meets the preset condition, the current manufacturer node processes the fragmentation request, and when the service performance of the current manufacturer node does not meet the preset condition, the manufacturer node is switched to process the request sent by the client, so that the problem of poor user experience caused by the reduction of the service quality of the manufacturer node can be avoided, and the service quality of the manufacturer node is ensured.

Drawings

The above and other features, advantages, and aspects of embodiments of the present disclosure will become more apparent by reference to the following detailed description when taken in conjunction with the accompanying drawings. The same or similar reference numbers will be used throughout the drawings to refer to the same or like elements. It should be understood that the figures are schematic and that elements and components are not necessarily drawn to scale.

FIG. 1 is a flow chart of an information processing method provided by the application;

FIG. 2 is a diagram of a hierarchical scheduling architecture provided by the present application;

FIG. 3 is a block diagram of an information handling system according to the present application;

Fig. 4 is a schematic structural diagram of an electronic device according to the present application.

Detailed Description

Embodiments of the present application will be described below with reference to the accompanying drawings in the embodiments of the present application. The terminology used in the description of the embodiments of the application herein is for the purpose of describing particular embodiments of the application only and is not intended to be limiting of the application.

Embodiments of the present application are described below with reference to the accompanying drawings. As one of ordinary skill in the art can know, with the development of technology and the appearance of new scenes, the technical scheme provided by the embodiment of the application is also applicable to similar technical problems.

The terms first, second and the like in the description and in the claims and in the above-described figures, are used for distinguishing between similar elements and not necessarily for describing a particular sequential or chronological order. It is to be understood that the terms so used are interchangeable under appropriate circumstances and are merely illustrative of the manner in which embodiments of the application have been described in connection with the description of the objects having the same attributes. Furthermore, the terms "comprises," "comprising," and "having," and any variations thereof, are intended to cover a non-exclusive inclusion, such that a process, method, system, article, or apparatus that comprises a list of elements is not necessarily limited to those elements, but may include other elements not expressly listed or inherent to such process, method, article, or apparatus.

Referring to fig. 1, fig. 1 is a flowchart of an information processing method according to an embodiment of the present application, and as shown in fig. 1, the information processing method according to an embodiment of the present application may include steps 101 to 103, which are described in detail below, respectively.

And 101, extracting target parameter information from a file request website, wherein the file request website is a website for requesting a playlist file, the file request website carries the target parameter information, and the target parameter information is obtained by analyzing the playlist file request sent by a client by an edge node of a first manufacturer.

The target parameter information may include target area, target operator, and target live stream identification (Identity document, ID). The client sends a playlist file request to an edge node of the first vendor, and the edge node of the first vendor obtains a target area and a target operator by using IP library analysis based on a user IP (Internet Protocol ) address, and obtains a target live stream identifier from the playlist file request address. Wherein the playlist file may be an m3u8 file. The edge node may serve the CDN.

The client requests a play list file from an edge node of a first manufacturer, namely, a request m3u8 file, the edge node checks whether the m3u8 file is cached, if the m3u8 file is cached, the request is sent to the client, if the m3u8 file is cached, the request carries target parameter information to be returned, as shown in fig. 2, after the request of the m3u8 file sent by the client is obtained, the CDN service edge node of the first manufacturer rewrites a return path, the target parameter information, namely, a target area, a target operator and a target live broadcast stream identifier are added into the return path, the request of the m3u8 file is sent to a CDN service area source station, if the m3u8 file is not cached, the return path is also required to be carried with target parameter information, namely, the request of the return path is rewritten, the target area, the target operator and the target stream identifier are added into the return path, if the m3u8 file is not cached in the center, the return path carries target parameter information to be carried continuously, and the core area 3u8 file can be requested from the core area, the target operator and the live broadcast stream identifier can be extracted from the core area source station.

And 102, determining a target manufacturer node with service performance meeting preset conditions based on the target parameter information, wherein the target manufacturer node is an edge node of a first manufacturer or an edge node of a second manufacturer, and the first manufacturer is different from the second manufacturer.

When determining the target manufacturer nodes with service performance meeting the preset conditions based on the target parameter information, the determined target manufacturer can be one manufacturer or a plurality of different manufacturers, and if the determined target manufacturer nodes are the plurality of different manufacturers, the edge nodes of the target manufacturers all belong to the same target area, the same target operators and the same target live broadcast stream identifier. The service performance of the target manufacturer node needs to meet a preset condition, if the service performance of the edge node of the first manufacturer meets the preset condition, it can be determined that the target manufacturer node comprises the edge node of the first manufacturer, if the service performance of the edge node of the first manufacturer does not meet the preset condition, the manufacturer is switched, and an edge node corresponding to a second manufacturer different from the first manufacturer is taken as the target manufacturer node, wherein the edge node of the second manufacturer can be an edge node of one manufacturer or can be edge nodes corresponding to a plurality of different manufacturers.

The service performance of the vendor node may be embodied by a service performance index, which may include, but is not limited to, a stuck rate, a load rate, a network delay, a packet loss rate, a connection failure rate, and the like. The service performance of the edge node of the manufacturer meets the preset conditions, namely that one of the blocking rate, the load rate, the network delay, the packet loss rate and the connection failure rate is smaller than a threshold value, or the sum of several weights is smaller than the threshold value, so that the problem that the service quality is reduced due to overload caused by concentrated flow of the manufacturer node is avoided.

In one possible implementation, determining, based on the target parameter information, a target vendor node for which the service performance meets a preset condition, includes:

And determining the manufacturer edge node with the decision value smaller than the preset value as a target manufacturer node with the service performance meeting the preset condition.

And determining edge nodes of all manufacturers matched with the target parameter information, wherein the edge nodes of all manufacturers have consistent target parameter information, namely, the edge nodes of all target manufacturers belong to the same target area, the same target operators and have the same target live broadcast stream identifier, so that the matched manufacturer edge nodes are obtained. And then calculating service performance indexes of the matched manufacturer edge nodes, wherein the service performance indexes comprise a cartoon rate, a load rate, a network delay, a packet loss rate and a connection failure rate, the service performance indexes correspond to index weight values, the index weight values of different service performance indexes can be the same or different, the service performance indexes and the corresponding index weight values are subjected to weighted summation operation to obtain decision values of the matched manufacturer edge nodes, and the decision values are smaller than the manufacturer edge nodes corresponding to preset values and are determined to be target manufacturer nodes with service performance meeting preset conditions.

In one possible implementation, determining edge nodes of each vendor matching the target parameter information, and calculating a service performance index of the matched vendor edge nodes includes:

determining edge nodes of each manufacturer under the identification of a target area, a target operator and a target live stream to obtain matched edge nodes of the manufacturer;

And aiming at each matched manufacturer edge node, acquiring a first service performance index within a first preset time period, and acquiring a second service performance index corresponding to a target event based on the times of occurrence of the target event within the first preset time period, wherein the first service performance index comprises a load rate and/or delay, the target event comprises at least one of a stuck event, a packet loss event and a connection failure event, the second service performance index corresponding to the stuck event is the stuck rate, the second service performance index corresponding to the packet loss event is the packet loss rate, and the second service performance index corresponding to the connection failure event is the connection failure rate.

For the first service performance index, the load rate and the network delay in a first preset duration may be directly obtained, where the first preset duration may be 30s or other values. For the second service performance index, the second service performance index corresponding to the target event can be obtained based on the number of times of occurrence of the target event in the first preset time period, for the stuck event, the stuck rate can be obtained based on the number of times of occurrence of stuck in the first preset time period, for the packet loss event, the packet loss rate can be obtained based on the number of times of occurrence of packet loss in the first preset time period, and for the connection failure event, the connection failure rate can be obtained based on the number of times of transmission connection failure in the first preset time period.

In one possible implementation, obtaining the second service performance index corresponding to the target event based on the number of times the target event occurs within the first preset duration includes:

Determining an exponential decay weight based on a difference between the current time and the time of occurrence of the target event;

The exponential decay weight is determined by the difference value between the current time and the occurrence time of the target event, so that the recent event weight can be changed, and the current network state can be reflected more.

In the converged CDN network, the multi-dimensional performance index q of the manufacturer v, the region r, the operator o and the live stream IDs in four dimensions can be acquired in real time, and live stream service performance data in different scenes can be recorded. Where q=1 denotes a stuck rate, q=2 denotes a load rate, q=3 denotes a network delay, q=4 denotes a packet loss rate, and q=5 denotes a connection failure rate.

And (3) calculating the real-time cartoon rate, the packet loss rate and the connection failure rate of the manufacturer v by adopting a time weighted sliding window (the first preset duration tau=30s) aiming at the target region r, the target operator o and the target live stream IDs. The calculation formula is as follows:

wherein M (r, o, s, v, t) represents a clip rate or a packet loss rate or a connection failure rate, and f (·) is an indication function, which is a Boolean function for determining whether a condition is satisfied, and when the condition is satisfied, the value is 1, and when the condition is not satisfied, the value is 0.

F (e _i＝e₁,r_i＝r,o_i＝o,s_i＝s,v_i =v) represents that the ith event e _i is judged to be a target event, which may be a stuck event, a packet loss event or a connection failure event, and whether the region r _i corresponding to the event is the target region r, whether the operator o _i is the target operator o, whether the target live stream ID s _i is the target live stream IDs, and whether the vendor v _i is the target vendor v, when these conditions are satisfied at the same time, the value of the indication function is 1, otherwise, the value is 0.f (e _i∈{e₁,e₂},r_i＝r,o_i＝o,s_i＝s,v_i =v) indicates that whether the ith event e _i is a target event e ₁ or a normal play event e ₂ is judged, whether the region r _i corresponding to the event is a target region r, whether the operator o _i is a target operator o, whether the target live stream ID s _i is a target live stream ID s, whether the vendor v _i is a target vendor v, and when the condition is satisfied, the indication function value is 1, otherwise, the indication function value is 0.

Omega _i is the i-th event exponentially decaying weight,Wherein λ is an attenuation factor, λ may be 0.1 or other values, t is a current time, and t _i is a timestamp of occurrence of the ith event, so that the weight of the recent event is higher, and the current network state can be reflected more.

For the sum sign, k is the number of events,The weighted values of all the events e ₁ meeting the conditions in the time window are summed, that is, the weighted values of all the target events which occur when the vendor v provides services under the target region r, the target operator o and the target live stream IDs in the time window are summed, and e ₁ can be a stuck event, a packet loss event or a connection failure event.The weighted values of all the events meeting the conditions (including the target event and the play normal event) in the time window are summed, and e ₂ is the normal event.

And under the conditions of the target region r, the target operator o and the target live stream IDs, the vendor v provides the real-time cartoon rate, the packet loss rate and the connection failure rate when the service is provided. By means of a time weighted sliding window, the recent network state is comprehensively considered, and the calculated cartoon rate, packet loss rate and connection failure rate can reflect the current actual situation more accurately.

In one possible implementation, performing a weighted summation operation on the service performance index and the corresponding index weight value to obtain a decision value of the matched vendor edge node, including:

And carrying out weighted summation operation on the service performance index and the target index weight value to obtain a decision value of the matched manufacturer edge node.

When the index weight value corresponding to the service performance index is determined according to the live stream type, delay weight can be increased for live broadcast with high code rate and high real-time requirement, such as live broadcast of sports events, manufacturer nodes with low delay are preferentially selected, smoothness and real-time performance of live broadcast pictures are guaranteed, for live broadcast of cost-sensitive electronic commerce, load rate weight can be increased, manufacturer nodes with lower load rate and proper cost are selected, and the cost is controlled while the service quality is guaranteed. And respectively obtaining an index weight value corresponding to the blocking rate, an index weight value corresponding to the load rate, an index weight value corresponding to the network delay, an index weight value corresponding to the packet loss rate and an index weight value corresponding to the connection failure rate.

When the service performance index and the target index weight value are subjected to weighted summation operation, the calculation formula is as follows:

D(r,o,s,v)=α·J+β·L+γ·T+δ·P+∈·C。

Wherein D (r, o, s, v) is a decision value, D (·) is a decision function, J is a jamming rate, the frequency of jamming occurring in the live stream playing process is reflected, L is a load rate, the busyness of node processing requests is reflected, T is a network delay, the standardized value of the transmission time of data from a client to an edge node is indicated, and a T calculation formula is T _min is a time lower limit, t _min＝0ms,t_max is a time upper limit, event live broadcast is sensitive to delay, t _max＝100ms can be set, e-commerce live broadcast is sensitive to cost, delay tolerance is higher, t _max＝1000ms can be set, t is current time, P is packet loss rate, namely the proportion of lost data packets in the transmission process, C is connection failure rate, the probability of connection failure between a client and a node is represented, alpha, beta, gamma, delta and epsilon are index weights corresponding to service performance indexes, alpha=0.2, beta=0.6, gamma=0.1, delta=0.05 and epsilon=0.05 can be set, or other values can be set according to the type of live broadcast.

When D (r, o, s, v) > a, vendor switch may be triggered, a is a preset value, and a may be set to 0.6 or other values. By comprehensively considering a plurality of indexes and characteristics of different live streams, the decision function can evaluate service quality of manufacturer nodes and select an optimal distribution path for the live streams.

Step 103, generating a fragment download address containing the domain name of the target manufacturer node, and adding the fragment download address to the play list file so that the client side sends a fragment request to the target manufacturer node based on the play list file.

When generating a fragment download address containing the domain name of the target vendor node, a signed absolute URL (Uniform Resource Locator ) may be generated for the TS fragment, in the following specific format:

http(s):// < target vendor domain name >/< fragment path >

And adding the fragment downloading address to the playlist file, and returning the playlist file to the client step by step, namely returning the core source station to the central source station, returning the central source station to the regional source station, returning the regional source station to the edge node, and returning the m3u8 file containing the TS fragment URL of the target manufacturer node to the client by the edge node. The client may send a shard request, such as http (s)// v.cdn.com/seg.ts, to the target vendor node via a shard download address in the playlist file.

As shown in fig. 2, if the target vendor node is a vendor a edge node, the ts slicing request is sent to the vendor a edge node, if there is ts slicing in the vendor a cache, the ts slicing request is returned to the client, if there is no ts slicing cache, the ts slicing request is sent to the vendor a regional source station, if there is no ts slicing cache, the ts slicing request is sent to the vendor a central source station until the ts slicing request is returned to the core source station. Similarly, if the target manufacturer node is a manufacturer B edge node, the ts slicing request is sent to the manufacturer B edge node, if the manufacturer B caches ts slices, the ts slices are returned to the client, if the ts slices are not cached, the ts slices are returned, namely, the ts slicing request is sent to the manufacturer B regional source station, if the ts slices are not cached, the ts slicing request is sent to the manufacturer B central source station, and until the ts slices are returned to the core source station. The core source station returns TS slices to the edge node step by step, namely the core source station returns TS slices to the central source station, the central source station returns TS slices to the regional source station, the regional source station returns TS slices to the edge node, and the edge node returns TS slices to the client.

In one possible implementation, after adding the clip download address to the playlist file, the information processing method provided by the present application further includes:

the method comprises the steps that an edge node of a first manufacturer obtains a play list file;

In order to ensure that the manufacturer node switching occurs at the media slicing boundary, avoid the video frame analysis interruption, realize that the user does not have the perception switching, the time for making the edge node initiate the source returning request is required to be a second preset time length before the current TS slicing end time, the second preset time length can be 50ms, namely, a new play list file request is sent within 50ms before the current slicing end time, so that after the core source station returns the new play list file, the client can acquire a new slicing download address within the second preset time length after the slicing end time, namely, acquire the new slicing download address within 50ms after the current slicing end time. In practical application, the switching time window may be set to be ±50ms of the current TS slice end time t _end, i.e. the time range of the switching time t _switch is t _switch∈[t_end-50ms,t_end +50ms ]. The CDN edge node adopts an active source returning mode, node manufacturer switching is carried out in the time window, continuity of live streams can be guaranteed, a user cannot perceive interruption or blocking of pictures in the watching process, and watching experience is greatly improved.

In summary, the client accesses the m3u8 file through a unified domain name (e.g., https:// live.proxy.com/stream 2025.m3u8), and the CDN service edge node reconstructs the original m3u8 file request into a tagged path back source according to the user IP resolution result, separates the scheduling of m3u8 from the scheduling of ts slices, and the m3u8 uses a separate domain name service, and the ts slices use CDN vendor services. And the core source station selects a target manufacturer node with service performance meeting preset conditions for each request according to the user region, the operator information and the live stream ID, and dispatches the request to the target manufacturer node to ensure high-quality transmission of the live stream. And the target manufacturer node returns the TS fragments adapting to the signature, so that the end-to-end optimization of the user-region-operator-manufacturer-live stream is realized. The client can be seamlessly switched to a new manufacturer node without any additional operation in the receiving and playing processes, and the whole process is not perceived, so that the smoothness and stability of live broadcast watching are ensured.

For further explanation of the information processing method provided by the present application, reference may be made to the following examples.

Assuming that the user IP is 116.228.Xxx, it is parsed by the IP library that the region r=r, the operator o=y, and the live stream ids=sports2025 are extracted from the m3u8 request URL parameter stream_id=sports2025. The edge node generates the label r_o_s=r_y_pipes 2025 as a cache key and a back source path parameter.

Querying the index of vendor a in the r_y_sports2025 dimension from Redis, the acquisition frequency may be 10 times/second, resulting in a load factor L of 0.85 and a delay T of 80ms.

If the current time t=15:30:00 (units: seconds), the time window τ=30 s, i.e. the monitoring interval is [15:29:30,15:30:00].

Assuming 5 jams are detected within the time window, 3 occurrences are 10 seconds ago, 2 occurrences are 20 seconds ago, and the occurrence times are t ₁ =15:29:50 (10 seconds ago), t ₂ =15:29:40 (20 seconds ago), respectively. The event is normally played 15 times, the stuck event is 5 times, and 20 times total events are performed.

When the weight is calculated, the exponential decay formula: where λ=0.1, time difference Δt=t-t _i.

Katon event 1 (10 seconds ago) Δt=10s, ω ₁＝e^-0.1×10＝e^-1, ω ₁ can be given a value of 0.3679.

Katon event 2 (20 seconds ago): Δt=20s, # ₂＝e^-0.1×20＝e^-2, can take the value of ω ₂ to 0.1353.

The weight of the near-term event is higher than that of the distant event, for example, the weight of the event before 10 seconds is higher than that before 20 seconds, so that the real-time performance is ensured.

The weight calculation mode of the normal event is the same, if a certain normal event occurs before 5 seconds, ω ₃＝e^-0.1×5＝e^-0.5, ω ₃ may be valued as 0.6065. The 15 normal events are assumed to be uniformly distributed in the window, the simplified average weight is about 0.3, and the actual calculation is needed according to specific time.

When calculating the real-time click-through rate, the numerator is the click-through event weighted sum, and the denominator is the total event weighted sum.

Molecule = 3 x 0.3679+2 x 0.1353 =1.1037+0.2706= 1.3743;

denominator = 1.3743+15 x 0.3 =1.3743+4.5= 5.8743;

The click-through rate= 1.3743/5.8743, and the click-through rate can be set to 0.234.

The calculation of the indexes such as the packet loss rate, the connection failure rate and the like is similar to the blocking rate, and is not repeated here.

If the live broadcast type is sports live broadcast (the characteristics of the sports live broadcast are high code rate and high real-time requirements, delay can be reduced, and the standardized interval of the delay is 0ms-100 ms).

The candidate vendors are vendor a (i.e., the current service vendor) and vendor B (the candidate switch vendor).

The real-time index is shown in table 1 and is collected in a 30 second sliding window.

TABLE 1 index data

Index (I)	Vendor A	Manufacturer B
			Katon rate J	15%(0.15)	12%(0.12)
Load factor L	85%(0.85)	60%(0.60)
			Delay T	80ms(0.8)	60ms(0.6)

For sports indexes, the weight adjustment may be performed, that is, the delay weight is increased to γ=0.2 (default 0.1), so as to preferentially select low delay nodes, the katon rate weight is α=0.6 (default 0.6, which remains unchanged), and the load rate weight is β=0.2 (default 0.6, which is reduced to adapt to real-time requirements).

The decision function is D (r, o, s, v) =α·j+β·l+γ·t.

Vendor a decision value: D _A =0.6×0.15+0.2×0.85+0.2 x 0.8=0.09+0.17+0.16=0.42.

Vendor B decision value: D _B =0.6x0.12+0.2x0.60+0.2 x 0.6=0.072+0.12+0.12=0.312.

Triggering condition, triggering a handover when D (r, o, s, v) > T, t=0.3.

Manufacturer a, D _A =0.42 >0.3, judges that the performance is not up to standard;

Vendor B, D _B =0.312 >0.3, is close to the threshold 0.3 but does not reach the standard, at which time the threshold T may be dynamically adjustable (if the sports live scene allows higher delay tolerance, it may be set to t=0.35, then the D _B performance reaches the standard).

Vendor B, D _B =0.312 <0.35, satisfies the handover condition, triggers handover to vendor B.

The edge node extracts the end time T end = 15:30:05.000 of the current slice seg-0.ts from the m3u8 timestamp, defining a time window [15:30:04.950,15:30:05.050]. The edge node initiates a source return request at T _end -50 ms=15:30:04.950, and the unified service end returns a new m3u8 at T _end +20ms=15:30:05.020, so that the client end is ensured to acquire a new URL within 50ms after the slicing is finished.

M3u8 back source path reconstruction:

The original path http:// live.proxy.com/SPORTS2025/stream.m3u8 is rewritten as:

http://live.proxy.com/R_Y_SPORTS2025/stream.m3u8。

the path parameter r_y_slots 2025 is used for source station database queries and cache fragmentation.

TS shard URL generation:

generating a signed URL for the fragment seg-1.Ts using the SHA-256 algorithm:

http://B.cdn.com/TS/SPORTS2025/seg-1.tssign＝HMAC_SHA256(key_B,"B.cdn.com/TS/SPORTS2025/seg-1.tst＝1690000000&rand＝12345").

Wherein, cdn.com is vendor B domain name, key _B is pre-shared by the core source station and vendor B.

The m3u8 file is distributed through a unified domain name CDN (e.g., live. Proxy. Com), and the m3u8 corresponding To the edge node cache tag r_y_sports2025 has a TTL (Time To Live) of 60 seconds.

TS fragmentation requests are directed to vendor B's node http:// R-Y.B.cdn.com, with its local node acceleration, the average delay is reduced to 60ms (25% lower than vendor A).

After the client finishes playing seg-0.ts at T _end, the client immediately requests seg-1.ts (manufacturer B), and the actual switching interruption time is 28ms (lower than the human eye perception threshold value by 100 ms).

When the node load rate of the manufacturer B is more than 90% and lasts for 30 seconds, the node of the manufacturer B is overloaded, and disaster recovery is triggered. At this time, the indexes of other operator nodes in the same region are checked, if D is less than 0.3, the switch is performed, if all the nodes are failed, the source is returned to the core source station, the alarm is simultaneously carried out, and the failed node is automatically restarted (recovery time is less than 30 seconds).

When the edge node caches the m3u8 file, a compound key is adopted:

CacheKey=m3u8<r><o><s>=m3u8_R_Y_SPORTS2025。

the cache hit rate is improved to 85 percent, and the source returning times are reduced by 40 percent (compared with the conventional two-dimensional key m3u8_R_Y hit rate of 65 percent).

The request parameters may be:

response parameters:

The method and the system construct a territory, an operator, a manufacturer and a live broadcast stream ID four-dimensional monitoring system through user IP analysis, collect multidimensional performance indexes such as a load rate, a delay, a blocking rate, a connection failure rate, a packet loss rate and the like by combining a time weighted sliding window, realize fine granularity scheduling of the manufacturer-territory-operator-live broadcast stream ID by utilizing a dynamic weight decision function, accurately switch at a media slicing boundary through a labeled back source path reconstruction and a source station layering architecture, ensure that a client does not feel, solve the problems that the load of each manufacturer node is unbalanced and cannot be automatically switched to other manufacturer nodes, so that part of nodes are overloaded due to flow concentration, service quality is reduced, other nodes are idle in resources, the whole utilization rate is insufficient, or TS slicing loading is interrupted due to forced switching, and black screen or blocking occurs. The method can remarkably improve the resource allocation precision and the network utilization efficiency, effectively reduce the cross-domain source return cost, realize the efficient distribution and smooth play of the live stream, and is suitable for large-scale cross-domain live broadcast scenes.

Having described an information processing method provided by an embodiment of the present application, a system for executing the information processing method will be described below.

Referring to fig. 3, fig. 3 is a schematic structural diagram of an information processing system according to an embodiment of the application. As shown in fig. 3, the information processing system includes:

the parameter obtaining module 301 is configured to extract target parameter information from a file request website, where the file request website is a website of a request playlist file, the file request website carries target parameter information, and the target parameter information is obtained by analyzing a playlist file request sent by a client by an edge node of a first vendor.

And the vendor node determining module 302 is configured to determine, based on the target parameter information, a target vendor node whose service performance meets a preset condition, where the target vendor node is an edge node of a first vendor or an edge node of a second vendor, and the first vendor is different from the second vendor.

The file generation module 303 is configured to generate a fragment download address containing the domain name of the target vendor node, and add the fragment download address to the playlist file, so that the client sends a fragment request to the target vendor node based on the playlist file.

In one possible implementation, the vendor node determination module 302 is specifically configured to:

In one possible implementation, the vendor node determination module 302 is further configured to:

In one possible implementation, the information processing system provided by the present application further includes:

And when the target manufacturer node is the edge node of the first manufacturer, the edge node of the first manufacturer acquires the ending time of the current fragment from the playlist file, and a new playlist file request is sent within a second preset time period before the ending time of the current fragment.

The embodiment of the application also provides electronic equipment. Referring to fig. 4, a schematic diagram of an electronic device suitable for use in implementing embodiments of the present application is shown. The electronic device in the embodiment of the present application may include, but is not limited to, a fixed terminal such as a mobile phone, a notebook computer, a PDA (personal digital assistant), a PAD (tablet computer), a desktop computer, and the like. The electronic device shown in fig. 4 is only an example and should not be construed as limiting the functionality and scope of use of the embodiments of the application.

As shown in fig. 4, the electronic device may include a processing means (e.g., a central processing unit, a graphics processor, etc.) 401, which may perform various appropriate actions and processes according to a program stored in a Read Only Memory (ROM) 402 or a program loaded from a storage means 408 into a Random Access Memory (RAM) 403. In the state where the electronic device is powered on, various programs and data necessary for the operation of the electronic device are also stored in the RAM 403. The processing device 401, the ROM 402, and the RAM 403 are connected to each other by a bus 404. An input/output (I/O) interface 405 is also connected to bus 404.

In general, devices may be connected to I/O interface 405 including input devices 406 such as a touch screen, touch pad, keyboard, mouse, camera, microphone, accelerometer, gyroscope, etc., output devices 407 including Liquid Crystal Displays (LCDs), speakers, vibrators, etc., storage devices 408 including memory cards, hard disks, etc., and communications devices 409. The communication means 409 may allow the electronic device to communicate with other devices wirelessly or by wire to exchange data. While fig. 4 shows an electronic device having various means, it is to be understood that not all of the illustrated means are required to be implemented or provided. More or fewer devices may be implemented or provided instead.

Embodiments of the present application also provide a computer program product including computer readable instructions, which when executed on an electronic device, cause the electronic device to implement any of the information processing methods provided in the embodiments of the present application.

The embodiment of the application also provides a computer readable storage medium, which carries one or more computer programs, and when the one or more computer programs are executed by the electronic device, the electronic device can realize any information processing method provided by the embodiment of the application.

It should be further noted that the above-described apparatus embodiments are merely illustrative, and that the units described as separate units may or may not be physically separate, and that units shown as units may or may not be physical units, may be located in one place, or may be distributed over a plurality of network units. Some or all of the modules may be selected according to actual needs to achieve the purpose of the solution of this embodiment. In addition, in the drawings of the embodiment of the device provided by the application, the connection relation between the modules represents that the modules have communication connection, and can be specifically implemented as one or more communication buses or signal lines.

From the above description of the embodiments, it will be apparent to those skilled in the art that the present application may be implemented by means of software plus necessary general purpose hardware, or of course by means of special purpose hardware including application specific integrated circuits, special purpose CPUs, special purpose memories, special purpose components, etc. Generally, functions performed by computer programs can be easily implemented by corresponding hardware, and specific hardware structures for implementing the same functions can be varied, such as analog circuits, digital circuits, or dedicated circuits. But a software program implementation is a preferred embodiment for many more of the cases of the present application. Based on such understanding, the technical solution of the present application may be embodied essentially or in a part contributing to the prior art in the form of a software product stored in a readable storage medium, such as a floppy disk, a usb disk, a removable hard disk, a ROM, a RAM, a magnetic disk or an optical disk of a computer, etc., comprising several instructions for causing a computer device (which may be a personal computer, a training device, a network device, etc.) to perform the method according to the embodiments of the present application.

In the above embodiments, it may be implemented in whole or in part by software, hardware, firmware, or any combination thereof. When implemented in software, may be implemented in whole or in part in the form of a computer program product.

The computer program product includes one or more computer instructions. When loaded and executed on a computer, produces a flow or function in accordance with embodiments of the present application, in whole or in part. The computer may be a general purpose computer, a special purpose computer, a computer network, or other programmable apparatus. The computer instructions may be stored in a computer-readable storage medium or transmitted from one computer-readable storage medium to another computer-readable storage medium, for example, the computer instructions may be transmitted from one website, computer, training device, or data center to another website, computer, training device, or data center via a wired (e.g., coaxial cable, optical fiber, digital Subscriber Line (DSL)) or wireless (e.g., infrared, wireless, microwave, etc.). The computer readable storage medium may be any available medium that can be stored by a computer or a data storage device such as a training device, a data center, or the like that contains an integration of one or more available media. The usable medium may be a magnetic medium (e.g., floppy disk, hard disk, tape), an optical medium (e.g., DVD), or a semiconductor medium (e.g., solid state disk (Solid STATE DISK, SSD)), etc.

Claims

1. An information processing method, comprising:

Extracting target parameter information from a file request URL; wherein the file request URL is a URL for requesting a playlist file, and the file request URL carries the target parameter information, the target parameter information being obtained by parsing the playlist file request sent by the client by the edge node of the first manufacturer;

Determining a target vendor node whose service performance meets a preset condition based on the target parameter information; wherein the target vendor node is an edge node of the first vendor or an edge node of a second vendor, and the first vendor is different from the second vendor;

Generate a fragment download address containing the domain name of the target manufacturer node, and add the fragment download address to the playlist file, so that the client sends a fragment request to the target manufacturer node based on the playlist file.

2. The information processing method according to claim 1, wherein determining the target manufacturer node whose service performance meets the preset conditions based on the target parameter information comprises:

Determine the edge nodes of each manufacturer that match the target parameter information, and calculate the service performance indicators of the matched manufacturer edge nodes;

Performing a weighted sum operation on the service performance indicator and the corresponding indicator weight value to obtain the decision value of the matched manufacturer edge node;

The manufacturer edge node corresponding to the decision value being smaller than the preset value is determined as the target manufacturer node whose service performance meets the preset conditions.

3. The information processing method according to claim 2, wherein determining the edge nodes of each manufacturer that match the target parameter information and calculating the service performance indicators of the matched manufacturer edge nodes comprises:

Determine each manufacturer edge node under the target area, target operator and target live stream identifier, and obtain the matched manufacturer edge node;

For each matched manufacturer edge node, a first service performance indicator within a first preset time period is obtained, and based on the number of times the target event occurs within the first preset time period, a second service performance indicator corresponding to the target event is obtained; wherein, the first service performance indicator includes load rate and/or delay, and the target event includes at least one of a freeze event, a packet loss event, and a connection failure event. The second service performance indicator corresponding to the freeze event is the freeze rate, the second service performance indicator corresponding to the packet loss event is the packet loss rate, and the second service performance indicator corresponding to the connection failure event is the connection failure rate.

4. The information processing method according to claim 3, wherein obtaining a second service performance indicator corresponding to the target event based on the number of times the target event occurs within the first preset time period comprises:

Determining an exponential decay weight based on a difference between a current time and a time at which the target event occurs;

Performing a weighted sum operation on the exponential decay weight and the number of times the target event occurs to obtain a first weighted sum value;

Performing a weighted sum operation on the exponential decay weight and the total number of events to obtain a second weighted sum value; wherein the total number of events is the sum of the number of target events and the number of normal events;

The ratio of the first weighted sum value to the second weighted sum value is used as a second service performance indicator corresponding to the target event.

5. The information processing method according to claim 2, wherein performing a weighted sum operation on the service performance indicator and the corresponding indicator weight value to obtain the decision value of the matched manufacturer edge node comprises:

Determine an indicator weight value corresponding to the service performance indicator according to the live stream type, and obtain a target indicator weight value;

A weighted sum operation is performed on the service performance indicator and the target indicator weight value to obtain the decision value of the matched manufacturer edge node.

6. The information processing method according to claim 1, characterized in that after adding the segment download address to the playlist file, the method further comprises:

The edge node of the first manufacturer obtains the playlist file;

When the target manufacturer node is the edge node of the first manufacturer, the edge node of the first manufacturer obtains the end time of the current segment from the playlist file, and sends a new playlist file request within a second preset time period before the end time of the current segment.

7. An information processing system, comprising:

a parameter acquisition module, configured to extract target parameter information from a file request URL; wherein the file request URL is a URL for requesting a playlist file, and the file request URL carries the target parameter information, the target parameter information being obtained by the first manufacturer's edge node parsing the playlist file request sent by the client;

a vendor node determination module, configured to determine, based on the target parameter information, a target vendor node whose service performance satisfies a preset condition; wherein the target vendor node is an edge node of the first vendor or an edge node of a second vendor, the first vendor being different from the second vendor;

The file generation module is used to generate a fragment download address containing the domain name of the target manufacturer node, and add the fragment download address to the playlist file, so that the client sends a fragment request to the target manufacturer node based on the playlist file.

8. A computer program product, characterized in that it comprises computer-readable instructions, and when the computer-readable instructions are executed on an electronic device, the electronic device implements the information processing method according to any one of claims 1 to 6.

9. An electronic device, comprising at least one processor and a memory connected to the processor, wherein:

The memory is used to store computer programs;

The processor is configured to execute the computer program so that the electronic device can implement the information processing method according to any one of claims 1 to 6.

10. A computer storage medium, characterized in that the storage medium carries one or more computer programs, and when the one or more computer programs are executed by an electronic device, the electronic device can implement the information processing method according to any one of claims 1 to 6.