TWI868775B - Method and system for processing video for streaming service - Google Patents

Abstract

There are provided a method and system for processing a video for a streaming service using a cloud function. The method for processing a video for a streaming service may include publishing creation of a job item for streaming of a video source file as a subject of a main queue, and sensing the creation of the job item according to subscribing to the subject of the main queue and executing a first pipeline in response to the creation of the job item.

Description

Video processing method and system for streaming service

The present invention relates to a video processing method for streaming services and a system thereof, and in particular to a method for processing videos for streaming services using cloud functions and a system thereof.

When a content provider (CP) provides the original video file of the content, it needs to perform multiple operations to provide the streaming service of the corresponding content to the user. For example, it needs to perform multiple operations such as video ingestion operation, operation for checking the quality of the original video file or ingested data, and subtitle processing operation. The video ingestion operation refers to the operation of processing the original video file into the streaming service format and uploading it to the server appropriately, including encoding or chunking of the original video file.

According to the existing technology, these multiple operations for video streaming are usually executed sequentially in a large server. According to this traditional method, there is an advantage in saving computing resources, but because multiple operations are processed sequentially, the processing speed of the original video file is slow, so there is a disadvantage that it takes a long time from the content provider providing the original video file to the final streaming service to the user.

Furthermore, according to the traditional method, when adding specific operations for video streaming, such as harmfulness verification operations, to the existing processing logic, in many cases it is necessary to modify the existing source code according to the characteristics of the added operations, which is defective in the scalability of the architecture.

Patent document: Korean patent application No. 10-1141020 (published on February 10, 2011)

The technical problem to be solved by some embodiments of the present invention is to provide a method for processing videos for streaming services using cloud functions and a system applying the method.

Another technical problem to be solved by some embodiments of the present invention is to provide a method for shortening the time required for video processing by parallel processing of multiple operations for streaming services and a system applying the method.

The technical problems to be solved by the present invention are not limited to the above-mentioned technical problems, and those skilled in the art will be able to clearly understand other technical problems not mentioned from the following description.

A video processing method for streaming services according to an embodiment of the present invention for solving the technical problem may include the following steps:

The creation of a job item for streaming a video original file is published to a topic of a main queue; and with the subscription of the topic of the main queue, the creation of the job item is detected, and a first pipeline is executed in response to the creation of the job item. At this time, the step of executing the first pipeline includes the following steps: inserting the created job item into a first queue of the first pipeline; dequeuing the job item from the first queue, and calling a first cloud function in response to the dequeuing from the first queue, wherein the first cloud function is executed by executing a video interface. A serverless computing application for executing a video access operation by using a cloud application monitoring module for executing the video access module; detecting whether the video access operation is completed by using a cloud application monitoring module for executing the video access module; in response to detecting that the video access operation is completed, inserting the completed video access operation item into a second queue of the first pipeline; and queuing the completed video access operation item from the second queue, and calling a second cloud function in response to dequeuing from the second queue, wherein the second cloud function is a serverless computing application for executing completion processing of the video access operation indicated by the operation item queued from the second queue.

In one embodiment, the first cloud function corresponds to the first queue one by one, and the second cloud function may correspond to the second queue one by one.

In one embodiment, the step of publishing the creation of the operation item to the main queue includes the following steps: inserting the created operation item into the main queue by executing the content creation processing cloud function. At this time, the step of inserting the created operation item into the main queue by executing the content creation processing cloud function includes the following steps: adding the record corresponding to the video original file of the created operation item to the first table included in the database of the content management system (CMS) by executing the content creation processing cloud function. In addition, the first cloud function includes: an instruction for executing the video access module and updating the status field of the record. Furthermore, the second cloud function includes: instructions for updating the status field of the record based on whether the video access operation indicated by the operation item from the second queue is successful.

In one embodiment, the video processing method for streaming service may further include the following steps: with the subscription of the topic of the main queue, detecting the creation of the operation item, and executing the second pipeline in response to the creation of the operation item. At this time, the step of executing the second pipeline includes the following steps: inserting the created operation item into the third queue of the second pipeline; and queuing the created operation item from the third queue, and calling a third cloud function in response to dequeuing from the third queue, wherein the third cloud function is a serverless computing application that calls a message creation API to publish a message on the collaboration tool notifying the creation of the operation item.

In one embodiment, the video processing method for streaming service further includes the following steps: with the subscription of the topic of the main queue, detecting the creation of the operation item, and executing the third pipeline in response to the creation of the operation item. At this time, the step of executing the third pipeline includes the following steps: inserting the created operation item into the fourth queue of the third pipeline; and queuing the created operation item from the fourth queue, and calling the fourth cloud function in response to the dequeuing from the fourth queue, the fourth cloud function is a serverless computing application including instructions for executing the video original file-related appending operation executed in parallel with the video access operation according to the operation item queued from the fourth queue.

A video processing system for streaming services according to another embodiment of the present invention for solving the technical problem may include: a communication interface; a memory for loading a computer program; and a processor for executing the computer program. At this time, the computer program may include: a plurality of instructions for publishing the creation of a job item for streaming a video original file to a topic of a main queue; and a plurality of instructions for detecting the creation of the job item and executing the first pipeline in response to the creation of the job item by subscribing to the topic of the main queue. At this time, the multiple instructions for executing the first pipeline may include: multiple instructions for inserting the created operation item into the first queue of the first pipeline; multiple instructions for dequeuing the operation item from the first queue and calling a first cloud function in response to the dequeuing from the first queue, wherein the first cloud function is a serverless computing application that executes a video access module to execute a video access operation of the operation item queued from the first queue; and multiple instructions for invoking a first cloud function in response to the dequeuing from the first queue. The first cloud function is a serverless computing application that executes a video access module to execute a video access operation of the operation item queued from the first queue; and a cloud application monitoring system for executing the video access module. The module includes a plurality of instructions for detecting whether the video access operation is completed; in response to detecting that the video access operation is completed, a plurality of instructions for inserting the completed video access operation item into the second queue of the first pipeline; and a plurality of instructions for queuing the completed video access operation item from the second queue and calling a second cloud function in response to dequeuing from the second queue, wherein the second cloud function is a serverless computing application that performs completion processing of the video access operation indicated by the operation item queued from the second queue.

In one embodiment, the video processing system for streaming services may further include: detecting the creation of the job item as the topic of the main queue is subscribed, and executing multiple instructions of the third pipeline in response to the creation of the job item. At this time, the multiple instructions for executing the third pipeline may include: multiple instructions for inserting the created job item into the fourth queue of the third pipeline; and instructions for queuing the created job item from the fourth queue and calling a fourth cloud function in response to dequeuing from the fourth queue, wherein the fourth cloud function is a serverless computing application including instructions for executing an append operation related to the video original file executed in parallel with the video access operation according to the job item queued from the fourth queue.

Hereinafter, preferred embodiments of the present invention will be described in detail with reference to the accompanying drawings. Through the embodiments described in detail below in conjunction with the accompanying drawings, the advantages and features of the present invention and the methods for implementing them will become clear. However, the technical ideas of the present invention are not limited to the following embodiments and can be implemented in various different forms. The following embodiments are provided only to improve the technical ideas of the present invention and enable ordinary technicians in the field to which the present invention belongs to fully understand the scope of the present invention. The technical ideas of the present invention are limited only by the scope of the claims.

When describing various embodiments of the present invention, if it is determined that a detailed description of related known configurations or functions may obscure the gist of the present invention, the detailed description will be omitted.

Unless otherwise defined, the terms (including technical and scientific terms) used in the following embodiments may be used according to the meanings commonly understood by ordinary technicians in the field to which the present invention belongs, but may also change according to the intentions of technicians in the relevant fields, precedents, and the emergence of new technologies. The terms used in the present invention are used to illustrate the embodiments and are not intended to limit the scope of the present invention.

Unless the context clearly specifies the singular, the singular expressions used in the following examples include the plural concept. In addition, unless the context clearly specifies the plural, the plural expressions include the singular concept.

Furthermore, terms such as first, second, A, B, (a), and (b) used in the following embodiments are only used to distinguish certain components from other components, and these terms are not used to limit the nature or order of the components.

Hereinafter, various embodiments of the present invention will be described in detail with reference to the accompanying drawings.

FIG1 is a configuration diagram of the entire system according to an embodiment of the present invention.

Hereinafter, the configuration and operation of the whole system according to an embodiment of the present invention will be described with reference to the accompanying drawings. As shown in Fig. 1, the whole system according to the present embodiment may include a video processing system 10 for streaming services, and in some embodiments, may also include an archive 20.

The archive 20 may store the original video file of the content to be streamed. Such original video file may be uploaded by the content provider, and when the content provider completes the uploading of the original video file, the content creation processing cloud function may be executed. That is, the execution of the content creation processing cloud function may be caused by the uploading by the content provider. When the content creation processing cloud function is executed, a job item for streaming may be created.

The job item manager 11 can publish the creation of a job item for streaming the original video file to the topic of the main queue. Among them, the job item for streaming can refer to data for processing the video that is inserted into the main queue and at least one of the first to fourth queues and dequeued. At this time, the main queue can be a publish/subscribe (Pub/Sub) model. Therefore, the pipeline executor 100 that detects the creation of the job item with the subscription of the topic of the main queue can execute each pipeline in parallel. Details about the pipeline will be explained later.

In some embodiments, the operation item manager 11 can insert the created operation item into the main queue by executing the content creation processing cloud function. At this time, the operation item manager 11 can add the record corresponding to the original video file of the created operation item to the first table included in the database of the content management system (CMS).

The first table may store a processing history of operations on the video original file. Adding a record corresponding to the video original file may mean adding row data including a status field and the processing time of each operation in the first table. In this case, adding a record about the creation of a work item to the first table may add a row data including a status field having a status value corresponding to "Create" and the creation time of the work item to the first table.

The video access module 12 can execute the video access operation indicated by the operation item queued from the first queue of the first pipeline. The video access operation can mean an operation related to video access, such as encoding or segmentation.

The cloud application monitoring module 13 can monitor a specific module, for example, the video access module 12 to detect whether the execution of the corresponding module is completed.

The pipeline executor 100 can detect the creation of a job item as the topic of the main queue is subscribed, and execute the first pipeline in response to the creation of the job item. For example, the pipeline executor 100 can insert the created job item into the first queue of the first pipeline. Thereafter, the job item can be queued from the first queue, and the first cloud function can be called in response to the dequeue from the first queue. At this time, the first cloud function can be a serverless computing application that executes a video access module to execute a video access operation of the job item queued from the first queue. Thereafter, in response to detecting whether the video access operation is completed by the cloud application monitoring module for executing the video access module, the completed video access operation item may be inserted into the second queue of the first pipeline. Thereafter, the completed video access operation item may be dequeued from the second queue, and a second cloud function may be called in response to dequeuing from the second queue. At this time, the second cloud function may be a serverless computing application that performs completion processing of the video access operation indicated by the operation item dequeued from the second queue.

In some embodiments, the pipeline executor 100 can detect the creation of a work item as the main queue's topic is subscribed, and execute the second and/or third pipelines in response to the creation of the work item. In this process, the pipeline executor 100 can insert the work item into the second to fourth queues, or queue it from the second to fourth queues, and call the second to fourth cloud functions.

The video processing system 10 for streaming services includes the above-mentioned job item manager 11 and pipeline executor 100, and in some embodiments, may also include a video access module 12 and a cloud application monitoring module 13.

The operation item manager 11, the video access module 12, the cloud application monitoring module 13 and the pipeline executor 100 can be implemented in independent computing systems respectively, or at least one of the operation item manager 11, the video access module 12, the cloud application monitoring module 13 and the pipeline executor 100 can be implemented together through one computing system.

The configuration and operation of the entire system according to the present embodiment are described above. In particular, the operation of the pipeline executor 100 can be made clearer through the embodiment described later. That is, the operation of the pipeline executor 100 can be supplemented by the embodiment described later.

Next, a video processing method for streaming service according to another embodiment of the present invention is described with reference to FIGS. 2 to 8. The video processing method for streaming service according to this embodiment can be executed by more than one computing system. Furthermore, the video processing method for streaming service according to this embodiment can be partially executed by a first computing system, and other operations can be executed by a second computing system.

For example, the video processing method for streaming service according to the present embodiment can be performed partially by a pre-set (On-Premise) physical server, and other operations by a cloud server. In the following, when the execution subject of each operation is omitted, it will be understood that the execution subject is the computing system.

First, the video processing method for streaming service according to the present embodiment is briefly described with reference to FIG2 . The details of each step may be described later as needed. The creation of a job item for streaming the original video file is published to the topic of the main queue ( S100 ), and with the subscription of the topic of the main queue, the creation of the job item is detected, and the first pipeline is executed in response to the creation of the job item ( S200 ).

3 and 4 , step S200 is further described in detail.

FIG. 4 is a diagram conceptually showing the execution process of the first pipeline.

With the subscription of the topic of the main queue 300, when the creation of a job item for streaming the original video file is detected, the created job item is inserted into the first queue 410 of the first pipeline 400 (S210). Afterwards, the job item is dequeued from the first queue 410, and the first cloud function 420 is called in response to the dequeuing from the first queue 410 (S220). At this time, the first cloud function 420 can be a serverless computing application that executes the video access operation of the job item dequeued from the first queue 410 by executing the video access module 12.

Among them, the first cloud function 420 can correspond to the first queue 410 one by one. That is, the first queue 410 can be the exclusive queue of the first cloud function 420, and the first cloud function 420 can receive the execution target from the first queue 410. The first queue 410 can store and update information related to the execution result of the operation to be executed by the first cloud function 420, for example, whether the corresponding operation is successful, and if it fails, the number of related information. And, based on this information, the operation item manager 11 executes processing such as pausing video processing or deleting operation items from the main queue 300.

Afterwards, the cloud application monitoring module 13 monitoring the video access module 12 detects whether the execution of the video access operation is completed (S230). In response to detecting that the execution of the video access operation is completed, the completed video access operation item is inserted into the second queue 430 of the first pipeline 400 (S240).

Afterwards, the completed video access operation item is dequeued from the second queue 430, and the second cloud function 440 is called in response to the dequeuing from the second queue 430 (S250). At this time, the second cloud function 440 may be a serverless computing application that performs completion processing of the video access operation indicated by the operation item dequeued from the second queue 430.

The second cloud function 440 may correspond to the second queue 430 one by one. That is, the second queue 430 may be the exclusive queue of the second cloud function 440, and the second cloud function 440 may receive the execution target from the second queue 430. The second queue 430 may store and update information related to the execution result of the operation to be executed by the second cloud function 440, for example, whether the corresponding operation is successful, and if it fails, the number of related information. And, based on this information, the operation item manager 11 executes processing such as pausing video processing or deleting operation items from the main queue 300.

In some embodiments, the first cloud function 420 may include an instruction to execute the video access module 12 and update the status field of the record corresponding to the video original file of the created operation item. In this case, the status field may be updated to a status value corresponding to the executed state of the video access module 12.

Furthermore, in some embodiments, the second cloud function 440 may include an instruction to update the status field of the record based on whether the video access operation indicated by the operation item dequeued from the second queue 430 is successful. In this case, the status field may be updated to a status value corresponding to the success or failure of the video access operation indicated by the operation item dequeued from the second queue 430.

Like this, by including instructions to update the status field of the record corresponding to the video original file into each cloud function (in the case of the first pipeline, the first cloud function 420 and the second cloud function 440), the overall video processing situation can be recorded and monitored while using the cloud function.

5 , in other embodiments, the video processing method for streaming service may further include: following the subscription of the subject of the main queue 300, detecting the creation of a job item for streaming the original video file, and executing the second pipeline in response to the creation of the job item (S300).

Referring to FIG. 6 , step S300 is further described in detail.

In step S300, the created operation item is inserted into the third queue 510 of the second pipeline 500. Afterwards, the created operation item is dequeued from the third queue 510, and a third cloud function 520 is called in response to the dequeuing from the third queue 510. At this time, the third cloud function 520 may be a serverless computing application that calls a message creation API to publish a message notifying the creation of the operation item on a collaboration tool 530 such as Slack.

The third cloud function 520 may correspond to the third queue 510 one by one. That is, the third queue 510 may be the exclusive queue of the third cloud function 520, and the third cloud function 520 may receive the execution target from the third queue 510.

On the other hand, in some embodiments, the second cloud function 440 of the first pipeline 400 may, in response to the completion of processing of the video access operation indicated by the operation item dequeued from the second queue 430, insert the operation item dequeued from the second queue 430 into the third queue 510 of the second pipeline 500. Thus, the video processing status may be monitored by publishing a message to the collaboration tool 530.

7 , in other embodiments, the video processing method for streaming service further includes: detecting the creation of a job item for streaming the original video file along with the subscription of the topic of the main queue 300, and executing the third pipeline (S400) in response to the creation of the job item.

Referring to FIG. 8 , step S400 is further described in detail.

In step S400 , the created operation item is inserted into the fourth queue 610 of the third pipeline 600 .

Afterwards, the created operation item is dequeued from the fourth queue 610, and the fourth cloud function 620 is called in response to the dequeuing of the fourth queue 610. At this time, the fourth cloud function 620 is a serverless computing application including instructions for executing additional operations related to the video original file that are executed in parallel with the video access operation according to the operation item dequeued from the fourth queue 610. The additional operation may refer to multiple operations that can be executed in parallel with the video access operation, for example, any one of multiple operations such as a quality inspection operation, a subtitle processing operation, and a harmfulness verification operation. Such additional operations may be performed by a specific module 630 that executes the corresponding additional operation.

Furthermore, in response to the cloud application monitoring module 640 monitoring the specific module 630 detecting that the corresponding append operation is completed, the operation item indicated by the completed append operation may be inserted into the second queue 430 of the first pipeline 400. In this case, the operation item indicated by the completed append operation is dequeued from the second queue 430, and the second cloud function 440 is called in response to the dequeuing from the second queue 430. At this time, the second cloud function 440 may be a serverless computing application that performs completion processing of the video access operation indicated by the operation item dequeued from the second queue 430.

As described in the above embodiment, when multiple operations for streaming, such as video access, quality inspection, subtitle processing, and harmfulness verification, are executed by cloud functions, the multiple operations can be processed in parallel. Therefore, the time required from the content provider providing the original video file to the final provision of streaming services to users can be shortened, thereby quickly providing streaming services to users.

Furthermore, as described in the above embodiment, executing the multiple operations through cloud functions also has the advantage of easy expansion of the architecture. That is, when it is necessary to add a specific operation for video streaming to the existing logic, the architecture expansion can be achieved by simply connecting the pipeline including the cloud function for executing the specific operation to the main queue without modifying the existing source code as a whole.

On the other hand, the fourth cloud function 620 may correspond one-to-one to the fourth queue 610. That is, the fourth queue 610 may be the exclusive queue of the fourth cloud function 620, and the fourth cloud function 620 may receive the execution target from the fourth queue 610. The fourth queue 610 may store and update information related to the execution result of the operation to be executed by the fourth cloud function 620, for example, whether the corresponding operation is successful, and if it fails, the number of related information. And, based on this information, the operation item manager 11 executes processing such as pausing video processing or deleting operation items from the main queue 300.

FIG9 is a schematic hardware configuration diagram of a computing system 1000 according to some embodiments of the present invention.

As shown in FIG9 , the computing system 1000 of FIG9 may include: one or more processors 1100, a system bus 1600, a communication interface 1200, a memory 1400 for loading a computer program 1500 executed by the processor 1100, and an auxiliary memory 1300 for storing the computer program 1500. However, FIG9 only shows components related to an embodiment of the present invention. Therefore, a person of ordinary skill in the art to which the present invention belongs should understand that in addition to the components shown in FIG9 , other general components may also be included. That is, the computing system 1000 may include various components in addition to the components shown in FIG9 . And, in some cases, the computing system 1000 may be configured in a form in which some components shown in FIG9 are omitted. In the following, the components of computing system 1000 will be described.

The processor 1100 may control the overall operation of the components of the computing system 1000. The processor 1100 may include at least one of a CPU (Central Processing Unit), an MPU (Micro Processor Unit), an MCU (Micro Controller Unit), a GPU (Graphic Processing Unit), an NPU (Neural Processing Unit), or any processor known in the art. Furthermore, the processor 1100 may execute the operation of at least one application or program for executing the operation/method according to various embodiments of the present invention. The computing system 1000 may include one or more processors.

And, the memory 1400 can store various data, commands and/or information. The memory 1400 can load the computer program 1500 from the auxiliary memory 1300 to execute the method/operation according to various embodiments of the present invention. The memory 1400 can be implemented as a volatile memory such as a RAM, but the technical scope of the present invention is not limited thereto.

Furthermore, the system bus 1600 may provide a communication function between components of the computing system 1000. The system bus 1600 may be implemented as various types of buses, such as an address bus, a data bus, and a control bus.

Furthermore, the communication interface 1200 may support wired/wireless Internet communication of the computing system 1000. In addition, the communication interface 1200 may support various communication methods other than Internet communication. To this end, the communication interface 1200 may include a communication module known in the art.

Furthermore, the auxiliary memory 1300 can non-temporarily store one or more computer programs 1500. The auxiliary memory 1300 can include a non-volatile memory such as a flash memory, a hard disk, a removable disk, or any type of computer-readable recording medium known in the art.

Furthermore, the computer program 1500 may include one or more instructions, which, when loaded into the memory 1400, cause the processor 1100 to perform operations/methods according to various embodiments of the present invention. That is, when the computer program 1500 is loaded into the memory 1400, the processor 1100 may perform methods/operations according to various embodiments of the present invention by executing one or more instructions.

In some embodiments, the computer program 1500 may include: publishing a plurality of instructions for creating a job item for streaming a video raw file to a topic of a main queue; and detecting the creation of the job item as the topic of the main queue is subscribed, and executing a plurality of instructions of a first pipeline in response to the creation of the job item. At this time, the multiple instructions for executing the first pipeline may include: multiple instructions for inserting the created operation item into the first queue of the first pipeline; multiple instructions for queuing the operation item from the first queue and calling a first cloud function in response to the dequeuing from the first queue, wherein the first cloud function is a serverless computing application that executes a video access module to execute a video access operation of the operation item queued from the first queue; and detecting the operation item by a cloud application monitoring module for executing the video access module. The invention relates to a serverless computing application comprising: a plurality of instructions for detecting whether the video access operation is completed; a plurality of instructions for inserting the completed video access operation item into a second queue of the first pipeline in response to detecting that the video access operation is completed; and a plurality of instructions for queuing the completed video access operation item from the second queue and calling a second cloud function in response to dequeuing from the second queue, wherein the second cloud function is a serverless computing application for executing completion processing of the video access operation indicated by the operation item queued from the second queue.

In one embodiment, the video processing system for streaming services may further include: detecting the creation of the job item as the topic of the main queue is subscribed, and executing multiple instructions of the third pipeline in response to the creation of the job item. At this time, the multiple instructions for executing the third pipeline may include: multiple instructions for inserting the created job item into the fourth queue of the third pipeline; and instructions for queuing the created job item from the fourth queue and calling a fourth cloud function in response to dequeuing from the fourth queue, wherein the fourth cloud function is a serverless computing application including instructions for executing an append operation related to the video original file executed in parallel with the video access operation according to the job item queued from the fourth queue.

On the other hand, in some embodiments, the computing system 1000 shown in FIG. 9 may mean a virtual machine implemented based on cloud technology. Assume that the computing system 1000 is a virtual machine running in one or more physical servers in a server farm. In this case, at least a portion of the processor 1100, the memory 1400, and the auxiliary memory 1300 shown in FIG. 9 may be virtual hardware, and the communication interface 1200 may also be implemented as a virtualized network element such as a virtual switch.

In the above, with reference to FIG. 9 , a schematic computing system 1000 of a video processing system 10 for streaming services capable of implementing some embodiments of the present invention is described.

Various embodiments of the present invention and the effects according to the embodiments are described above with reference to Figures 1 to 9. The effects according to the technical idea of the present invention are not limited to the above effects, and those skilled in the art will clearly understand other effects not mentioned from the following description.

Furthermore, although the above embodiments illustrate that multiple components are combined into one or operate in combination, the technical concept of the present invention is not necessarily limited to these embodiments. That is, within the scope of the technical concept of the present invention, all components can be selectively combined into one or more to operate.

The technical ideas of the present invention described so far can be implemented as computer-readable codes on a computer-readable medium. The computer program recorded on the computer-readable recording medium can be sent to another computing system through a network such as the Internet, installed in the another computing system, and used in the another computing system.

Although operations are shown in the drawings in a particular order, it should not be understood that the operations must be performed in the particular order shown or in sequential order, or that all shown operations must be performed to achieve the desired results. In some cases, multitasking and parallel processing may be advantageous.

Although various embodiments of the present invention have been described with reference to the accompanying drawings, it should be understood by those skilled in the art that the technical concept of the present invention can be implemented in different specific forms without changing the technical concept or essential characteristics of the present invention. Therefore, the above embodiments should be understood to be illustrative rather than restrictive in all aspects. The scope of protection of the present invention should be interpreted by the scope of the attached patent application, and all technical concepts within the equivalent scope should be interpreted as included in the scope of rights of the technical concept defined by the present invention.

10: Video processing system for streaming services 11: Job manager 12: Video access module 13, 640: Cloud application monitoring module 100: Pipeline executor 20: Archive 300: Main queue 400, 500, 600: Pipeline 410, 430, 510, 610: Queue 420, 440, 520, 620: Cloud function 530: Collaboration tool 630: Module 1000: Computing system 1100: Processor 1200: Communication interface 1300: Auxiliary memory 1400: Memory 1500: Computer program 1600: System Bus S100, S200, S210, S220, S230, S240, S250, S300, S400: Steps

FIG1 is a configuration diagram of the entire system according to an embodiment of the present invention.

FIG. 2 is a flow chart of a video processing method for streaming services according to another embodiment of the present invention.

FIG. 3 is a flow chart for explaining part of the operation of the video processing method for streaming service with reference to FIG. 2 .

FIG. 4 is a diagram conceptually showing the execution process of the first pipeline.

FIG. 5 is a flow chart for illustrating a modified embodiment of the video processing method for streaming service described with reference to FIG. 2 .

FIG. 6 is a diagram conceptually showing the execution process of the first pipeline and the second pipeline.

FIG. 7 is a flow chart for illustrating a modified embodiment of the video processing method for streaming service described with reference to FIG. 2 .

FIG. 8 is a diagram conceptually showing the execution process of the first pipeline and the third pipeline.

FIG9 is a hardware configuration diagram of a computing system described in some embodiments of the present invention.

S100, S200: Steps

Claims (11)

A video processing method for streaming service, executed by a computing system, wherein, includes the following steps: Publishing the creation of a job item for streaming a video original file to a topic of a main queue; and Following the subscription of the topic of the main queue, detecting the creation of the job item, and executing a first pipeline in response to the creation of the job item, The step of executing the first pipeline includes the following steps: Inserting the created job item into a first queue of the first pipeline; Dequeue the operation item from the first queue, and call a first cloud function in response to the dequeue from the first queue, wherein the first cloud function is a serverless computing application that executes a video access module to execute a video access operation of the operation item queued from the first queue; Detect whether the video access operation is completed by a cloud application monitoring module for executing the video access module; In response to detecting that the video access operation is completed, insert the completed video access operation item into the second queue of the first pipeline; and The completed video access operation item is queued from the second queue, and a second cloud function is called in response to the dequeuing from the second queue, wherein the second cloud function is a serverless computing application that performs completion processing of the video access operation indicated by the operation item queued from the second queue. A video processing method for streaming service as claimed in claim 1, wherein the first cloud function corresponds to the first queue one-to-one, and the second cloud function corresponds to the second queue one-to-one. As in claim 1, the video processing method for streaming services, wherein the step of publishing the creation of the operation item to the main queue includes the following steps: Inserting the created operation item into the main queue by executing the content creation processing cloud function. As in claim 3, the step of inserting the created operation item into the main queue by executing the content creation processing cloud function comprises the following steps: By executing the content creation processing cloud function, adding the record corresponding to the original video file of the created operation item to the first table included in the database of the content management system (CMS). A video processing method for a streaming service as claimed in claim 4, wherein the first cloud function comprises: Instructions for executing the video access module and updating the status field of the record. A video processing method for a streaming service as claimed in claim 4, wherein the second cloud function comprises: Instructions for updating the status field of the record based on whether the video access operation indicated by the operation item queued from the second queue is successful. The video processing method for streaming service as claimed in claim 1 further comprises the following steps: With the subscription of the topic of the main queue, the creation of the operation item is detected, and the second pipeline is executed in response to the creation of the operation item. A video processing method for streaming services as claimed in claim 7, wherein the step of executing the second pipeline includes the following steps: Inserting the created operation item into the third queue of the second pipeline; and Queuing the created operation item from the third queue, and calling a third cloud function in response to dequeuing from the third queue, wherein the third cloud function is a serverless computing application that calls a message creation API to publish a message on the collaboration tool notifying the creation of the operation item. As in claim 1, a video processing method for streaming services, wherein, further comprises the following steps: with the subscription of the topic of the main queue, detecting the creation of the operation item, and executing the third pipeline in response to the creation of the operation item, the step of executing the third pipeline comprises the following steps: inserting the created operation item into the fourth queue of the third pipeline; and queuing the created operation item from the fourth queue, and calling the fourth cloud function in response to the dequeuing from the fourth queue, the fourth cloud function being a serverless computing application including instructions for executing the video original file-related appending operation executed in parallel with the frequency access operation according to the operation item queued from the fourth queue. A video processing system for streaming services, wherein, includes: a communication interface; a memory for loading a computer program; and a processor for executing the computer program, the computer program includes: multiple instructions for publishing the creation of a job item for streaming a video raw file to a topic of a main queue; and with the subscription of the topic of the main queue, detecting the creation of the job item, and executing multiple instructions of a first pipeline in response to the creation of the job item, the multiple instructions for executing the first pipeline include: multiple instructions for inserting the created job item into a first queue of the first pipeline; dequeue the operation item from the first queue, and in response to the dequeue from the first queue, call a first cloud function, wherein the first cloud function is a serverless computing application that executes a video access module to execute a video access operation of the operation item dequeued from the first queue; A plurality of instructions for detecting whether the video access operation is completed by a cloud application monitoring module for executing the video access module; In response to detecting that the video access operation is completed, insert the completed video access operation item into the second queue of the first pipeline; and The completed video access operation items are queued from the second queue, and multiple instructions of a second cloud function are called in response to the dequeuing from the second queue, wherein the second cloud function is a serverless computing application that performs completion processing of the video access operation indicated by the operation items queued from the second queue. As in claim 10, a video processing system for streaming services, wherein, further includes: with the subscription of the topic of the main queue, detecting the creation of the operation item, and executing multiple instructions of the third pipeline in response to the creation of the operation item, the multiple instructions for executing the third pipeline include: multiple instructions for inserting the created operation item into the fourth queue of the third pipeline; and an instruction for queuing the created operation item from the fourth queue, and calling a fourth cloud function in response to dequeuing from the fourth queue, the fourth cloud function being a serverless computing application including instructions for executing an append operation related to the video original file executed in parallel with the video access operation according to the operation item queued from the fourth queue.

Images