CN110858829B - Video processing method, device and system, analysis server and transcoding server - Google Patents
Video processing method, device and system, analysis server and transcoding server Download PDFInfo
- Publication number
- CN110858829B CN110858829B CN201810958862.3A CN201810958862A CN110858829B CN 110858829 B CN110858829 B CN 110858829B CN 201810958862 A CN201810958862 A CN 201810958862A CN 110858829 B CN110858829 B CN 110858829B
- Authority
- CN
- China
- Prior art keywords
- transcoding
- code stream
- stream format
- node
- analysis
- 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
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/02—Protocols based on web technology, e.g. hypertext transfer protocol [HTTP]
- H04L67/025—Protocols based on web technology, e.g. hypertext transfer protocol [HTTP] for remote control or remote monitoring of applications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L65/00—Network arrangements, protocols or services for supporting real-time applications in data packet communication
- H04L65/60—Network streaming of media packets
- H04L65/75—Media network packet handling
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/10—Protocols in which an application is distributed across nodes in the network
- H04L67/1097—Protocols in which an application is distributed across nodes in the network for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS]
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04N—PICTORIAL COMMUNICATION, e.g. TELEVISION
- H04N7/00—Television systems
- H04N7/18—Closed-circuit television [CCTV] systems, i.e. systems in which the video signal is not broadcast
Landscapes
- Engineering & Computer Science (AREA)
- Signal Processing (AREA)
- Computer Networks & Wireless Communication (AREA)
- Multimedia (AREA)
- Compression Or Coding Systems Of Tv Signals (AREA)
Abstract
The embodiment of the invention provides a video processing method, a device and a system, an analysis server and a transcoding server, wherein the video processing method comprises the following steps: acquiring video data to be analyzed, wherein the current code stream format of the video data to be analyzed is a first code stream format; judging whether the first code stream format is contained in a preset code stream format, wherein the preset code stream format is a code stream format supported by an analysis server; if the first code stream format is not contained in the preset code stream format, sending a transcoding instruction to a transcoding server so that the transcoding server transcodes the code stream format of the video data to be analyzed into a second code stream format according to the transcoding instruction; and acquiring video data to be analyzed with a code stream format being a second code stream format, and decoding and subsequently analyzing the video data. In the video processing method of the embodiment of the invention, the transcoding instruction is sent to the transcoding server, so that the transcoding server converts the code stream format of the video data to be analyzed into the code stream format supported by the analysis server, and the application range of video analysis can be enlarged.
Description
Technical Field
The present invention relates to the field of image processing technologies, and in particular, to a video processing method, apparatus, system, analysis server, and transcoding server.
Background
With the development of computer vision technology, automatic classification and identification of images become possible. The video data are analyzed through the computer vision technology, so that the labor cost can be saved, the working intensity of workers is reduced, and the method is widely applied to various fields.
In video intelligent analysis application, video analysis and application are generally performed on video data acquired by a front-end camera of a monitoring platform through an analysis server, such as a video cloud structured server, on the basis of an existing monitoring platform system.
However, in the research of the inventor, it is found that the code stream format supported by the analysis server is single, and the code stream formats such as the coding format and the packaging format of the video data output by different front-end cameras are different, which may cause that the analysis server may not complete the video data processing when encountering the unsupported code stream format, and the application range of the video analysis based on the analysis server is limited.
Disclosure of Invention
Embodiments of the present invention provide a video processing method, an apparatus, a system, an analysis server, and a transcoding server, so as to increase an application range of video analysis. The specific technical scheme is as follows:
in a first aspect, an embodiment of the present invention provides a video processing method, which is applied to an analysis server, where the method includes:
acquiring video data to be analyzed, wherein the current code stream format of the video data to be analyzed is a first code stream format, and the code stream format comprises a coding format and a packaging format;
judging whether the first code stream format is contained in a preset code stream format, wherein the preset code stream format is a code stream format supported by the analysis server;
if the first code stream format is not contained in the preset code stream format, sending a transcoding instruction to a transcoding server so that the transcoding server transcodes the code stream format of the video data to be analyzed into a second code stream format according to the transcoding instruction, wherein the second code stream format is contained in the preset code stream format, and the transcoding instruction comprises an identifier of the video data to be analyzed;
and acquiring video data to be analyzed with the code stream format being the second code stream format, and decoding and subsequently analyzing the video data.
Optionally, after the sending the transcoding instruction to the transcoding server, the method further includes:
receiving a task identifier which is returned by the transcoding server and aims at the transcoding instruction;
the acquiring the video data to be analyzed with the code stream format being the second code stream format, and performing decoding and subsequent analysis, including:
querying whether the transcoding server completes transcoding of the video data to be analyzed or not through the task identifier;
if the transcoding server completes transcoding of the video data to be analyzed, acquiring a stream taking address of the transcoded video data to be analyzed;
and acquiring video data to be analyzed with a code stream format being the second code stream format according to the stream taking address, and decoding and subsequently analyzing the video data.
Optionally, the transcoding server includes a plurality of transcoding nodes, and the method further includes:
obtaining operation parameters of each transcoding node;
and managing the operation state of each transcoding node according to the operation parameters.
In a second aspect, an embodiment of the present invention provides a video processing method, which is applied to a transcoding server, where the method includes:
receiving a transcoding instruction sent by an analysis server, wherein the transcoding instruction comprises an identifier of video data to be analyzed;
acquiring the video data to be analyzed according to the identifier of the video data to be analyzed in the transcoding instruction;
transcoding the code stream format of the video data to be analyzed from a first code stream format to a second code stream format, wherein the second code stream format is a code stream format supported by the analysis server;
and sending the video data to be analyzed with the code stream format being the second code stream format.
Optionally, after the receiving the transcoding instruction sent by the analysis server, the method further includes:
and generating a task identifier aiming at the transcoding instruction, and sending the task identifier to an analysis server.
Optionally, the analysis server periodically sends a heartbeat packet to the transcoding server, and the method further includes:
and if the heartbeat packet is not received within the preset time length, stopping transcoding the video data to be analyzed.
In a third aspect, an embodiment of the present invention provides a video processing apparatus, located in an analysis server, where the apparatus includes:
the device comprises a first data acquisition module, a second data acquisition module and a video analysis module, wherein the first data acquisition module is used for acquiring video data to be analyzed, the current code stream format of the video data to be analyzed is a first code stream format, and the code stream format comprises a coding format and a packaging format;
the format judging module is used for judging whether the first code stream format is contained in a preset code stream format, wherein the preset code stream format is a code stream format supported by the analysis server;
a transcoding instruction sending module, configured to send a transcoding instruction to a transcoding server if the first code stream format is not included in the preset code stream format, so that the transcoding server transcodes the code stream format of the video data to be analyzed into a second code stream format according to the transcoding instruction, where the second code stream format is included in the preset code stream format, and the transcoding instruction includes an identifier of the video data to be analyzed;
and the second data acquisition module is used for acquiring the video data to be analyzed with the code stream format being the second code stream format, and decoding and subsequently analyzing the video data.
Optionally, the video processing apparatus located in the analysis server in the embodiment of the present invention further includes:
the identification receiving module is used for receiving the task identification which is returned by the transcoding server and aims at the transcoding instruction;
the second data acquisition module includes:
the transcoding query submodule is used for querying whether the transcoding server completes transcoding of the video data to be analyzed or not through the task identifier;
the address acquisition submodule is used for acquiring a stream taking address of the transcoded video data to be analyzed if the transcoding server completes transcoding of the video data to be analyzed;
and the data processing submodule is used for acquiring the video data to be analyzed with the code stream format being the second code stream format according to the stream taking address, and decoding and subsequently analyzing the video data.
Optionally, the transcoding server includes a plurality of transcoding nodes, and the apparatus further includes:
the operation parameter acquisition module is used for acquiring operation parameters of the transcoding nodes;
and the running state management module is used for managing the running state of each transcoding node according to the running parameters.
In a fourth aspect, an embodiment of the present invention provides a video processing apparatus, located at a transcoding server, where the apparatus includes:
the transcoding instruction receiving module is used for receiving a transcoding instruction sent by the analysis server, wherein the transcoding instruction comprises an identifier of video data to be analyzed;
a third data obtaining module, configured to obtain the video data to be analyzed according to the identifier of the video data to be analyzed in the transcoding instruction;
the transcoding module is used for transcoding the code stream format of the video data to be analyzed from a first code stream format into a second code stream format, wherein the second code stream format is a code stream format supported by the analysis server;
and the video data sending module is used for sending the video data to be analyzed with the code stream format being the second code stream format.
Optionally, the video processing apparatus located in the transcoding server in the embodiment of the present invention further includes:
and the task identifier sending module is used for generating a task identifier aiming at the transcoding instruction and sending the task identifier to the analysis server.
Optionally, the analysis server periodically sends a heartbeat packet to the transcoding server, where the apparatus further includes:
and the transcoding stopping module is used for stopping transcoding the video data to be analyzed if the heartbeat packet is not received within a preset time length.
In a fifth aspect, an embodiment of the present invention provides an analysis server, including a processor and a memory;
the memory is used for storing a computer program;
the processor is configured to implement the video processing method according to any one of the first aspect when executing the program stored in the memory.
In a sixth aspect, an embodiment of the present invention provides a transcoding server, including a processor and a memory;
the memory is used for storing a computer program;
the processor is configured to implement the video processing method according to any of the second aspects when executing the program stored in the memory.
In a seventh aspect, an embodiment of the present invention provides a video processing system, which includes the analysis server in any one of the fifth aspects and the transcoding server in any one of the sixth aspects.
In an eighth aspect, an embodiment of the present invention provides a computer-readable storage medium, where a computer program is stored in the computer-readable storage medium, and the computer program, when executed by a processor, implements the video processing method according to any one of the above first aspects.
In a ninth aspect, an embodiment of the present invention provides a computer-readable storage medium, where a computer program is stored in the computer-readable storage medium, and when the computer program is executed by a processor, the computer program implements the video processing method according to any one of the second aspects.
The video processing method, the video processing device, the video processing system, the analysis server and the transcoding server acquire video data to be analyzed, wherein the current code stream format of the video data to be analyzed is a first code stream format, and the code stream formats comprise a coding format and a packaging format; judging whether the first code stream format is contained in a preset code stream format, wherein the preset code stream format is a code stream format supported by an analysis server; if the first code stream format is not contained in the preset code stream format, sending a transcoding instruction to a transcoding server so that the transcoding server transcodes the code stream format of the video data to be analyzed into a second code stream format according to the transcoding instruction, wherein the second code stream format is contained in the preset code stream format, and the transcoding instruction comprises an identifier of the video data to be analyzed; and acquiring video data to be analyzed with a code stream format being a second code stream format, and decoding and subsequently analyzing the video data. The transcoding instruction is sent to the transcoding server, so that the transcoding server converts the code stream format of the video data to be analyzed into the code stream format supported by the analysis server, and the application range of video analysis can be enlarged. Of course, it is not necessary for any product or method to achieve all of the above-described advantages at the same time for practicing the invention.
Drawings
In order to more clearly illustrate the embodiments of the present invention or the technical solutions in the prior art, the drawings used in the description of the embodiments or the prior art will be briefly described below, it is obvious that the drawings in the following description are only some embodiments of the present invention, and for those skilled in the art, other drawings can be obtained according to the drawings without creative efforts.
Fig. 1 is a schematic flow chart of a video processing method applied to an analysis server according to an embodiment of the present invention;
fig. 2 is a schematic flowchart of a video processing method applied to a transcoding server according to an embodiment of the present invention;
FIG. 3 is a diagram of a video processing apparatus at an analysis server according to an embodiment of the present invention;
fig. 4 is a schematic diagram of a video processing apparatus at a transcoding server according to an embodiment of the present invention;
FIG. 5 is a schematic diagram of an analysis server according to an embodiment of the present invention;
FIG. 6 is a diagram of an encoding server according to an embodiment of the present invention;
FIG. 7 is a diagram of an image processing system according to an embodiment of the present invention;
FIG. 8 is a diagram illustrating an application scenario of the image processing system according to an embodiment of the present invention;
FIG. 9 is a first schematic diagram of a workflow of an image processing system according to an embodiment of the present invention;
FIG. 10 is another schematic diagram of an image processing system according to an embodiment of the present invention;
FIG. 11 is a second schematic diagram of a workflow of an image processing system according to an embodiment of the present invention;
FIG. 12 is a third exemplary flowchart of an image processing system according to an embodiment of the present invention.
Detailed Description
The technical solutions in the embodiments of the present invention will be clearly and completely described below with reference to the drawings in the embodiments of the present invention, and it is obvious that the described embodiments are only a part of the embodiments of the present invention, and not all of the embodiments. All other embodiments, which can be derived by a person skilled in the art from the embodiments given herein without making any creative effort, shall fall within the protection scope of the present invention.
In the related video processing method, the analysis server, such as a video cloud structured server, supports a single code stream format, which limits the application range of the analysis server, and how to increase the application range of the analysis server on the basis of the existing monitoring platform is a problem to be solved urgently
In view of this, an embodiment of the present invention provides a video processing method, which is applied to an analysis server, and referring to fig. 1, the method includes:
s101, video data to be analyzed is obtained, wherein the current code stream format of the video data to be analyzed is a first code stream format, and the code stream format comprises a coding format and a packaging format.
The video processing method applied to the analysis server in the embodiment of the present invention may be implemented by an analysis system, and the analysis system is any system capable of implementing the video processing method applied to the analysis server in the embodiment of the present invention. For example:
the analysis system may be an apparatus comprising: a processor, a memory, a communication interface, and a bus; the processor, the memory and the communication interface are connected through a bus and complete mutual communication; the memory stores executable program code; the processor runs a program corresponding to the executable program code by reading the executable program code stored in the memory for executing the video processing method applied to the analysis server of the embodiment of the present invention.
Optionally, the analysis system may be an analysis server, specifically, a video cloud structured server.
The analysis system may also be an application program for executing the video processing method applied to the analysis server according to the embodiment of the present invention when running.
The analysis system may also be a storage medium for storing executable code for performing the video processing method applied to the analysis server according to the embodiment of the present invention.
The analysis system obtains video data to be analyzed, for example, the analysis system obtains the video data to be analyzed from the monitoring platform. The analysis system selects a path of video data code stream for analysis, issues a stream-fetching command to the monitoring platform, the monitoring platform acquires the video data code stream from the database or the front-end camera and sends the video data code stream to the analysis server, and the analysis system acquires the video data to be analyzed through the analysis server. The current code stream format of the video data to be analyzed is a first code stream format, that is, the code stream format of the video data to be analyzed received by the analysis server and sent by the monitoring platform is the first code stream format. The code stream format at least comprises a coding format and a packaging format, and certainly can also comprise other parameters related to code stream identification, and can be set according to the actual situation.
And S102, judging whether the first code stream format is contained in a preset code stream format, wherein the preset code stream format is a code stream format supported by the analysis server.
The preset code stream format is a code stream format supported by the analysis server, and the analysis server can decapsulate and decode the video data in the preset code stream format. The analysis system judges whether the first code stream format is included in the preset code stream format, if so, transcoding is not carried out on the video data to be analyzed, and if not, transcoding is carried out on the video data to be analyzed.
S103, if the first code stream format is not contained in the preset code stream format, a transcoding instruction is sent to a transcoding server, so that the transcoding server transcodes the code stream format of the video data to be analyzed into a second code stream format according to the transcoding instruction, wherein the second code stream format is contained in the preset code stream format, and the transcoding instruction comprises an identifier of the video data to be analyzed.
The identification of the video data to be analyzed can be a stream taking address of the video data to be analyzed, the analysis system sends a transcoding instruction to the forwarding server, so that after the transcoding instruction is received by the transcoding server, the video data to be analyzed with the stream format being a first stream format is obtained according to the stream taking address, and the stream format of the video data to be analyzed is converted into a second stream format.
And S104, acquiring the video data to be analyzed with the code stream format being the second code stream format, and decoding and subsequently analyzing the video data.
The analysis system obtains the video data to be analyzed after being transcoded by the transcoding server (at this time, the code stream format of the video data to be analyzed is the second code stream format supported by the analysis server), and decodes and subsequently analyzes the video data to be analyzed through the analysis server.
In the embodiment of the invention, when the analysis server does not support the code stream format of the video data to be analyzed, the transcoding instruction is sent to the transcoding server so that the transcoding server converts the code stream format of the video data to be analyzed into the code stream format supported by the analysis server, and the application range of video analysis can be increased.
Optionally, after the sending the transcoding instruction to the transcoding server, the method further includes:
receiving a task identifier which is returned by the transcoding server and aims at the transcoding instruction;
after receiving the transcoding instruction, the transcoding server establishes a transcoding task, wherein the transcoding task is used for transcoding the code stream format of the video data to be analyzed into a second code stream format. And the transcoding server sends the task identifier of the transcoding task to the analysis server. The analysis system receives the task identification through the analysis server. Specifically, the task identifier may be a name or an ID of the transcoding task.
Correspondingly, the obtaining of the video data to be analyzed with the code stream format being the second code stream format, and the decoding and subsequent analysis include:
step one, whether the transcoding server completes transcoding of the video data to be analyzed is inquired through the task identifier.
The analysis system can judge whether the transcoding server completes transcoding of the video data to be analyzed or not by inquiring the transcoding state of the transcoding task corresponding to the task identifier. When the transcoding server does not finish transcoding of the video data to be analyzed, the transcoding state of the transcoding task corresponding to the task identifier is in an unfinished state, and after the transcoding server finishes transcoding of the video data to be analyzed, the transcoding state of the transcoding task corresponding to the task identifier is set to be in a finished state. When the transcoding state is the finished state, judging that the transcoding server finishes transcoding the video data to be analyzed; and when the transcoding state is an uncompleted state, judging that the transcoding server does not complete the transcoding of the video data to be analyzed.
And step two, if the transcoding server completes transcoding of the video data to be analyzed, acquiring a stream taking address of the transcoded video data to be analyzed.
After the analysis system queries the transcoding server to complete transcoding of the video data to be analyzed, a stream fetching address of the transcoded video data to be analyzed is obtained through the task identifier.
And step three, acquiring the video data to be analyzed with the code stream format being the second code stream format according to the stream taking address, and decoding and subsequently analyzing the video data.
In the embodiment of the invention, the transcoding state is conveniently monitored through the task identifier, and the video data to be analyzed is conveniently acquired through the streaming address.
Optionally, the transcoding server includes a plurality of transcoding nodes, and the method further includes:
step one, obtaining operation parameters of each transcoding node;
the transcoding server can be deployed in a cluster mode and comprises a plurality of transcoding nodes. Each transcoding node may be either a supervisory transcoding node (primary transcoding node) or an analytical transcoding node (secondary transcoding node). The cluster of the transcoding server can comprise a plurality of management transcoding nodes, and when the management service of the transcoding nodes has the addition analysis service, the transcoding nodes execute management work; and otherwise, when the transcoding node is not added with the analysis transcoding node and is added by other transcoding nodes, the transcoding node executes analysis service.
And the analysis system acquires the operating parameters of each transcoding node. The operation parameters of the transcoding node can comprise the residual load of the transcoding node, the managed node, the responsible task and the like.
And step two, managing the operation state of each transcoding node according to the operation parameters.
For example, the analysis system can control the transcoding server to add a transcoding child node IP, remove a transcoding child node IP, and delete all child nodes managed by the managed transcoding node, i.e., to break up the transcoding cluster on the managed transcoding node.
In the embodiment of the invention, the management of each transcoding node in the transcoding server can be realized, and the working efficiency of the transcoding server can be improved.
An embodiment of the present invention further provides a video processing method, applied to a transcoding server, referring to fig. 2, where the method includes:
s201, receiving a transcoding instruction sent by an analysis server, wherein the transcoding instruction comprises an identifier of video data to be analyzed.
The video processing method applied to the transcoding server in the embodiment of the invention can be realized by a transcoding system, and the transcoding system is any system capable of realizing the video processing method applied to the transcoding server in the embodiment of the invention. For example:
the transcoding system may be an apparatus comprising: a processor, a memory, a communication interface, and a bus; the processor, the memory and the communication interface are connected through a bus and complete mutual communication; the memory stores executable program code; the processor executes a program corresponding to the executable program code by reading the executable program code stored in the memory, so as to execute the video processing method applied to the transcoding server of the embodiment of the invention.
Optionally, the transcoding system may be a transcoding server.
The transcoding system may also be an application program for executing the video processing method applied to the transcoding server in the embodiment of the present invention when running.
The transcoding system may also be a storage medium for storing executable code for executing the video processing method applied to the transcoding server according to the embodiment of the present invention.
The analysis server acquires video data to be analyzed, judges whether the analysis server supports a first code stream format of the video data to be analyzed, and sends a transcoding instruction to the transcoding server if the analysis server does not support the first code stream format. Transcoding instructions sent by the analysis server are received by the transcoding server. The code stream format comprises a coding format and a packaging format.
And S202, acquiring the video data to be analyzed according to the identifier of the video data to be analyzed in the transcoding instruction.
The identification of the video data to be analyzed may be a name, ID, uniform identifier or address, etc. of the video data to be analyzed. For example, the transcoding system obtains the video data to be analyzed according to the address of the video data to be analyzed.
S203, transcoding the code stream format of the video data to be analyzed from a first code stream format to a second code stream format, wherein the second code stream format is a code stream format supported by the analysis server.
The first code stream format is a code stream format of the video data to be analyzed when the video data to be analyzed is obtained, that is, the code stream format of the video data to be analyzed in the monitoring platform is the first code stream format. Various coding and decoding modes and encapsulation and decapsulation modes are integrated in the transcoding server. And decapsulating and decoding the video data to be analyzed by the transcoding server in a decapsulating and decoding mode corresponding to the first code stream format, and encoding and encapsulating the video data to be analyzed in an encoding format and an encapsulating format of the second code stream format.
And S204, sending the video data to be analyzed with the code stream format being the second code stream format.
And the transcoding system sends the transcoded video data to be analyzed, namely the video data to be analyzed with the code stream format being the second code stream format, to the analysis server.
In the embodiment of the invention, the code stream format of the video data to be analyzed is converted into the second code stream format supported by the analysis server, so that the application range of video analysis can be enlarged.
Optionally, after receiving the transcoding instruction sent by the analysis server, the method further includes:
and generating a task identifier aiming at the transcoding instruction, and sending the task identifier to an analysis server.
After the transcoding server receives the transcoding instruction, the transcoding system establishes a transcoding task, and the transcoding task is used for transcoding the code stream format of the video data to be analyzed into a second code stream format. And the transcoding system sends the task identifier of the transcoding task to the analysis server through the transcoding server. Specifically, the task identifier may be a name or an ID of the transcoding task. The analysis system receives the task identifier through the analysis server, inquires whether the transcoding server completes transcoding of the video data to be analyzed or not according to the task identifier, and acquires the transcoded video data to be analyzed.
In the embodiment of the invention, the transcoding state is conveniently monitored through the task identifier, and the video data to be analyzed is conveniently acquired.
Optionally, the analysis server periodically sends a heartbeat packet to the transcoding server, and the method further includes:
and if the heartbeat packet is not received within a preset time length, stopping transcoding the video data to be analyzed.
The analysis server periodically sends the heartbeat packets to the transcoding server, and the sending period may be set according to actual conditions, for example, set to be 1 second, 10 seconds, or 2 minutes. The preset duration can be set according to actual conditions, but the preset duration should be longer than the duration of the period for sending the heartbeat packet. And if the transcoding server does not receive the heartbeat packet within the preset time, the transcoding system controls the transcoding server to stop transcoding the video data to be analyzed.
In the embodiment of the invention, the analysis server is not offline or down when the heartbeat packet is not received, the video data to be analyzed is transcoded continuously, and the analysis of the video data to be analyzed cannot be completed through the analysis server, so that the transcoding is stopped to save resources.
An embodiment of the present invention further provides a video processing apparatus, located in an analysis server, and referring to fig. 3, the apparatus includes:
a first data obtaining module 301, configured to obtain video data to be analyzed, where a current code stream format of the video data to be analyzed is a first code stream format, and the code stream format includes a coding format and a packaging format;
a format determining module 302, configured to determine whether the first code stream format is included in a preset code stream format, where the preset code stream format is a code stream format supported by the analysis server;
a transcoding instruction sending module 303, configured to send a transcoding instruction to a transcoding server if the first code stream format is not included in the preset code stream format, so that the transcoding server transcodes the code stream format of the video data to be analyzed into a second code stream format according to the transcoding instruction, where the second code stream format is included in the preset code stream format, and the transcoding instruction includes an identifier of the video data to be analyzed;
the second data obtaining module 304 is configured to obtain video data to be analyzed, whose code stream format is the second code stream format, and perform decoding and subsequent analysis.
Optionally, the video processing apparatus located in the analysis server in the embodiment of the present invention further includes:
the identification receiving module is used for receiving the task identification which is returned by the transcoding server and aims at the transcoding instruction;
the second data obtaining module 304 includes:
a transcoding query submodule, configured to query, through the task identifier, whether the transcoding server completes transcoding of the video data to be analyzed;
the address acquisition submodule is used for acquiring a stream taking address of the transcoded video data to be analyzed if the transcoding server completes transcoding of the video data to be analyzed;
and the data processing submodule is used for acquiring the video data to be analyzed with the code stream format being the second code stream format according to the stream taking address, and decoding and subsequently analyzing the video data.
Optionally, the transcoding server includes a plurality of transcoding nodes, and the video processing apparatus located in the analysis server according to the embodiment of the present invention further includes:
the operation parameter acquisition module is used for acquiring operation parameters of the transcoding nodes;
and the running state management module is used for managing the running state of each transcoding node according to the running parameters.
An embodiment of the present invention further provides a video processing apparatus, located at a transcoding server, referring to fig. 4, where the apparatus includes:
a transcoding instruction receiving module 401, configured to receive a transcoding instruction sent by an analysis server, where the transcoding instruction includes an identifier of video data to be analyzed;
a third data obtaining module 402, configured to obtain the video data to be analyzed according to the identifier of the video data to be analyzed in the transcoding instruction;
a transcoding module 403, configured to transcode a code stream format of the video data to be analyzed from a first code stream format to a second code stream format, where the second code stream format is a code stream format supported by the analysis server;
a video data sending module 404, configured to send video data to be analyzed, where the code stream format is the second code stream format.
Optionally, the video processing apparatus located in the transcoding server in the embodiment of the present invention further includes:
and the task identifier sending module is used for generating a task identifier aiming at the transcoding instruction and sending the task identifier to the analysis server.
Optionally, the analysis server periodically sends a heartbeat packet to the transcoding server, and the video processing apparatus located in the transcoding server in the embodiment of the present invention further includes:
and the transcoding stopping module is used for stopping transcoding the video data to be analyzed if the heartbeat packet is not received within a preset time length.
The embodiment of the present invention provides an analysis server, which is shown in fig. 5 and includes a processor 501 and a memory 502;
the memory 502 is used for storing computer programs;
the processor 501 is configured to implement the following steps when executing the program stored in the memory 502:
acquiring video data to be analyzed, wherein the current code stream format of the video data to be analyzed is a first code stream format, and the code stream format comprises a coding format and a packaging format;
judging whether the first code stream format is contained in a preset code stream format, wherein the preset code stream format is a code stream format supported by the analysis server;
if the first code stream format is not included in the preset code stream format, sending a transcoding instruction to a transcoding server so that the transcoding server transcodes the code stream format of the video data to be analyzed into a second code stream format according to the transcoding instruction, wherein the second code stream format is included in the preset code stream format, and the transcoding instruction comprises an identifier of the video data to be analyzed;
and acquiring the video data to be analyzed with the code stream format being the second code stream format, and decoding and subsequently analyzing the video data.
In the embodiment of the invention, when the analysis server does not support the code stream format of the video data to be analyzed, the transcoding instruction is sent to the transcoding server so that the transcoding server converts the code stream format of the video data to be analyzed into the code stream format supported by the analysis server, and the application range of video analysis can be increased.
Optionally, the processor 501 is configured to implement any of the video processing methods applied to the analysis server when executing the program stored in the memory 502.
Optionally, the analysis server is specifically a video cloud structured server.
Optionally, the analysis server according to the embodiment of the present invention further includes a communication interface and a communication bus, where the processor 501, the communication interface, and the memory 502 complete communication therebetween through the communication bus.
An embodiment of the present invention provides a transcoding server, referring to fig. 6, including a processor 601 and a memory 602;
the memory 602 is used for storing computer programs;
the processor 601 is configured to implement the following steps when executing the program stored in the memory 602:
receiving a transcoding instruction sent by an analysis server, wherein the transcoding instruction comprises an identifier of video data to be analyzed;
acquiring the video data to be analyzed according to the identifier of the video data to be analyzed in the transcoding instruction;
transcoding the code stream format of the video data to be analyzed from a first code stream format to a second code stream format, wherein the second code stream format is a code stream format supported by the analysis server;
and sending the video data to be analyzed with the code stream format being the second code stream format.
In the embodiment of the invention, the code stream format of the video data to be analyzed is converted into the second code stream format supported by the analysis server, so that the application range of video analysis can be enlarged.
Optionally, the processor 601 is configured to implement any of the video processing methods applied to the transcoding server when executing the program stored in the memory 602.
Optionally, the transcoding server in the embodiment of the present invention further includes a communication interface and a communication bus, where the processor 601, the communication interface, and the memory 602 complete communication therebetween through the communication bus.
The aforementioned communication bus may be a Peripheral Component Interconnect (PCI) bus, an Extended Industry Standard Architecture (EISA) bus, or the like. The communication bus may be divided into an address bus, a data bus, a control bus, etc. For ease of illustration, only one thick line is shown, but this does not mean that there is only one bus or one type of bus.
The communication interface is used for communication with other devices.
The Memory may include a Random Access Memory (RAM) or a Non-Volatile Memory (NVM), such as at least one disk Memory. Alternatively, the memory may be at least one memory device located remotely from the processor.
The Processor may be a general-purpose Processor, including a Central Processing Unit (CPU), a Network Processor (NP), and the like; but also Digital Signal Processors (DSPs), application Specific Integrated Circuits (ASICs), field Programmable Gate Arrays (FPGAs) or other Programmable logic devices, discrete Gate or transistor logic devices, discrete hardware components.
An embodiment of the present invention further provides a video processing system, which is shown in fig. 7 and includes an analysis server 701 and a transcoding server 702;
the analysis server 701 is configured to implement any one of the video processing methods applied to the analysis server;
the transcoding server 702 is configured to implement any of the video processing methods applied to the transcoding server.
In the embodiment of the invention, when the analysis server does not support the code stream format of the video data to be analyzed, the transcoding instruction is sent to the transcoding server, so that the transcoding server converts the code stream format of the video data to be analyzed into the code stream format supported by the analysis server, and the application range of video analysis can be increased.
An application scenario of the video processing system according to the embodiment of the present invention may be as shown in fig. 8.
A user logs in a web page of an analysis server (specifically, a video cloud structured server) to select a path of code stream of video data for analysis, the analysis server issues a stream-fetching command to a monitoring platform, and the monitoring platform fetches a stream from the front end. The analysis server decodes the received code stream of the video data, if the decoding is successful, further performs video analysis, and returns an analysis result; and if the decoding fails, the analysis server issues a transcoding task to the configured transcoding server and sends the stream fetching address to the transcoding server.
And the transcoding server receives the transcoding task, acquires the code stream of the video data according to the stream-taking address, decodes the code stream and encodes the code stream again, and transcodes the video data into a coding format and a packaging format which can be analyzed by the analysis server.
The analysis server inquires a transcoding state ok and a transcoded stream taking address through the task ID, and then sends a stream taking command to the transcoding server; and the analysis server receives the transcoded code stream, performs video analysis and returns an analysis result.
Optionally, the transcoding server may be deployed in a cluster manner, and include a plurality of transcoding nodes. Each transcoding node may be either a supervisory transcoding node (primary transcoding node) or an analytical transcoding node (secondary transcoding node). The cluster of the transcoding server can comprise a plurality of management transcoding nodes, and when the management service of the transcoding nodes has the addition analysis service, the transcoding nodes execute management work; and otherwise, when the analysis transcoding node is not added to the transcoding node, the transcoding node is added by other transcoding nodes, and the transcoding node executes analysis service.
The transcoding node mainly comprises two functions of management service and analysis service, wherein the management service comprises a configuration interface and a task interface, and the configuration interface is used for: logging in, logging out, transcoding node adding, removing, node information inquiring and cluster resolving functions. The task interface is to: receiving and scheduling a transcoding task, sending the task to a child node, deleting the task and inquiring a transcoding state. The analytics service is to: receiving management of management service, providing specific transcoding service, starting transcoding, stopping transcoding, state query of residual resources, stream fetching and code stream publishing service. The specific workflow may be as shown in fig. 9.
For example, as shown in fig. 10, when a transcoding node 1 is added as a management transcoding node and a transcoding node 2 is added to it at the same time, the management service of the transcoding node 1 is responsible for managing the analysis service of itself and the analysis service of the transcoding node 2, so that the transcoding node 2 acts as a child transcoding node since no other analysis transcoding node is added to the management service of the transcoding node 2.
When a transcoding node 2 is added as a cluster management transcoding node, the management service of the transcoding node 2 is responsible for managing the analysis services of itself and the analysis services of other transcoding nodes.
The transcoding nodes 1 and 2 are management transcoding nodes and analysis transcoding nodes, when one management transcoding node is down, and the analysis transcoding node detects that no stream is taken for a long time, the transcoding task can be automatically stopped, the cluster is equivalent to automatic disintegration, and other transcoding nodes can still be designated as management transcoding nodes at the moment, so that the normal operation of the cluster is ensured.
A user may log in a web page of an analysis server (specifically, a video cloud structured server), configure a transcoding main node, add a transcoding sub node, and create a transcoding service cluster, for example, as shown in fig. 11.
1101-1102, logging in a transcoding server by an analysis server;
1103-1104, the analysis server acquires information states of the capability set, the number of remaining resources, the added child nodes and the like of the transcoding server;
step 1105-1108, the analysis server adds a transcoding child node ip to the transcoding server;
step 1109-1112, the analysis server removes a transcoding child node ip from the transcoding server;
1113-1116, the analysis server deletes all child nodes managed by the transcoding main node, namely, the transcoding cluster on the main node is dispersed;
1117-1118, the analysis server and the transcoding server keep heartbeat, if the heartbeat of the analysis server is not received and exceeds a certain time, all transcoding tasks are stopped;
1119-1120, the analysis server exits the transcoding server;
the method comprises the steps that a user can log in a web page of an analysis server (specifically, a video cloud structured server), when video data of a monitoring point on the page is selected for video analysis, if a video analysis system cannot analyze due to the fact that a front-end code stream video coding format or a packaging format does not support, the transcoding server is applied for transcoding the code stream, after transcoding is successful, stream is taken from the transcoding server, video analysis is continued, and the user cannot perceive the video stream. This may be particularly shown in figure 12.
Step 1201-1205, the analysis server issues a transcoding task, the transcoding server returns a task ID, the task is placed in a waiting queue, the task is taken out from the queue in sequence and is scheduled, then a transcoding sub-node with the optimal idle resource number is selected to detect the number of resources required by the task, after the transcoding main node obtains the number of resources required by the transcoding task, the scheduling is carried out again, the transcoding sub-node with the optimal idle resource number is selected to transcode, the transcoding sub-node takes a stream from the monitoring platform according to the task, and the obtained stream is transcoded.
Step 1206-1290, the analysis server queries the task state from the transcoding server according to the task ID at regular time, and acquires a URL (Uniform Resource Locator) of the transcoded code stream after the transcoding state ok of the path.
Step 1210-1211, the analysis server fetches a stream from the transcoding child node according to the URL of the code stream, and the transcoding child node returns the transcoded code stream to the analysis server for video analysis;
and step 1212-1213, the analysis server issues a transcoding stop request to the transcoding server, the transcoding main node issues a transcoding stop request to the transcoding sub-point, the transcoding sub-point stops fetching the stream from the monitoring platform and quits, and the transcoding main node returns a task stop state to the analysis server.
An embodiment of the present invention further provides a computer-readable storage medium, where a computer program is stored in the computer-readable storage medium, and when the computer program is executed by a processor, the computer program implements the following steps:
acquiring video data to be analyzed, wherein the current code stream format of the video data to be analyzed is a first code stream format, and the code stream format comprises a coding format and a packaging format;
judging whether the first code stream format is contained in a preset code stream format, wherein the preset code stream format is a code stream format supported by the analysis server;
if the first code stream format is not contained in the preset code stream format, sending a transcoding instruction to a transcoding server so that the transcoding server transcodes the code stream format of the video data to be analyzed into a second code stream format according to the transcoding instruction, wherein the second code stream format is contained in the preset code stream format, and the transcoding instruction comprises an identifier of the video data to be analyzed;
and acquiring the video data to be analyzed with the code stream format being the second code stream format, and decoding and subsequently analyzing the video data.
In the embodiment of the invention, when the analysis server does not support the code stream format of the video data to be analyzed, the transcoding instruction is sent to the transcoding server so that the transcoding server converts the code stream format of the video data to be analyzed into the code stream format supported by the analysis server, and the application range of video analysis can be increased.
Optionally, when executed by the processor, the computer program may further implement any of the video processing methods applied to the analysis server.
An embodiment of the present invention further provides a computer-readable storage medium, in which a computer program is stored, and when the computer program is executed by a processor, the computer program implements the following steps:
receiving a transcoding instruction sent by an analysis server, wherein the transcoding instruction comprises an identifier of video data to be analyzed;
acquiring the video data to be analyzed according to the identifier of the video data to be analyzed in the transcoding instruction;
transcoding the code stream format of the video data to be analyzed from a first code stream format to a second code stream format, wherein the second code stream format is a code stream format supported by the analysis server;
and sending the video data to be analyzed with the code stream format being the second code stream format.
In the embodiment of the invention, the code stream format of the video data to be analyzed is converted into the second code stream format supported by the analysis server, so that the application range of video analysis can be enlarged.
Optionally, when executed by the processor, the computer program may further implement any of the video processing methods applied to the transcoding server.
It is noted that, herein, relational terms such as first and second, and the like may be used solely to distinguish one entity or action from another entity or action without necessarily requiring or implying any actual such relationship or order between such entities or actions. Also, the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or apparatus that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or apparatus. Without further limitation, an element defined by the phrases "comprising a," "8230," "8230," or "comprising" does not exclude the presence of additional like elements in a process, method, article, or apparatus that comprises the element.
The embodiments in the present specification are described in a related manner, and each embodiment focuses on differences from other embodiments, and portions that are the same as and similar to each other in each embodiment may be referred to.
The above description is only for the preferred embodiment of the present invention, and is not intended to limit the scope of the present invention. Any modification, equivalent replacement, or improvement made within the spirit and principle of the present invention shall fall within the protection scope of the present invention.
Claims (13)
1. A video processing method applied to an analysis server, the method comprising:
acquiring video data to be analyzed, wherein the current code stream format of the video data to be analyzed is a first code stream format, and the code stream format comprises a coding format and a packaging format;
judging whether the first code stream format is contained in a preset code stream format, wherein the preset code stream format is a code stream format supported by the analysis server;
if the first code stream format is not contained in the preset code stream format, sending a transcoding instruction to a transcoding server so that the transcoding server transcodes the code stream format of the video data to be analyzed into a second code stream format according to the transcoding instruction, wherein the transcoding server comprises a plurality of transcoding nodes, when management services of the transcoding nodes have an addition analysis transcoding node, the transcoding node is used as a management transcoding node, when the transcoding node does not have the addition analysis transcoding node and is added by other transcoding nodes, the transcoding node is used as an analysis transcoding node, the second code stream format is contained in the preset code stream format, and the transcoding instruction comprises an identifier of the video data to be analyzed;
acquiring video data to be analyzed with a code stream format being the second code stream format, and decoding and subsequently analyzing the video data;
the plurality of transcoding nodes comprises a plurality of management transcoding nodes, the management service comprises a configuration interface and a task interface, and the configuration interface is used for: log-in, log-out, transcoding node adding, removing, node information query and cluster resolving functions; the task interface is to: receiving, scheduling and issuing a transcoding task to an analysis transcoding node, deleting the task and inquiring a transcoding state; the analytics transcoding node includes analytics services to: receiving management of management service, providing specific transcoding service, starting transcoding, stopping transcoding, inquiring residual resources in a state, fetching streams and issuing code stream service;
the sending a transcoding instruction to a transcoding server to enable the transcoding server to transcode the code stream format of the video data to be analyzed into a second code stream format according to the transcoding instruction comprises the following steps:
the method comprises the steps of sending a transcoding task to a transcoding server, enabling the transcoding server to feed a task ID back to an analysis server, enabling a management transcoding node to place the transcoding task into a waiting queue, taking out the transcoding task from the queue in sequence, scheduling, obtaining the number of idle resources of each analysis transcoding node, selecting an analysis transcoding node with the optimal idle resources to perform task required resource number detection, enabling the management transcoding node to obtain the number of resources required by the transcoding task, scheduling, determining the analysis transcoding node with the optimal number of idle resources according to the number of the idle resources of each analysis transcoding node and the number of the resources required by the transcoding task, enabling the determined analysis transcoding node to obtain video data to be analyzed from a monitoring platform according to the transcoding task, and transcoding the code stream format of the video data to be analyzed into a second code stream format.
2. The method of claim 1, wherein after said sending transcoding instructions to a transcoding server, the method further comprises:
receiving a task identifier which is returned by the transcoding server and aims at the transcoding instruction;
the acquiring the video data to be analyzed with the code stream format being the second code stream format, and performing decoding and subsequent analysis, including:
inquiring whether the transcoding server completes transcoding of the video data to be analyzed or not through the task identifier;
if the transcoding server completes transcoding of the video data to be analyzed, acquiring a stream taking address of the transcoded video data to be analyzed;
and acquiring video data to be analyzed with a code stream format being the second code stream format according to the stream taking address, and decoding and subsequently analyzing the video data.
3. The method of claim 1, wherein the transcoding server comprises a plurality of transcoding nodes, the method further comprising:
obtaining operation parameters of each transcoding node;
and managing the operation state of each transcoding node according to the operation parameters.
4. A video processing method applied to a transcoding server, wherein the transcoding server comprises a plurality of transcoding nodes, and when a management service of a transcoding node has an analysis transcoding node added, the transcoding node serves as a management transcoding node, and when the transcoding node has no analysis transcoding node added and is added by other transcoding nodes, the transcoding node serves as an analysis transcoding node, and the method comprises the following steps:
receiving a transcoding instruction sent by an analysis server, wherein the transcoding instruction comprises an identifier of video data to be analyzed;
acquiring the video data to be analyzed according to the identifier of the video data to be analyzed in the transcoding instruction;
transcoding the code stream format of the video data to be analyzed from a first code stream format to a second code stream format, wherein the second code stream format is a code stream format supported by the analysis server;
sending video data to be analyzed with a code stream format being the second code stream format;
the plurality of transcoding nodes comprises a plurality of management transcoding nodes, the management service comprises a configuration interface and a task interface, and the configuration interface is used for: log-in, log-out, transcoding node adding, removing, node information inquiring and cluster resolving functions; the task interface is to: receiving, scheduling and issuing a transcoding task to an analysis transcoding node, deleting the task and inquiring a transcoding state; the analytics transcoding node includes analytics services to: receiving management of management service, providing specific transcoding service, starting transcoding, stopping transcoding, inquiring residual resources in a state, fetching streams and issuing code stream service;
the receiving of the transcoding instruction sent by the analysis server includes:
receiving a transcoding task sent by an analysis server;
the transcoding the code stream format of the video data to be analyzed from a first code stream format to a second code stream format comprises the following steps:
feeding a task ID back to the analysis server, enabling a management transcoding node to place transcoding tasks into a waiting queue, taking out the transcoding tasks from the queue in sequence, scheduling and obtaining the number of idle resources of each analysis transcoding node, selecting an analysis transcoding node with the optimal idle resources to perform task required resource number detection, enabling the management transcoding node to obtain the number of resources required by the transcoding tasks, scheduling, determining the analysis transcoding node with the optimal number of idle resources according to the number of the idle resources of each analysis transcoding node and the number of resources required by the transcoding tasks, enabling the determined analysis transcoding node to obtain video data to be analyzed from a monitoring platform according to the transcoding tasks, and transcoding the code stream format of the video data to be analyzed into a second code stream format.
5. The method of claim 4, wherein after receiving the transcoding instruction sent by the analytics server, the method further comprises:
and generating a task identifier aiming at the transcoding instruction, and sending the task identifier to an analysis server.
6. The method of claim 4, wherein the analytics server periodically sends heartbeat packets to the transcoding server, the method further comprising:
and if the heartbeat packet is not received within a preset time length, stopping transcoding the video data to be analyzed.
7. A video processing apparatus at an analysis server, the apparatus comprising:
the device comprises a first data acquisition module, a second data acquisition module and a video analysis module, wherein the first data acquisition module is used for acquiring video data to be analyzed, the current code stream format of the video data to be analyzed is a first code stream format, and the code stream format comprises a coding format and a packaging format;
the format judging module is used for judging whether the first code stream format is contained in a preset code stream format, wherein the preset code stream format is a code stream format supported by the analysis server;
a transcoding instruction sending module, configured to send a transcoding instruction to a transcoding server, if the first code stream format is not included in the preset code stream format, so that the transcoding server transcodes the code stream format of the video data to be analyzed into a second code stream format according to the transcoding instruction, where the transcoding server includes multiple transcoding nodes, and when a management service of a transcoding node has an addition analysis transcoding node, the transcoding node serves as a management transcoding node, and when the transcoding node does not have the addition analysis transcoding node and is added by another transcoding node, the transcoding node serves as an analysis transcoding node, the second code stream format is included in the preset code stream format, and the transcoding instruction includes an identifier of the video data to be analyzed;
the second data acquisition module is used for acquiring the video data to be analyzed with the code stream format being the second code stream format, and decoding and subsequently analyzing the video data;
the plurality of transcoding nodes comprises a plurality of management transcoding nodes, the management service comprises a configuration interface and a task interface, and the configuration interface is used for: log-in, log-out, transcoding node adding, removing, node information query and cluster resolving functions; the task interface is to: receiving, scheduling and issuing a transcoding task to an analysis transcoding node, deleting the task and inquiring a transcoding state; the analytics transcoding node includes analytics services to: receiving management of management service, providing specific transcoding service, starting transcoding, stopping transcoding, inquiring residual resources in a state, fetching streams and issuing code stream service;
the transcoding instruction sending module sends a transcoding instruction to a transcoding server so that the transcoding server transcodes the code stream format of the video data to be analyzed into a second code stream format according to the transcoding instruction, and the transcoding instruction sending module comprises:
and sending a transcoding task to a transcoding server, so that the transcoding server feeds a task ID back to the analysis server, a management transcoding node puts the transcoding task into a waiting queue, takes out the transcoding task from the queue in sequence, schedules and acquires the number of idle resources of each analysis transcoding node, selects an analysis transcoding node with the optimal idle resources to perform task required resource number detection, acquires the number of resources required by the transcoding task by the management transcoding node, schedules, determines the analysis transcoding node with the optimal number of idle resources according to the number of the idle resources of each analysis transcoding node and the number of resources required by the transcoding task, acquires the video data to be analyzed from a monitoring platform according to the transcoding task, and transcodes the code stream format of the video data to be analyzed into a second code stream format.
8. A video processing apparatus located in a transcoding server, wherein the transcoding server comprises a plurality of transcoding nodes, wherein a transcoding node serves as a managed transcoding node when an analysis transcoding node is added to a management service of the transcoding node, and wherein a transcoding node serves as an analysis transcoding node when an analysis transcoding node is not added to the transcoding node and the transcoding node is added by another transcoding node, the apparatus comprising:
the transcoding instruction receiving module is used for receiving a transcoding instruction sent by the analysis server, wherein the transcoding instruction comprises an identifier of video data to be analyzed;
a third data obtaining module, configured to obtain the video data to be analyzed according to the identifier of the video data to be analyzed in the transcoding instruction;
the transcoding module is used for transcoding the code stream format of the video data to be analyzed from a first code stream format to a second code stream format, wherein the second code stream format is a code stream format supported by the analysis server;
the video data sending module is used for sending the video data to be analyzed with the code stream format being the second code stream format;
the plurality of transcoding nodes comprises a plurality of management transcoding nodes, the management service comprises a configuration interface and a task interface, and the configuration interface is used for: log-in, log-out, transcoding node adding, removing, node information query and cluster resolving functions; the task interface is to: receiving, scheduling and issuing a transcoding task to an analysis transcoding node, deleting the task and inquiring a transcoding state; the analytics transcoding node includes analytics services to: receiving management of management service, providing specific transcoding service, starting transcoding, stopping transcoding, inquiring residual resources in a state, fetching streams and issuing code stream service;
the transcoding instruction receiving module receives a transcoding instruction sent by an analysis server, and comprises:
receiving a transcoding task sent by an analysis server;
the transcoding module transcodes the code stream format of the video data to be analyzed from a first code stream format to a second code stream format, and the transcoding module comprises the following steps:
feeding a task ID back to the analysis server, enabling a management transcoding node to place transcoding tasks into a waiting queue, taking out the transcoding tasks from the queue in sequence, scheduling and acquiring the number of idle resources of each analysis transcoding node, selecting an analysis transcoding node with the optimal idle resources to detect the number of resources required by the tasks, enabling the management transcoding node to acquire the number of resources required by the transcoding tasks, scheduling, determining the analysis transcoding node with the optimal number of idle resources according to the number of idle resources of each analysis transcoding node and the number of resources required by the transcoding tasks, enabling the determined analysis transcoding node to acquire video data to be analyzed from a monitoring platform according to the transcoding tasks, and transcoding the code stream format of the video data to be analyzed into a second code stream format.
9. An analysis server comprising a processor and a memory;
the memory is used for storing a computer program;
the processor, when executing the program stored in the memory, implementing the method steps of any of claims 1-3.
10. A transcoding server comprising a processor and a memory;
the memory is used for storing a computer program;
the processor, when executing the program stored in the memory, implementing the method steps of any of claims 4-6.
11. A video processing system comprising any of the analysis servers of claim 9 and any of the transcoding servers of claim 10.
12. A computer-readable storage medium, characterized in that a computer program is stored in the computer-readable storage medium, which computer program, when being executed by a processor, carries out the method steps of any one of the claims 1-3.
13. A computer-readable storage medium, characterized in that a computer program is stored in the computer-readable storage medium, which computer program, when being executed by a processor, carries out the method steps of any one of claims 4-6.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201810958862.3A CN110858829B (en) | 2018-08-22 | 2018-08-22 | Video processing method, device and system, analysis server and transcoding server |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201810958862.3A CN110858829B (en) | 2018-08-22 | 2018-08-22 | Video processing method, device and system, analysis server and transcoding server |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN110858829A CN110858829A (en) | 2020-03-03 |
| CN110858829B true CN110858829B (en) | 2023-02-07 |
Family
ID=69634769
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201810958862.3A Active CN110858829B (en) | 2018-08-22 | 2018-08-22 | Video processing method, device and system, analysis server and transcoding server |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN110858829B (en) |
Families Citing this family (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113766270B (en) * | 2021-02-26 | 2024-06-18 | 北京沃东天骏信息技术有限公司 | Video playing method, system, server, terminal equipment and electronic equipment |
| CN113949696B (en) * | 2021-08-31 | 2023-10-20 | 网宿科技股份有限公司 | Resource distribution method, electronic device, and computer-readable storage medium |
| CN114079823A (en) * | 2021-11-17 | 2022-02-22 | 天翼数字生活科技有限公司 | Video rendering method, device, equipment and medium based on Flutter |
Citations (11)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2007213547A (en) * | 2006-02-07 | 2007-08-23 | Era Digital Media Co Ltd | Web-based video blog |
| CN101984665A (en) * | 2010-10-29 | 2011-03-09 | 深圳市同洲电子股份有限公司 | Video transmission quality evaluating method and system |
| CN102014262A (en) * | 2010-10-27 | 2011-04-13 | 杭州海康威视软件有限公司 | Hard disk video recorder and system and method for converting multimedia formats |
| CN102122300A (en) * | 2011-03-08 | 2011-07-13 | 天脉聚源(北京)传媒科技有限公司 | Method for converting video format |
| CN202135269U (en) * | 2011-07-22 | 2012-02-01 | 江苏宇天新媒体技术有限公司 | System for realizing mobile phone video playing |
| WO2012095427A1 (en) * | 2011-01-11 | 2012-07-19 | Universiteit Gent | Fast channel switching |
| CN104394456A (en) * | 2014-11-20 | 2015-03-04 | 福建星网视易信息系统有限公司 | Method and device for decoding audios and videos in embedded environment |
| EP3073737A1 (en) * | 2015-03-26 | 2016-09-28 | Fujitsu Limited | Video coding device, video coding method, video decoding device and video decoding method |
| CN107070686A (en) * | 2016-12-23 | 2017-08-18 | 武汉烽火众智数字技术有限责任公司 | A kind of system and method for the parallel transcoding of video monitoring platform code stream |
| CN107995519A (en) * | 2017-11-30 | 2018-05-04 | 广州酷狗计算机科技有限公司 | The method, apparatus and storage medium that multimedia file plays |
| CN108063952A (en) * | 2017-12-14 | 2018-05-22 | 暴风集团股份有限公司 | Method for processing video frequency, device and terminal |
-
2018
- 2018-08-22 CN CN201810958862.3A patent/CN110858829B/en active Active
Patent Citations (11)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2007213547A (en) * | 2006-02-07 | 2007-08-23 | Era Digital Media Co Ltd | Web-based video blog |
| CN102014262A (en) * | 2010-10-27 | 2011-04-13 | 杭州海康威视软件有限公司 | Hard disk video recorder and system and method for converting multimedia formats |
| CN101984665A (en) * | 2010-10-29 | 2011-03-09 | 深圳市同洲电子股份有限公司 | Video transmission quality evaluating method and system |
| WO2012095427A1 (en) * | 2011-01-11 | 2012-07-19 | Universiteit Gent | Fast channel switching |
| CN102122300A (en) * | 2011-03-08 | 2011-07-13 | 天脉聚源(北京)传媒科技有限公司 | Method for converting video format |
| CN202135269U (en) * | 2011-07-22 | 2012-02-01 | 江苏宇天新媒体技术有限公司 | System for realizing mobile phone video playing |
| CN104394456A (en) * | 2014-11-20 | 2015-03-04 | 福建星网视易信息系统有限公司 | Method and device for decoding audios and videos in embedded environment |
| EP3073737A1 (en) * | 2015-03-26 | 2016-09-28 | Fujitsu Limited | Video coding device, video coding method, video decoding device and video decoding method |
| CN107070686A (en) * | 2016-12-23 | 2017-08-18 | 武汉烽火众智数字技术有限责任公司 | A kind of system and method for the parallel transcoding of video monitoring platform code stream |
| CN107995519A (en) * | 2017-11-30 | 2018-05-04 | 广州酷狗计算机科技有限公司 | The method, apparatus and storage medium that multimedia file plays |
| CN108063952A (en) * | 2017-12-14 | 2018-05-22 | 暴风集团股份有限公司 | Method for processing video frequency, device and terminal |
Non-Patent Citations (1)
| Title |
|---|
| 联网监控图像转码平台技术实现;柳等;《南京大学学报(自然科学版)》;20090130(第01期);全文 * |
Also Published As
| Publication number | Publication date |
|---|---|
| CN110858829A (en) | 2020-03-03 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN110300050B (en) | Message pushing method and device, computer equipment and storage medium | |
| CN110858829B (en) | Video processing method, device and system, analysis server and transcoding server | |
| CN110020062B (en) | Customizable web crawler method and system | |
| US20180359140A1 (en) | Method, device, and system for processing a terminal fault | |
| CN107908465B (en) | Task scheduling method for big data platform | |
| CN110633442A (en) | Pushing method and device and electronic equipment | |
| US11979761B2 (en) | Method and apparatus for detecting time series data | |
| CN108712422B (en) | Method and device for creating transcoding task | |
| CN106657371B (en) | Scheduling method and device for transmission node | |
| US20170085512A1 (en) | Generating message envelopes for heterogeneous events | |
| CN111917777A (en) | Network data analysis method and device and electronic equipment | |
| CN111597057B (en) | Data processing method, device and computer readable storage medium | |
| CN110781180B (en) | Data screening method and data screening device | |
| CN113596078B (en) | Service problem positioning method and device | |
| CN109144676B (en) | Self-starting detection method and device of application program and server | |
| WO2016101446A1 (en) | Data analysis method, apparatus, system, and terminal, and server | |
| CN115168031A (en) | Fog calculation system, method, electronic equipment and storage medium | |
| US10861306B2 (en) | Method and apparatus for video surveillance | |
| CN110309028B (en) | Monitoring information acquisition method, service monitoring method, device and system | |
| CN114780529B (en) | Data processing method and device | |
| CN113179261B (en) | Video stream processing method and device, storage medium and platform server | |
| KR101828156B1 (en) | Transaction Monitoring System and Operating method thereof | |
| CN104462235A (en) | Internet of Things general event service mechanism based on Restful Web Service | |
| CN114553944A (en) | Early warning message pushing method and system | |
| CN115701584A (en) | Thread determining method and device, storage medium and electronic 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 |