CN114501044B - Live broadcast data processing method, device, equipment and storage medium - Google Patents
Live broadcast data processing method, device, equipment and storage medium Download PDFInfo
- Publication number
- CN114501044B CN114501044B CN202111620154.7A CN202111620154A CN114501044B CN 114501044 B CN114501044 B CN 114501044B CN 202111620154 A CN202111620154 A CN 202111620154A CN 114501044 B CN114501044 B CN 114501044B
- Authority
- CN
- China
- Prior art keywords
- live
- live broadcast
- room
- video
- storage
- 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
Links
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04N—PICTORIAL COMMUNICATION, e.g. TELEVISION
- H04N21/00—Selective content distribution, e.g. interactive television or video on demand [VOD]
- H04N21/20—Servers specifically adapted for the distribution of content, e.g. VOD servers; Operations thereof
- H04N21/21—Server components or server architectures
- H04N21/218—Source of audio or video content, e.g. local disk arrays
- H04N21/2187—Live feed
-
- G—PHYSICS
- G06—COMPUTING OR CALCULATING; COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F16/00—Information retrieval; Database structures therefor; File system structures therefor
- G06F16/10—File systems; File servers
- G06F16/17—Details of further file system functions
- G06F16/172—Caching, prefetching or hoarding of files
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04N—PICTORIAL COMMUNICATION, e.g. TELEVISION
- H04N21/00—Selective content distribution, e.g. interactive television or video on demand [VOD]
- H04N21/20—Servers specifically adapted for the distribution of content, e.g. VOD servers; Operations thereof
- H04N21/23—Processing of content or additional data; Elementary server operations; Server middleware
- H04N21/231—Content storage operation, e.g. caching movies for short term storage, replicating data over plural servers, prioritizing data for deletion
Landscapes
- Engineering & Computer Science (AREA)
- Databases & Information Systems (AREA)
- Multimedia (AREA)
- Signal Processing (AREA)
- Theoretical Computer Science (AREA)
- Data Mining & Analysis (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Two-Way Televisions, Distribution Of Moving Picture Or The Like (AREA)
Abstract
The embodiment of the application discloses a live broadcast data processing method, a device, equipment and a storage medium, wherein the method comprises the following steps: acquiring live broadcast information of a live broadcast room through live broadcast room distribution service, and distributing live broadcast storage service in a preset area for the live broadcast room according to the live broadcast information; the machine room of the live broadcast content of the live broadcast room in the preset area is subjected to periodic full-quantity storage through the live broadcast storage service; when a video recording request is detected through the video calling service, the video file of the corresponding live broadcast content is transferred to storage equipment in the same area as the video recording request initiating terminal, and is used for feedback when being called. The scheme reduces the overall cost of the system, has high reliability and availability, is non-invasive to the original media service system, obviously reduces the flow cost and reduces the storage cost.
Description
Technical Field
The embodiment of the application relates to the technical field of computers, in particular to a live broadcast data processing method, a live broadcast data processing device, live broadcast data processing equipment and a storage medium.
Background
In the field of live broadcast application content monitoring and auditing, aiming at risk and violation identification of live broadcast content of a user, a live broadcast room with violation risk is generally identified based on live broadcast picture machine identification, live broadcast voice segmentation machine identification, user reporting and other strategy identification, an auditing platform to-be-audited work order is written, and then a content security monitoring team carries out live broadcast content violation judgment.
In the prior art, when an auditor audits and judges a risk live broadcast room, the auditor can only monitor the live broadcast room backwards from a time node for starting audit to confirm whether illegal actions exist, and the content before the auditing time point can only be judged from live broadcast screenshot, so that the problems that the live broadcast screenshot sequence has time intervals and the illegal actions of the flash type can be missed are solved, meanwhile, the live broadcast screenshot content form lacks audio, and the illegal actions of the voice type can be missed. In addition, after the audit processing is performed on the illegal live broadcast, the complaint and customer service processing flow and the audit quality inspection flow of the punished user are also involved, corresponding evidence is needed for checking when the customer complaints are processed and the audit quality is inspected, and a reasonable and efficient processing mechanism is lacked in the existing live broadcast data processing mode to meet the requirements.
Disclosure of Invention
The embodiment of the application provides a live broadcast data processing method, a device, equipment and a storage medium, which solve the problems of low live broadcast monitoring and review efficiency and poor effect in the prior art, reduce the overall cost of a system, have high reliability and availability, do not invade an original media service system, obviously reduce the flow cost and reduce the storage cost.
In a first aspect, an embodiment of the present application provides a live broadcast data processing method, where the method includes:
acquiring live broadcast information of a live broadcast room through live broadcast room distribution service, and distributing live broadcast storage service in a preset area for the live broadcast room according to the live broadcast information;
the machine room of the live broadcast content of the live broadcast room in the preset area is subjected to periodic full-quantity storage through the live broadcast storage service;
when a video recording request is detected through the video calling service, the video file of the corresponding live broadcast content is transferred to storage equipment in the same area as the video recording request initiating terminal, and is used for feedback when being called.
In a second aspect, an embodiment of the present application further provides a live broadcast data processing apparatus, including:
the distribution module is used for acquiring the live broadcast information of the live broadcast room and distributing live broadcast storage services in a preset area to the live broadcast room according to the live broadcast information;
the storage module is used for carrying out periodic full-quantity storage on the live broadcast content in the live broadcast room;
and the calling module is used for transferring the video file of the corresponding live broadcast content to the storage equipment in the same area as the video recording request initiating terminal when the video recording request is detected, and carrying out feedback when the video file is called.
In a third aspect, an embodiment of the present application further provides a live broadcast data processing apparatus, including:
one or more processors;
storage means for storing one or more programs,
when the one or more programs are executed by the one or more processors, the one or more processors implement the live data processing method according to the embodiment of the present application.
In a fourth aspect, embodiments of the present application also provide a storage medium storing computer-executable instructions that, when executed by a computer processor, are configured to perform the live data processing method according to the embodiments of the present application.
In the embodiment of the application, the live broadcast information of the live broadcast room is acquired through the live broadcast room distribution service, the live broadcast storage service in the preset area is distributed for the live broadcast room according to the live broadcast information, the live broadcast content of the live broadcast room is subjected to periodic full-scale storage through the live broadcast storage service, and when the video recording request is detected through the video calling service, the corresponding video file is transferred to the storage equipment in the same area as the video recording request initiating terminal for feedback when being called, so that the integral cost of the system is reduced, the reliability and the availability are high, the intrusion to the original media service system is avoided, the flow cost is obviously reduced, and the storage cost is reduced.
Drawings
Fig. 1 is a flowchart of a live broadcast data processing method according to an embodiment of the present application;
fig. 2 is a flowchart of another live data processing method according to an embodiment of the present application;
fig. 3 is a flowchart of another live data processing method according to an embodiment of the present application;
fig. 4 is a flowchart of another live data processing method according to an embodiment of the present application;
fig. 5 is a flowchart of another live data processing method according to an embodiment of the present application;
fig. 6 is a flowchart of another live data processing method according to an embodiment of the present application;
fig. 7 is a block diagram of a live broadcast data processing device according to an embodiment of the present application;
fig. 8 is a schematic structural diagram of a live broadcast data processing device according to an embodiment of the present application.
Detailed Description
Embodiments of the present application will be described in further detail below with reference to the drawings and examples. It should be understood that the particular embodiments described herein are illustrative only and are not limiting of embodiments of the application. It should be further noted that, for convenience of description, only some, but not all of the structures related to the embodiments of the present application are shown in the drawings.
The terms first, second and the like in the description and in the claims, 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 data so used may be interchanged, as appropriate, such that embodiments of the present application may be implemented in sequences other than those illustrated or described herein, and that the objects identified by "first," "second," etc. are generally of a type, and are not limited to the number of objects, such as the first object may be one or more. Furthermore, in the description and claims, "and/or" means at least one of the connected objects, and the character "/", generally means that the associated object is an "or" relationship.
Fig. 1 is a flowchart of a live data processing method provided in an embodiment of the present application, which may be applied to recording and review live data, where the method may be executed by a server, and specifically includes the following steps:
and step S101, acquiring live broadcast information of a live broadcast room through a live broadcast room distribution service, and distributing live broadcast storage service in a preset area for the live broadcast room according to the live broadcast information.
The live broadcast room distribution service is used for acquiring live broadcast information of the live broadcast room. The live broadcast room is a network live broadcast program started by a live broadcast user in a live broadcast scene. The live information is used for representing the live condition of the live broadcasting room, such as the ID of the live broadcasting room, the live broadcasting start time, the live broadcasting end time and the like. The live broadcast room distribution service may be one of services in a system operated by a server, and in one embodiment, after the live broadcast room distribution service is opened online, the live broadcast room distribution service is registered in a media live broadcast room management service, where the media live broadcast room management service is used for implementing management on a live broadcast room. The live broadcasting room distribution service can continuously acquire the live broadcasting information such as notification pushing of the live broadcasting room management service on the switch broadcasting of each live broadcasting room.
After the live broadcast information of the live broadcast room is obtained, the live broadcast room distribution service distributes live broadcast storage service in a preset area for the live broadcast room according to the live broadcast information. The live broadcast preservation service is used for realizing the storage of live broadcast contents in a live broadcast room. In one embodiment, the live broadcast room distribution service distributes live broadcast preservation services in a preset area for the live broadcast room through calculation, wherein the preset area specifically comprises live broadcast preservation services running on equipment in the same machine room as the live broadcast room media server.
And step S102, performing periodic full-quantity storage on the machine room of the live broadcast content of the live broadcast room in the preset area through the live broadcast storage service.
After the live broadcast preservation service is distributed to the live broadcast room, live broadcast content of the live broadcast room is obtained through the live broadcast preservation service and stored in a machine room in a preset area. The full-volume storage refers to uninterrupted storage of live contents in a live broadcasting room, namely continuous storage of the live contents. Periodic full storage refers to the full storage of live content over a fixed periodic time interval, which may be a reasonable value, such as 15 minutes or 1 hour, etc., set according to the business and acceptable cost ranges.
In one embodiment, the period of storing the live content may be a dynamically adjusted value based on machine cost and live peak, e.g., the value of the period may be adaptively reduced when the number of peaks is greater, i.e., the number of live rooms is greater, or may be increased otherwise. And deleting the outdated live content data when the stored live content exceeds the set period value.
Step S103, when a video recording request is detected through a video calling service, the video file of the corresponding live broadcast content is transferred to a storage device in the same area as the video recording request initiating terminal, and is used for feedback when being called.
The video recording request can be a request sent by an auditing system for auditing live content. In one embodiment, the video call service provides an API to obtain live content data of the live room, and the caller can record and review live content using the live room ID, the start and end times of the desired live content as request parameters. The specific APIs may include a notification recording API and a review video API, which implement calls for recording and review of live content, respectively.
In one embodiment, when the video call service detects a video recording request, the video call service broadcasts the video recording request to each room to regularly pull live video clip data that meets the condition, wherein the specific condition may be a specific time period of a specific live room. And the video file requested to be recorded by the video recording request is transferred to a storage device in the same area as the video recording request initiating terminal. Wherein the same region may be the same large region, such as asian, american or african, etc.
According to the scheme, the live broadcast data processing method provided by the scheme realizes the storage of live broadcast contents in a general scheme which is non-invasive, low in cost and high in reliability and availability for the existing media service system. The live content is periodically stored in the same machine room in full, so that the flow consumption is obviously reduced, and the recording cost is greatly reduced. Through corresponding to the appointed video recording request, the corresponding video file is permanently transferred to the storage equipment in the same area, so that the permanent archiving of important video content is ensured, and meanwhile, in order to reduce the problems of poor fluency and poor stability caused by trans-regional network transmission when an auditor requests to review video, the important video file is transferred to the storage equipment in the same area, and the overall cost and the performance are balanced.
Fig. 2 is a flowchart of another live broadcast data processing method provided by an embodiment of the present application, which provides a specific service allocation scheme, including:
and step S201, acquiring an IP address and a live broadcasting room ID of a media server accessed by the live broadcasting room through a live broadcasting room allocation service, determining a machine room corresponding to the live broadcasting room according to the IP address, and performing consistent hash operation calculation according to the live broadcasting room ID to obtain live broadcasting storage service allocated to the live broadcasting room and having the same machine room.
The live broadcast information comprises an IP address of a media server accessed by the live broadcast room and an ID of the live broadcast room. The IP of the accessed media server is a server for recording live broadcast contents of a live broadcast room and providing data for live broadcast watching users, and the ID of the live broadcast room is used for carrying out unique identification on the live broadcast room. And determining a machine room for recording live broadcast contents of the live broadcast room according to the IP address of the media server, and distributing live broadcast storage services of the same machine room to the live broadcast room. Optionally, the machine room where the machine room is located can be determined according to the IP address through a preset interface, for example, it is determined that the machine room is the machine room No. 01 in the vietnamese area of asia area.
Specifically, when live broadcast preservation service distribution is performed, a consistent hash operation is performed according to the ID of the live broadcast room to obtain the live broadcast preservation service distributed for the live broadcast room and in the same machine room. The purpose of the consistent Hash operation is to transfer data as little as possible when the number of nodes of the live video storage service is changed, all the nodes are arranged on a Hash ring connected end to end, and each key can find adjacent nodes clockwise after Hash is calculated. And when a node joins or leaves, only the subsequent nodes of the node adjacent clockwise on the Hash ring are affected.
And step S202, performing periodic full-quantity storage on the machine room of the live broadcast content of the live broadcast room in the preset area through the live broadcast storage service.
Step 203, when a video recording request is detected through a video calling service, the video file of the corresponding live broadcast content is transferred to a storage device in the same area as the video recording request initiating terminal, and is used for feedback when being called.
According to the scheme, the live broadcast preservation service distributed for the live broadcast room and distributed in the same machine room is obtained through consistent hash operation, so that multi-instance distributed deployment of the live broadcast video preservation service is realized, and high availability of functions is ensured. Meanwhile, according to the IP address of the media server accessed by the live broadcasting room, the live broadcasting content storage is determined in the machine room corresponding to the live broadcasting room, so that the flow consumption is obviously reduced, and the recording cost is reduced.
Fig. 3 is a flowchart of another live broadcast data processing method provided in an embodiment of the present application, and provides a method for triggering live broadcast data storage, including:
step S301, acquiring the broadcasting information and the ID of the live broadcasting room through the live broadcasting room distribution service, and distributing the live broadcasting storage service in a preset area for the live broadcasting room according to the live broadcasting information.
And step S302, generating an open broadcasting information pushing request according to the open broadcasting information and the live broadcasting room ID, and sending the open broadcasting information pushing request to the live broadcasting storage service.
In one embodiment, after a live broadcast storage service is distributed to a live broadcast room, after the live broadcast room distribution service obtains the open broadcast information, a push request containing the open broadcast information and the live broadcast room ID open broadcast information is generated and sent to the live broadcast storage service, so that the live broadcast storage service is triggered to record live broadcast contents of the live broadcast room. When the live broadcasting is carried out in the live broadcasting room, the recording of the live broadcasting content is automatically realized.
And step 303, performing periodic full-quantity storage on the machine room of the live broadcast content of the live broadcast room in the preset area through the live broadcast storage service.
Step S304, when a video recording request is detected through a video calling service, the video file of the corresponding live broadcast content is transferred to a storage device in the same area as the video recording request initiating terminal, and is used for feedback when being called.
According to the scheme, the live broadcast data processing method provided by the scheme realizes the storage of live broadcast contents in a general scheme which is non-invasive, low in cost and high in reliability and availability for the existing media service system. The live content can be automatically and periodically stored in the same machine room in full, so that the flow consumption is obviously reduced, and the recording cost is greatly reduced. Through corresponding to the appointed video recording request, the corresponding video file is permanently transferred to the storage equipment in the same area, so that the permanent archiving of important video content is ensured, and meanwhile, in order to reduce the problems of poor fluency and poor stability caused by trans-regional network transmission when an auditor requests to review video, the important video file is transferred to the storage equipment in the same area, and the overall cost and the performance are balanced.
Fig. 4 is a flowchart of another live broadcast data processing method provided by an embodiment of the present application, and provides a method for storing live broadcast content, including:
and S401, acquiring live broadcast information of a live broadcast room through a live broadcast room distribution service, and distributing live broadcast storage service in a preset area for the live broadcast room according to the live broadcast information.
And step S402, generating an open broadcasting information pushing request according to the open broadcasting information and the live broadcasting room ID, and sending the open broadcasting information pushing request to the live broadcasting storage service.
Step S403, requesting a service based on a geographic position according to the ID of the live broadcasting room to obtain a low-load media server, and continuously updating the index file of the live broadcasting room from the media server according to a stream media transmission protocol with an adaptive code rate.
The service based on the geographic position is to acquire the current position of the positioning equipment by utilizing various positioning technologies, and provide information resources and basic services for the positioning equipment through a mobile internet. The system integrates various information technologies such as mobile communication, internet, space positioning, position information, big data and the like, and utilizes the mobile internet service platform to update and interact data, so that a user can acquire corresponding service through space positioning.
In one embodiment, after receiving the open play information push request, the live video save service requests lbs (Location Based Services, geographic location based service) according to the ID of the living room recorded in the open play information push request to obtain a low-load media server, and continuously updates an index file (e.g., an m3u8 index file) of the living room at the media server according to the adaptive bitrate streaming media transmission protocol. It should be noted that, besides the adaptive rate streaming media transmission protocol, other media live streaming protocols, such as rtmp protocol and rtsp protocol, may also be used.
And step S404, acquiring newly generated live video clip information based on the index file, and performing periodic full-scale storage on live data based on the live video clip information.
Further, after updating the index file of the live broadcasting room, the newly generated live video clip information is obtained based on the index file of the live broadcasting room. The live video clip information includes a file address (such as a TS live video slice data address) of a live video clip, and a start time and an end time of the live video clip. And after the live broadcast segment information is determined, downloading and uploading live broadcast data based on the live broadcast segment information, and periodically storing the live broadcast data in the same machine room in a full-quantity manner in a storage cluster manner. Meanwhile, the addresses of the live broadcast data are stored in a Redis cache of the same machine room.
Step 405, when a video recording request is detected through a video calling service, the video file of the corresponding live broadcast content is transferred to a storage device in the same area as the video recording request initiating terminal, and is used for feedback when being called.
According to the scheme, when live broadcast data is stored, component technologies such as Redis clusters and distributed file storage clusters are adopted, a stateless distributed design scheme is adopted, the problem that live broadcast video data is lost possibly caused by single-point faults is avoided, and the whole system has the characteristics of high availability, high reliability and flexible horizontal expansion.
Fig. 5 is a flowchart of another live data processing method provided by an embodiment of the present application, and provides a method for recording live content, including:
step S501, acquiring live broadcast information of a live broadcast room through live broadcast room distribution service, and distributing live broadcast storage service in a preset area for the live broadcast room according to the live broadcast information.
Step S502, generating an open broadcasting information push request according to the open broadcasting information and the live broadcasting room ID, and sending the open broadcasting information push request to the live broadcasting storage service.
Step S503, requesting a service based on a geographic location according to the live broadcast room ID to obtain a low-load media server, and continuously updating the index file of the live broadcast room from the media server according to the adaptive code rate streaming media transmission protocol.
And step S504, acquiring newly generated live video clip information based on the index file, and performing periodic full-scale storage on live data based on the live video clip information.
Step S505, when a video recording request is detected through a video calling service, the Redis caches of all large areas are polled, the file address of a live video corresponding to the video recording request is determined, local downloading and merging of video data are carried out according to the file address of the live video, and the video data are uploaded to storage equipment in the same area as the initiating end of the video recording request and used for feedback when being called.
When a video recording request is detected, the Redis caches of all the machine rooms of all the large areas are polled, and the file address of the live video corresponding to the video recording request is determined. The video recording request can be a request sent by an auditing system for auditing live content. The video calling service provides an API for video recording and review to the outside, and can be used for users and staff to call, for example, a calling party can use a live broadcast room ID, live broadcast starting time and live broadcast ending time of desired recording and review as request parameters. When receiving a video recording request, the video calling service starts a timing task and responds to the video recording request. Specifically, the timing task acquires a file address of a live video meeting the conditions, such as meeting the conditions of ID of a live broadcasting room, the starting time of the live broadcasting and the ending time of the live broadcasting, from a global Redis instance, and transfers corresponding video data and relevant information of the file address to a storage device in the same area of an initiating terminal.
According to the scheme, aiming at the live video which is requested to be recorded and used for being reviewed, the distributed file storage cluster which is uploaded to the same area as the auditing system by crossing the machine room is adopted, so that cross-regional network transmission of auditing personnel when the video is reviewed is reduced, smooth experience and stability of video loading are improved, and balance is achieved in cost and performance experience.
Fig. 6 is a flowchart of another live data processing method provided by an embodiment of the present application, which provides a process for stopping live content storage update, including:
and step S601, acquiring live broadcast information of a live broadcast room through live broadcast room distribution service, and distributing live broadcast storage service in a preset area for the live broadcast room according to the live broadcast information.
And step S602, generating an open broadcasting information pushing request according to the open broadcasting information and the live broadcasting room ID, and sending the open broadcasting information pushing request to the live broadcasting storage service.
And step 603, performing periodic full-quantity storage on the machine room of the live broadcast content of the live broadcast room in the preset area through the live broadcast storage service.
Step S604, when a video recording request is detected through a video calling service, the video file of the corresponding live broadcast content is transferred to a storage device in the same area as the video recording request initiating terminal, and is used for feedback when being called.
And step 605, generating a downloading information pushing request according to the downloading information and the live broadcasting room ID, and sending the downloading information pushing request to the live broadcasting storage service, wherein the live broadcasting storage service stops updating and storing the live broadcasting content of the live broadcasting room after receiving the downloading information pushing request.
In one embodiment, when the live content of the live broadcasting room stops, such as when the main broadcasting is in a downcast state, the live broadcasting room distribution service generates a downcast information push request according to the downcast information and the live broadcasting room ID and sends the downcast information push request to the live broadcasting storage service to stop updating and storing the live content of the live broadcasting room. By adopting the notification mode, the automatic periodic storage of the live broadcast data is realized. In one embodiment, the live broadcast saving service detects whether an on-broadcast or an off-broadcast notification is received at intervals of a preset time by starting a timing task, if the on-broadcast notification is not detected, the execution of the timing task is stopped, and if the on-broadcast notification is received, the latest index content is continuously acquired, and the update and the uploading of the live broadcast video content are performed.
According to the scheme, automatic live broadcast data storage and updating are realized by detecting the on-air and off-air notification of the live broadcast room through the timing task, the whole-course live broadcast video recording of the on-line anchor of the whole network can be performed at the server, the dependence on the client is avoided, the recording end is used as a viewer to acquire the live broadcast video data by using a protocol provided by the media, and the invasive adjustment and transformation of the media service are also avoided.
On the basis of the technical scheme, after the video file of the corresponding live broadcast content is transferred to the storage device in the same area as the video recording request initiating terminal, the method further comprises the following steps: and calling the corresponding media video to feed back according to the detected video review request, wherein the video review request and the video recording request have the same request parameters. Illustratively, the parameters included in the review request include a live room ID, a start time and an end time at which review is desired, and the like. After the video file is transferred to the storage device in the same area as the video recording request initiating terminal, the smoothness of video review is obviously improved in response to the review request.
Fig. 7 is a block diagram of a live broadcast data processing device according to an embodiment of the present application, where the device is configured to execute the live broadcast data processing method provided in the foregoing embodiment, and the device has corresponding functional modules and beneficial effects of the execution method. As shown in fig. 7, the apparatus specifically includes: an allocation module 101, a save module 102, and a retrieval module 103, wherein,
the distribution module 101 is configured to obtain live broadcast information of a live broadcast room, and distribute a live broadcast storage service in a preset area for the live broadcast room according to the live broadcast information;
a saving module 102, configured to periodically store the total content of the live broadcast room;
and the calling module 103 is used for transferring the video file of the corresponding live broadcast content to the storage equipment in the same area as the video recording request initiating terminal when the video recording request is detected, and is used for carrying out feedback when the video recording request is called.
According to the scheme, the live broadcast information of the live broadcast room is obtained through the live broadcast room distribution service, the live broadcast storage service in the preset area is distributed for the live broadcast room according to the live broadcast information, the live broadcast content of the live broadcast room is subjected to periodic full-scale storage through the live broadcast storage service, when the video recording request is detected through the video calling service, the corresponding video file is transferred to the storage equipment in the same area as the video recording request initiating end for feedback when being called, the integral cost of the system is reduced, the reliability and the availability are high, the intrusion to the original media service system is avoided, the flow cost is obviously reduced, and the storage cost is reduced.
In one possible embodiment, the live broadcast information includes an IP address of a media server accessed by the live broadcast room and a live broadcast room ID, and the allocating, according to the live broadcast information, a live broadcast storage service in a preset area to the live broadcast room includes:
determining a machine room corresponding to the live broadcasting room according to the IP address;
and carrying out consistent hash operation according to the live broadcast room ID to obtain the live broadcast preservation service distributed for the live broadcast room and in the same machine room.
In one possible embodiment, the live broadcast information includes a live broadcast information and a live broadcast room ID of the live broadcast room, and after a live broadcast preservation service in a preset area is allocated to the live broadcast room according to the live broadcast information, the method further includes:
and generating an open broadcasting information push request according to the open broadcasting information and the live broadcasting room ID, and sending the open broadcasting information push request to the live broadcasting storage service.
In one possible embodiment, the storing, by the live saving service, the live content of the live broadcasting room in a machine room in the preset area in a full amount periodically includes:
requesting a geographic location-based service to obtain a low-load media server according to the live broadcast room ID;
continuously updating the index file of the live broadcasting room from the media server according to the self-adaptive code rate streaming media transmission protocol;
and acquiring newly generated live video segment information based on the index file, and performing periodic full-scale storage on live data based on the live video segment information, wherein the address of the live data is stored in a Redis cache of the same machine room, and the live data is stored in a storage cluster of the same machine room.
In one possible embodiment, the transferring the video file of the corresponding live content to the storage device in the same area as the video recording request initiating end includes:
polling the Redis caches of all the large areas, and determining the file address of the live video corresponding to the video recording request;
and carrying out local downloading and merging of video data according to the file address of the live video, and uploading the video data to storage equipment in the same area as the video recording request initiating terminal.
In one possible embodiment, the live broadcast information includes a down-cast information of the live broadcast room, and after generating an open broadcast information push request according to the open broadcast information and the live broadcast room ID, the method further includes:
generating a downloading information pushing request according to the downloading information and the live broadcasting room ID, and sending the downloading information pushing request to the live broadcasting storage service;
and after receiving the downloading information pushing request, the live broadcast storage service stops updating and storing the live broadcast content in the live broadcast room.
In one possible embodiment, after the video file of the corresponding live content is transferred to the storage device in the same area as the video recording request initiating end, the method further includes:
and calling the corresponding media video to feed back according to the detected video review request, wherein the video review request and the video recording request have the same request parameters.
Fig. 8 is a schematic structural diagram of a live broadcast data processing apparatus according to an embodiment of the present application, where, as shown in fig. 8, the apparatus includes a processor 201, a memory 202, an input device 203, and an output device 204; the number of processors 201 in the device may be one or more, one processor 201 being taken as an example in fig. 8; the processor 201, memory 202, input devices 203, and output devices 204 in the apparatus may be connected by a bus or other means, for example in fig. 8. The memory 202 is used as a computer readable storage medium for storing software programs, computer executable programs and modules, such as program instructions/modules corresponding to the live data processing method in the embodiment of the present application. The processor 201 executes various functional applications of the device and data processing, i.e., implements the live data processing method described above, by running software programs, instructions, and modules stored in the memory 202. The input means 203 may be used to receive entered numeric or character information and to generate key signal inputs related to user settings and function control of the device. The output device 204 may include a display device such as a display screen.
The embodiment of the present application further provides a storage medium containing computer executable instructions, which when executed by a computer processor, are configured to perform a live data processing method described in the foregoing embodiment, and specifically includes:
acquiring live broadcast information of a live broadcast room through live broadcast room distribution service, and distributing live broadcast storage service in a preset area for the live broadcast room according to the live broadcast information;
the machine room of the live broadcast content of the live broadcast room in the preset area is subjected to periodic full-quantity storage through the live broadcast storage service;
when a video recording request is detected through the video calling service, the video file of the corresponding live broadcast content is transferred to storage equipment in the same area as the video recording request initiating terminal, and is used for feedback when being called.
It should be noted that, in the embodiment of the live broadcast data processing apparatus, each unit and module included are only divided according to the functional logic, but not limited to the above division, so long as the corresponding functions can be implemented; in addition, the specific names of the functional units are also only for distinguishing from each other, and are not used to limit the protection scope of the embodiments of the present application.
Note that the above is only a preferred embodiment of the present application and the technical principle applied. It will be understood by those skilled in the art that the embodiments of the present application are not limited to the particular embodiments described herein, but are capable of numerous obvious changes, rearrangements and substitutions without departing from the scope of the embodiments of the present application. Therefore, while the embodiments of the present application have been described in connection with the above embodiments, the embodiments of the present application are not limited to the above embodiments, but may include many other equivalent embodiments without departing from the spirit of the embodiments of the present application, and the scope of the embodiments of the present application is determined by the scope of the appended claims.
Claims (10)
1. The live broadcast data processing method is characterized by comprising the following steps of:
acquiring live broadcast information of a live broadcast room through live broadcast room distribution service, and distributing live broadcast storage service in a preset area for the live broadcast room according to the live broadcast information;
the machine room of the live broadcast content of the live broadcast room in the preset area is subjected to periodic full-quantity storage through the live broadcast storage service;
when a video recording request is detected through the video calling service, the video file of the corresponding live broadcast content is transferred to storage equipment in the same area as the video recording request initiating terminal, and is used for feedback when being called.
2. The live broadcast data processing method according to claim 1, wherein the live broadcast information includes an IP address and a live broadcast room ID of a media server accessed by the live broadcast room, and the allocating a live broadcast storage service in a preset area to the live broadcast room according to the live broadcast information includes:
determining a machine room corresponding to the live broadcasting room according to the IP address;
and carrying out consistent hash operation according to the live broadcast room ID to obtain the live broadcast preservation service distributed for the live broadcast room and in the same machine room.
3. The live data processing method according to claim 1, wherein the live information includes a live room ID and a live room on-air information of the live room, and further comprising, after assigning a live saving service within a preset area to the live room according to the live information:
and generating an open broadcasting information push request according to the open broadcasting information and the live broadcasting room ID, and sending the open broadcasting information push request to the live broadcasting storage service.
4. A live data processing method according to claim 3, wherein the performing, by the live saving service, periodic full-size storage of live content of the live room in a room within the preset area includes:
requesting a geographic location-based service to obtain a low-load media server according to the live broadcast room ID;
continuously updating the index file of the live broadcasting room from the media server according to the self-adaptive code rate streaming media transmission protocol;
and acquiring newly generated live video segment information based on the index file, and performing periodic full-scale storage on live data based on the live video segment information, wherein the address of the live data is stored in a Redis cache of the same machine room, and the live data is stored in a storage cluster of the same machine room.
5. The live data processing method according to claim 4, wherein the step of transferring the video file of the corresponding live content to the storage device in the same area as the video recording request initiator includes:
polling the Redis caches of all the large areas, and determining the file address of the live video corresponding to the video recording request;
and carrying out local downloading and merging of video data according to the file address of the live video, and uploading the video data to storage equipment in the same area as the video recording request initiating terminal.
6. A live data processing method according to claim 3, wherein the live information includes the downcast information of the live room, and further comprising, after generating an open information push request according to the open information and the live room ID:
generating a downloading information pushing request according to the downloading information and the live broadcasting room ID, and sending the downloading information pushing request to the live broadcasting storage service;
and after receiving the downloading information pushing request, the live broadcast storage service stops updating and storing the live broadcast content in the live broadcast room.
7. The live data processing method according to claim 1, further comprising, after transferring the video file of the corresponding live content to a storage device in the same area as the video recording request originating terminal:
and calling the corresponding media video to feed back according to the detected video review request, wherein the video review request and the video recording request have the same request parameters.
8. Live broadcast data processing apparatus, characterized by comprising:
the distribution module is used for acquiring the live broadcast information of the live broadcast room and distributing live broadcast storage services in a preset area to the live broadcast room according to the live broadcast information;
the storage module is used for carrying out periodic full-quantity storage on the live broadcast content in the live broadcast room;
and the calling module is used for transferring the video file of the corresponding live broadcast content to the storage equipment in the same area as the video recording request initiating terminal when the video recording request is detected, and carrying out feedback when the video file is called.
9. A live data processing apparatus, the apparatus comprising: one or more processors; storage means for storing one or more programs which when executed by the one or more processors cause the one or more processors to implement the live data processing method of any of claims 1-7.
10. A storage medium storing computer executable instructions which, when executed by a computer processor, are for performing the live data processing method of any of claims 1-7.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111620154.7A CN114501044B (en) | 2021-12-23 | 2021-12-23 | Live broadcast data processing method, device, equipment and storage medium |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111620154.7A CN114501044B (en) | 2021-12-23 | 2021-12-23 | Live broadcast data processing method, device, equipment and storage medium |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN114501044A CN114501044A (en) | 2022-05-13 |
| CN114501044B true CN114501044B (en) | 2023-12-08 |
Family
ID=81496218
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202111620154.7A Active CN114501044B (en) | 2021-12-23 | 2021-12-23 | Live broadcast data processing method, device, equipment and storage medium |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN114501044B (en) |
Families Citing this family (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN115883862A (en) * | 2022-11-11 | 2023-03-31 | 深圳市其乐游戏科技有限公司 | Automatic live recording method, server, system and storage medium |
| CN118803039A (en) * | 2024-09-12 | 2024-10-18 | 天翼视联科技有限公司 | Video stream push method, device, electronic device and storage medium |
Citations (12)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101854515A (en) * | 2010-05-14 | 2010-10-06 | 武汉宽信科技有限公司 | Television program remote recording method |
| CN105472010A (en) * | 2015-12-22 | 2016-04-06 | 彭维国 | Video-audio management platform system |
| CN109618180A (en) * | 2019-01-30 | 2019-04-12 | 网宿科技股份有限公司 | A kind of live broadcast data processing method, system and server |
| CN109787983A (en) * | 2019-01-24 | 2019-05-21 | 北京百度网讯科技有限公司 | Live stream slicing method, device and system |
| CN110267053A (en) * | 2019-06-27 | 2019-09-20 | 广州酷狗计算机科技有限公司 | Live broadcasting method, apparatus and system |
| CN110300339A (en) * | 2018-03-22 | 2019-10-01 | 贵州白山云科技股份有限公司 | Live multimedia playback method, device and system |
| CN111787404A (en) * | 2020-07-26 | 2020-10-16 | 易视腾科技股份有限公司 | Live stream playing method and device |
| CN112533010A (en) * | 2020-11-23 | 2021-03-19 | 北京北笛科技有限公司 | Automatic evidence obtaining method and device for audio and video data in network live broadcast service |
| CN113132746A (en) * | 2021-04-16 | 2021-07-16 | 北京北笛科技有限公司 | Automatic evidence obtaining method and device for audio and video data in network live broadcast service |
| CN113542896A (en) * | 2021-05-19 | 2021-10-22 | 广州速启科技有限责任公司 | Free-view video live broadcast method, device and medium |
| CN113747188A (en) * | 2021-09-03 | 2021-12-03 | 百果园技术(新加坡)有限公司 | Link monitoring system and method for video live broadcast quality |
| CN113824986A (en) * | 2021-09-18 | 2021-12-21 | 北京云上曲率科技有限公司 | Context-based live broadcast audio auditing method and device, storage medium and equipment |
Family Cites Families (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US9491239B2 (en) * | 2014-01-31 | 2016-11-08 | Comcast Cable Communications, Llc | Methods and systems for processing data requests |
-
2021
- 2021-12-23 CN CN202111620154.7A patent/CN114501044B/en active Active
Patent Citations (12)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101854515A (en) * | 2010-05-14 | 2010-10-06 | 武汉宽信科技有限公司 | Television program remote recording method |
| CN105472010A (en) * | 2015-12-22 | 2016-04-06 | 彭维国 | Video-audio management platform system |
| CN110300339A (en) * | 2018-03-22 | 2019-10-01 | 贵州白山云科技股份有限公司 | Live multimedia playback method, device and system |
| CN109787983A (en) * | 2019-01-24 | 2019-05-21 | 北京百度网讯科技有限公司 | Live stream slicing method, device and system |
| CN109618180A (en) * | 2019-01-30 | 2019-04-12 | 网宿科技股份有限公司 | A kind of live broadcast data processing method, system and server |
| CN110267053A (en) * | 2019-06-27 | 2019-09-20 | 广州酷狗计算机科技有限公司 | Live broadcasting method, apparatus and system |
| CN111787404A (en) * | 2020-07-26 | 2020-10-16 | 易视腾科技股份有限公司 | Live stream playing method and device |
| CN112533010A (en) * | 2020-11-23 | 2021-03-19 | 北京北笛科技有限公司 | Automatic evidence obtaining method and device for audio and video data in network live broadcast service |
| CN113132746A (en) * | 2021-04-16 | 2021-07-16 | 北京北笛科技有限公司 | Automatic evidence obtaining method and device for audio and video data in network live broadcast service |
| CN113542896A (en) * | 2021-05-19 | 2021-10-22 | 广州速启科技有限责任公司 | Free-view video live broadcast method, device and medium |
| CN113747188A (en) * | 2021-09-03 | 2021-12-03 | 百果园技术(新加坡)有限公司 | Link monitoring system and method for video live broadcast quality |
| CN113824986A (en) * | 2021-09-18 | 2021-12-21 | 北京云上曲率科技有限公司 | Context-based live broadcast audio auditing method and device, storage medium and equipment |
Non-Patent Citations (2)
| Title |
|---|
| 基于安防视频的大规模存储录播系统研究;覃遵颖 等;;中国教育信息化(15);全文 * |
| 多媒体服务器集群系统节能建模与在线优化;胡晗 等;;信息与控制(01);全文 * |
Also Published As
| Publication number | Publication date |
|---|---|
| CN114501044A (en) | 2022-05-13 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US11863819B2 (en) | Content consumption monitoring | |
| US10631024B2 (en) | Intelligent video streaming system | |
| KR101432303B1 (en) | Bandwidth requesting apparatus, client apparatus, bandwidth requesting method, and recording medium | |
| US9729407B2 (en) | Distributed media resources in VoIP networks for providing services | |
| CN106488169B (en) | A kind of method, system and the relevant device of data transmission | |
| JP2014526763A (en) | Disaster recovery system and method | |
| US20130138649A1 (en) | Systems and methods for storing digital content | |
| WO2017096846A1 (en) | Method, apparatus and system for obtaining live broadcast | |
| CN114501044B (en) | Live broadcast data processing method, device, equipment and storage medium | |
| US20170332115A1 (en) | Video source access method and device | |
| CN107734350B (en) | Live broadcasting system and live broadcasting method | |
| US12155497B2 (en) | Live-custom recording | |
| CN110781149A (en) | Method, device, equipment and storage medium for managing live broadcast room information | |
| CN111654526A (en) | Load balancing method and system for streaming media server | |
| CN108551571B (en) | A monitoring video distribution method, device, system and distribution server | |
| CN108306923A (en) | A kind of live video method for uploading, device, electronic equipment and storage medium | |
| US11546212B2 (en) | Intelligent content server handling of client receipt disruptions | |
| CN119676162A (en) | Traffic scheduling method, device, storage medium and program product for multi-data center system | |
| US20170099333A1 (en) | Requesting and receiving a media stream within a networked system | |
| CN117056056A (en) | Task execution method and device, storage medium and electronic equipment | |
| CN112637258B (en) | Data processing method and system | |
| CN113347138B (en) | Transmission method, device, computer equipment and storage medium for transcoding data stream | |
| CN114143569A (en) | Webpage recording and live broadcasting method and system | |
| US11985072B2 (en) | Multimedia data stream processing method, electronic device, and storage medium | |
| CN113115065A (en) | Live broadcast-based data processing method and device |
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 |