CN111654671B - Video data storage method, device, equipment and storage medium - Google Patents

Abstract

The application discloses a video data storage method, a video data storage device, video data storage equipment and a video data storage medium, and belongs to the technical field of data storage. The method comprises the following steps: reading an additional recording task for storing the missing video data, wherein the additional recording task is generated under the condition that the corresponding monitoring equipment has data storage capacity and the video data recorded by the monitoring equipment stored by the first storage node is missing, or the additional recording task is issued to the second storage node by the first storage node under the condition that the video data recorded by the monitoring equipment cannot be acquired and the monitoring equipment has the data storage capacity, and the first storage node and the second storage node are one of the plurality of storage nodes. The additional recording task is generated under the condition that the monitoring equipment can store the video data, so that after the additional recording task is issued, the second storage node can store the missing video data in an additional mode, and the problem of video data loss can be avoided.

Description

Video data storage method, device, equipment and storage medium

Technical Field

The present application relates to the field of data storage technologies, and in particular, to a method, an apparatus, a device, and a storage medium for storing video data.

Background

With the improvement of safety awareness, monitoring equipment is installed in more and more places to monitor a monitoring area. In general, a storage node may obtain a stream from a monitoring device to obtain video data recorded by the monitoring device for storage, but if the storage node cannot obtain the video data recorded by the monitoring device due to a network failure or the like, a part of the video data may be lost.

Disclosure of Invention

The application provides a method, a device, equipment and a storage medium for storing video data, which can solve the problem of video data loss in the related technology. The technical scheme is as follows:

in one aspect, a method for storing video data is provided, and is applied to a storage management node in a cloud storage system, where the cloud storage system further includes a plurality of storage nodes, and the method includes:

reading an additional recording task, wherein the additional recording task is generated under the condition that it is determined that corresponding monitoring equipment has data storage capacity and video data recorded by the monitoring equipment and stored by a first storage node is missing, or the additional recording task is generated by the first storage node under the condition that the video data recorded by the monitoring equipment cannot be acquired and the monitoring equipment is determined to have the data storage capacity, the additional recording task is a task for storing the missing video data, and the first storage node is one storage node in the plurality of storage nodes;

and issuing the additional recording task to a second storage node, wherein the second storage node is one of the plurality of storage nodes.

In a possible implementation manner of the present application, the supplementary recording task is generated when it is determined that the corresponding monitoring device has a data storage capability and video data recorded by the monitoring device and stored by the first storage node is missing, and the method further includes:

determining storage capacity information of the monitoring equipment, wherein the storage capacity information is used for indicating whether the monitoring equipment has data storage capacity or not;

and if the monitoring equipment is determined to have the data storage capacity based on the storage capacity information and the video data recorded by the monitoring equipment and stored by the first storage node is determined to have the deficiency based on the video plan of the monitoring equipment, generating the additional recording task.

In a possible implementation manner of this application, the determining that video data recorded by the monitoring device and stored in the first storage node is missing based on the video recording plan of the monitoring device includes:

acquiring storage state information of the video data recorded by the monitoring equipment and stored in the first storage node, wherein the storage state information comprises a second time range of the stored video data recorded by the monitoring equipment;

and determining whether the video data recorded by the monitoring equipment is missing or not according to the first time range and the second time range.

In a possible implementation manner of the present application, the generating the additional recording task includes:

determining a missing time range based on the first time range and the second time range, wherein the missing time range refers to a time range corresponding to the missing video data;

and generating the additional recording task based on the missing time range and the equipment identifier of the monitoring equipment.

In a possible implementation manner of the present application, the supplementary recording task is generated by the first storage node when it is determined that the monitoring device has a data storage capability and the first storage node cannot acquire video data recorded by the monitoring device, and the method further includes:

and receiving the additional recording task reported by the first storage node.

In a possible implementation manner of the present application, after the issuing the additional recording task to the second storage node, the method further includes:

receiving task state information fed back by the second storage node;

if the task state information includes a third time range corresponding to video data which is not stored in the second storage node in the missing video data, updating the missing time range in the supplementary recording task to the third time range, wherein the missing time range refers to the time range corresponding to the missing video data.

In one aspect, a video data storage method is provided and applied to a second storage node in a cloud storage system, where the second storage node is one of a plurality of storage nodes included in the cloud storage system, the cloud storage system further includes a storage management node, and the method includes:

acquiring an additional recording task, wherein the additional recording task is generated by the storage management node when it is determined that the corresponding monitoring equipment has data storage capacity and video data recorded by the monitoring equipment and stored by a first storage node is missing, or the additional recording task is generated by the first storage node when it is determined that the monitoring equipment cannot acquire the video data recorded by the monitoring equipment and the monitoring equipment has the data storage capacity, and the additional recording task is a task for storing the missing video data;

and storing the missing video data based on the supplementary recording task.

In a possible implementation manner of the present application, the entry supplementing task includes a missing time range and an apparatus identifier of the monitoring apparatus, where the missing time range refers to a time range corresponding to the missing video data, and storing the missing video data based on the entry supplementing task includes:

sending a first request to the monitoring equipment indicated by the equipment identification, wherein the first request comprises the missing time range, and the first request is used for requesting the monitoring equipment to feed back video data recorded in the missing time range;

and receiving and storing the video data fed back by the monitoring equipment.

In one possible implementation manner of the present application, the method further includes:

and reporting task state information of the additional recording task to the storage management node, wherein the task state information is used for indicating the completion condition of the first storage node on the additional recording task.

In one possible implementation manner of the present application, the method further includes:

receiving a video recording plan from the storage management node;

sending a second request to monitoring equipment corresponding to the video plan based on the video plan, wherein the second request is used for requesting the monitoring equipment to feed back storage capacity information;

and receiving and storing the storage capacity information fed back by the monitoring equipment.

In one possible implementation manner of the present application, the method further includes:

and sending the storage capacity information to the storage management node for storage.

In another aspect, a storage apparatus for video data is provided, where the storage apparatus is applied to a storage management node in a cloud storage system, where the cloud storage system further includes a plurality of storage nodes, and the apparatus includes:

the device comprises a reading module and a processing module, wherein the reading module is used for reading an additional recording task, the additional recording task is generated under the condition that the corresponding monitoring equipment has data storage capacity and video data recorded by the monitoring equipment and stored by a first storage node is missing, or the additional recording task is generated by the first storage node under the condition that the video data recorded by the monitoring equipment cannot be acquired and the monitoring equipment has the data storage capacity, the additional recording task is a task for storing the missing video data, and the first storage node is one of the plurality of storage nodes;

and the sending module is used for issuing the additional recording task to a second storage node, wherein the second storage node is one of the plurality of storage nodes.

In one possible implementation manner of the present application, the sending module is further configured to:

the additional recording task is generated under the condition that the corresponding monitoring equipment is determined to have data storage capacity and video data recorded by the monitoring equipment and stored by a first storage node is missing, and storage capacity information of the monitoring equipment is determined, wherein the storage capacity information is used for indicating whether the monitoring equipment has data storage capacity or not;

and if the monitoring equipment is determined to have the data storage capacity based on the storage capacity information and the video data recorded by the monitoring equipment and stored by the first storage node is determined to have the deficiency based on the video plan of the monitoring equipment, generating the additional recording task.

In one possible implementation manner of the present application, the sending module is further configured to:

the video recording plan comprises a first time range, and the storage state information of the video data recorded by the monitoring equipment and stored in the first storage node is obtained, wherein the storage state information comprises a second time range of the stored video data recorded by the monitoring equipment;

and determining whether the video data recorded by the monitoring equipment is missing or not according to the first time range and the second time range.

In one possible implementation manner of the present application, the sending module is further configured to:

determining a missing time range based on the first time range and the second time range, wherein the missing time range refers to a time range corresponding to the missing video data;

and generating the additional recording task based on the missing time range and the equipment identifier of the monitoring equipment.

In one possible implementation manner of the present application, the sending module is further configured to:

the additional recording task is generated by the first storage node under the condition that the video data recorded by the monitoring equipment cannot be acquired and the monitoring equipment is determined to have the data storage capacity, and the additional recording task reported by the first storage node is received.

In one possible implementation manner of the present application, the sending module is further configured to:

receiving task state information fed back by the second storage node;

if the task state information includes a third time range corresponding to video data which is not stored in the second storage node in the missing video data, updating the missing time range in the supplementary recording task to the third time range, wherein the missing time range refers to the time range corresponding to the missing video data.

In another aspect, a storage apparatus for video data is provided, and is applied to a second storage node in a cloud storage system, where the second storage node is one of a plurality of storage nodes included in the cloud storage system, the cloud storage system further includes a storage management node, and the apparatus includes:

an obtaining module, configured to obtain an additional recording task, where the additional recording task is generated by the storage management node when it is determined that the corresponding monitoring device has a data storage capability and video data recorded by the monitoring device and stored by a first storage node is missing, or the additional recording task is generated by the first storage node when it is determined that the monitoring device cannot obtain the video data recorded by the monitoring device and the monitoring device has the data storage capability, and the additional recording task is a task of storing the missing video data;

and the storage module is used for storing the missing video data based on the additional recording task.

In one possible implementation manner of the present application, the storage module is configured to:

the supplementary recording task comprises a missing time range and a device identifier of the monitoring device, wherein the missing time range refers to a time range corresponding to the missing video data, a first request is sent to the monitoring device indicated by the device identifier, the first request comprises the missing time range, and the first request is used for requesting the monitoring device to feed back the video data recorded in the missing time range;

and receiving and storing the video data fed back by the monitoring equipment.

In one possible implementation manner of the present application, the storage module is further configured to:

and reporting task state information of the additional recording task to the storage management node, wherein the task state information is used for indicating the completion condition of the first storage node on the additional recording task.

In one possible implementation manner of the present application, the storage module is further configured to:

receiving a video recording plan from the storage management node;

sending a second request to monitoring equipment corresponding to the video plan based on the video plan, wherein the second request is used for requesting the monitoring equipment to feed back storage capacity information;

and receiving and storing the storage capacity information fed back by the monitoring equipment.

In one possible implementation manner of the present application, the storage module is further configured to:

and sending the storage capacity information to the storage management node for storage.

In another aspect, an apparatus is provided, which includes a processor, a communication interface, a memory, and a communication bus, where the processor, the communication interface, and the memory complete communication with each other through the communication bus, the memory is used to store a computer program, and the processor is used to execute the program stored in the memory to implement the steps of the method for storing video data in one aspect or implement the steps of the method for storing video data in another aspect.

In another aspect, a computer-readable storage medium is provided, in which a computer program is stored, which, when being executed by a processor, implements the steps of the method for storing video data according to the above-mentioned one aspect, or implements the steps of the method for storing video data according to the above-mentioned another aspect.

In another aspect, a computer program product is provided, which comprises instructions that, when run on a computer, cause the computer to perform the steps of the method for storing video data according to one aspect described above, or to carry out the steps of the method for storing video data according to another aspect described above.

The technical scheme provided by the application can at least bring the following beneficial effects:

the additional recording task is a task for storing the missing video data, some monitoring devices have storage capacity and can store the recorded video data, while some monitoring devices cannot store the recorded video data, and for the monitoring devices without storage capacity, the generated additional recording task cannot acquire the missing video data for storage. Therefore, whether the monitoring equipment has the data storage capacity or not can be judged before the supplementary recording task is generated. Therefore, the supplementary recording task may be generated by the storage management node when it is determined that the corresponding monitoring device has the data storage capability and the video data recorded by the monitoring device and stored by the first storage node is missing, or the supplementary recording task may be generated by the first storage node when it is determined that the monitoring device has the data storage capability and the video data recorded by the monitoring device cannot be acquired by the first storage node, where the first storage node is one storage node of a plurality of storage nodes included in the cloud storage system. The storage management node may read the entry-supplementing task, and then issue the entry-supplementing task to a second storage node, where the second storage node executes the entry-supplementing task, and the second storage node is one of the plurality of storage nodes. The additional recording task is generated under the condition that the monitoring equipment can store the video data, so that after the additional recording task is issued, the second storage node can be used for performing additional storage on the missing video data, the problem that the video data are lost can be avoided, the condition that a large number of useless additional recording tasks are generated is also avoided, the waste of hardware resources is reduced, the storage pressure of a storage space is reduced, and the stability of the cloud storage system for storing the video data is further improved.

Drawings

In order to more clearly illustrate the technical solutions in the embodiments of the present application, the drawings needed to be used in the description of the embodiments are briefly introduced below, and it is obvious that the drawings in the following description are only some embodiments of the present application, and it is obvious for those skilled in the art to obtain other drawings based on these drawings without creative efforts.

FIG. 1 is a schematic diagram of an implementation environment shown in accordance with an exemplary embodiment;

FIG. 2 is a flow chart illustrating a method of storing video data in accordance with an exemplary embodiment;

fig. 3 is a flowchart illustrating a method of storing video data according to another exemplary embodiment;

fig. 4 is a flowchart illustrating a method of storing video data according to another exemplary embodiment;

FIG. 5 is a thread diagram illustrating a method of obtaining storage capability information in accordance with an illustrative embodiment;

FIG. 6 is a flow diagram illustrating a storage management node generating an append task in accordance with another illustrative embodiment;

fig. 7 is a schematic diagram illustrating a structure of a video data storage apparatus according to an exemplary embodiment;

fig. 8 is a schematic structural diagram illustrating a video data storage apparatus according to an exemplary embodiment;

FIG. 9 is a schematic diagram illustrating the structure of an apparatus according to an exemplary embodiment.

Detailed Description

To make the objects, technical solutions and advantages of the present application more clear, embodiments of the present application will be described in further detail below with reference to the accompanying drawings.

Before explaining the storage method of video data provided by the embodiment of the present application in detail, an implementation environment provided by the embodiment of the present application is introduced.

Referring to FIG. 1, FIG. 1 is a schematic diagram illustrating an implementation environment in accordance with an example embodiment. The implementation environment may be a cloud storage system, which may include astorage management node 101, astorage node 102, and amonitoring device 103. Thestorage management node 101 and thestorage node 102 may be in communication connection, and thestorage node 102 and themonitoring device 103 may be in communication connection, and the communication connection is typically a wireless connection.

The number of thestorage nodes 102 may be plural. Each storage node in the plurality of storage nodes may be respectively in communication connection with the storage management node, and each storage node may be respectively in communication connection with the monitoring device.

Thestorage management node 101 may be configured to manage thestorage node 102, record a condition that thestorage node 102 stores video data, and store a video recording plan corresponding to themonitoring device 103. As an example, thestorage management node 101 may be a server, a server cluster composed of a plurality of servers, or a cloud computing service center.

Thestorage node 102 may be configured to store video data recorded by themonitoring device 103. As an example, thestorage node 102 may be a server, a server cluster composed of a plurality of servers, or a cloud computing service center.

Themonitoring device 103 may be configured to record video data and send the video data to thestorage node 103 for storage. As an example, the monitoring device 104 may be a camera. For example, the monitoring device may be IPC (IP Camera), CVR (Central Video Recorder), NVR (Network Video Recorder), or the like.

It should be understood by those skilled in the art that thestorage management node 101, thestorage node 102 and themonitoring device 103 are only examples, and other existing or future monitoring platforms, storage management nodes, storage nodes or monitoring devices may be suitable for the present application, and are included in the scope of the present application and are incorporated herein by reference.

After the implementation environment provided by the embodiment of the present application is introduced, a detailed explanation is next given to a method for storing video data provided by the embodiment of the present application.

Fig. 2 is a flowchart illustrating a video data storage method according to an exemplary embodiment, where the method is applied to a storage management node of the cloud storage system, where the cloud storage system further includes a plurality of storage nodes. Referring to fig. 2, the method may include the following steps:

step 201: reading an additional recording task, wherein the additional recording task is generated under the condition that the corresponding monitoring equipment has data storage capacity and video data recorded by the monitoring equipment and stored by a first storage node is missing, or the additional recording task is generated by the first storage node under the condition that the video data recorded by the monitoring equipment cannot be acquired and the monitoring equipment has the data storage capacity, the additional recording task is a task for storing the missing video data, and the first storage node is one storage node in a plurality of storage nodes.

In a possible implementation manner of the present application, if the supplementary recording task is generated when it is determined that the corresponding monitoring device has a data storage capability and video data recorded by the monitoring device and stored by the first storage node is missing, the specific implementation may include: and determining storage capacity information of the monitoring equipment, wherein the storage capacity information is used for indicating whether the monitoring equipment has data storage capacity. And if the monitoring equipment is determined to have the data storage capacity based on the storage capacity information, and the video data recorded by the monitoring equipment and stored by the first storage node is determined to have loss based on the video plan of the monitoring equipment, generating an additional recording task.

The recording plan may be used to describe a time plan for the corresponding monitoring device to record the video data.

That is, since some monitoring devices do not have data storage capability, the obtained video data cannot be stored, and for such monitoring devices, even if a supplementary recording task is generated, the storage node cannot obtain the missing video data. Therefore, the storage management node may determine the storage capacity information of the monitoring device, determine whether the video data recorded by the monitoring device and stored in the first storage node is missing based on the video plan if it is determined that the monitoring device has the data storage capacity, and generate the supplementary recording task if the video data recorded by the monitoring device and stored in the first storage node is missing.

In a possible implementation manner of the present application, the video recording plan includes a first time range, and the specific implementation that the video data recorded by the monitoring device and stored in the first storage node is determined to have a loss based on the video recording plan of the monitoring device may include: and acquiring storage state information of the video data recorded by the monitoring equipment stored in the first storage node, wherein the storage state information comprises a second time range of the stored video data recorded by the monitoring equipment. And determining whether the video data recorded by the monitoring equipment is missing or not according to the first time range and the second time range.

And the first time range is the time range of the video data recorded by the monitoring equipment corresponding to the video plan. For example, the first time range may be 00:00-24:00, indicating that the monitoring device needs to record video data continuously for 24 hours per day.

In one possible implementation manner of the present application, the missing time range is determined based on the first time range and the second time range, and the missing time range refers to a time range corresponding to the missing video data. And generating an additional recording task based on the missing time range and the equipment identifier of the monitoring equipment.

In a possible implementation manner of the present application, if the additional recording task is generated by the first storage node under the condition that the video data recorded by the monitoring device cannot be acquired and it is determined that the monitoring device has the data storage capability, the additional recording task reported by the first storage node may be received.

As an example, if the first storage node suddenly fails to acquire video data recorded by the monitoring device during normal video data storage, which indicates that a fault may occur, in order to restore the video data during the fault after the fault is recovered, the first storage node may determine whether the monitoring device has a data storage capability, and generate a supplementary recording task when it is determined that the monitoring device has the data storage capability.

Further, after the first storage node generates the additional recording task, the additional recording task may be sent to the storage management node, and accordingly, the storage management node may receive the additional recording task reported by the first storage node and store the additional recording task in the task list.

Therefore, when the storage management node next patrols the video plan to determine whether to generate the additional recording task, the additional recording task for storing the video data of the monitoring equipment in the missing time range can be prevented from being repeatedly generated.

Step 202: and issuing the additional recording task to a second storage node, wherein the second storage node is one of the plurality of storage nodes.

In a possible implementation manner of the present application, after the entry supplementing task is issued to the second storage node, task state information fed back by the second storage node may also be received. And if the task state information comprises a third time range corresponding to video data which is not stored in the second storage node in the missing video data, updating the missing time range in the supplementary recording task into the third time range, wherein the missing time range refers to the time range corresponding to the missing video data.

Therefore, if the second storage node fails, the storage management node can send the additional recording task to other storage nodes, and the other storage nodes store the video data in the missing time range based on the third time range, so that the video data in some time period can be prevented from being missed and not stored, and the video data in some time period can be prevented from being stored repeatedly.

In the embodiment of the application, the supplementary recording task is a task for storing the missing video data, some monitoring devices have storage capacity and can store the recorded video data, while some monitoring devices cannot store the recorded video data, and for the monitoring devices without storage capacity, the generated supplementary recording task cannot acquire the missing video data for storage. Therefore, whether the monitoring equipment has the data storage capacity or not can be judged before the supplementary recording task is generated. Therefore, the supplementary recording task may be generated by the storage management node when it is determined that the corresponding monitoring device has the data storage capability and the video data recorded by the monitoring device and stored by the first storage node is missing, or the supplementary recording task may be generated by the first storage node when it is determined that the monitoring device has the data storage capability and the video data recorded by the monitoring device cannot be acquired by the first storage node, where the first storage node is one storage node of a plurality of storage nodes included in the cloud storage system. The storage management node may read the entry-supplementing task, and then issue the entry-supplementing task to a second storage node, where the second storage node executes the entry-supplementing task, and the second storage node is one of the plurality of storage nodes. The additional recording task is generated under the condition that the monitoring equipment can store the video data, so that after the additional recording task is issued, the second storage node can be used for performing additional storage on the missing video data, the problem that the video data are lost is avoided, the condition that a large number of useless additional recording tasks are generated is also avoided, the waste of hardware resources is reduced, the storage pressure of a storage space is reduced, and the stability of the cloud storage system for storing the video data is further improved.

Fig. 3 is a flowchart illustrating a video data storage method according to an exemplary embodiment, where the method is applied to a second storage node of the cloud storage system, where the second storage node is one of a plurality of storage nodes included in the cloud storage system, and the cloud storage system further includes a storage management node. Referring to fig. 3, the method may include the following steps:

step 301: acquiring an additional recording task, wherein the additional recording task is generated by a storage management node under the condition that the corresponding monitoring equipment has data storage capacity and video data recorded by the monitoring equipment stored by a first storage node is missing, or the additional recording task is generated by the first storage node under the condition that the video data recorded by the monitoring equipment cannot be acquired and the monitoring equipment has data storage capacity, and the additional recording task is a task for storing the missing video data.

In implementation, the entry-supplementing task may be sent by the storage management node, or may be generated by the second storage node itself.

As an example, since some monitoring devices do not have data storage capability, the obtained video data cannot be stored, and for such monitoring devices, even if an additional recording task is generated, the storage node cannot obtain the missing video data. Therefore, the storage management node may determine the storage capacity information of the monitoring device, determine whether the video data recorded by the monitoring device and stored in the first storage node is missing based on the video plan if it is determined that the monitoring device has the data storage capacity, and generate the supplementary recording task if the video data recorded by the monitoring device and stored in the first storage node is missing.

As another example, if the first storage node suddenly fails to acquire video data recorded by the monitoring device during normal video data storage, which indicates that a fault may occur, in order to restore the video data during the fault after the fault is recovered, the first storage node may determine whether the monitoring device has a data storage capability, and generate a supplementary recording task when it is determined that the monitoring device has the data storage capability.

In one possible implementation manner of the application, a video recording plan from a storage management node is received. And sending a second request to the monitoring equipment corresponding to the video plan based on the video plan, wherein the second request is used for requesting the monitoring equipment to feed back the storage capacity information. And receiving and storing the storage capacity information fed back by the monitoring equipment.

In a possible implementation manner of the present application, the storage capacity information may also be sent to the storage management node for storage.

Step 302: and storing the missing video data based on the supplementary recording task.

In a possible implementation manner of the present application, the supplementary recording task includes a missing time range and an apparatus identifier of the monitoring apparatus, where the missing time range refers to a time range corresponding to missing video data, and a specific implementation of storing the missing video data based on the supplementary recording task may include: and sending a first request to the monitoring equipment indicated by the equipment identification, wherein the first request comprises a missing time range, and the first request is used for requesting the monitoring equipment to feed back the video data recorded in the missing time range. And receiving and storing the video data fed back by the monitoring equipment.

In a possible implementation manner of the present application, task state information of the entry-supplementing task may also be reported to the storage management node, where the task state information is used to indicate a completion condition of the entry-supplementing task by the first storage node.

That is to say, in the process of executing the entry-supplementing task, the storage node may report the task state information to the storage management node, so that the storage management node may update the completion condition of the entry-supplementing task in real time.

In the embodiment of the application, the supplementary recording task is a task for storing the missing video data, some monitoring devices have storage capacity and can store the recorded video data, while some monitoring devices cannot store the recorded video data, and for the monitoring devices without storage capacity, the generated supplementary recording task cannot acquire the missing video data for storage. Therefore, whether the monitoring equipment has the data storage capacity or not can be judged before the supplementary recording task is generated. Therefore, the supplementary recording task may be generated by the storage management node when it is determined that the corresponding monitoring device has the data storage capability and the video data recorded by the monitoring device and stored by the first storage node is missing, or the supplementary recording task may be generated by the first storage node when it is determined that the monitoring device has the data storage capability and the video data recorded by the monitoring device cannot be acquired by the first storage node, where the first storage node is one storage node of a plurality of storage nodes included in the cloud storage system. The supplement and record task is generated under the condition that the monitoring equipment can store the video data, so that after the second storage node acquires the supplement and record task, the second storage node can supplement and store the missing video data based on the supplement and record task, the problem that the video data are lost can be avoided, the condition that a large number of useless supplement and record tasks are generated is also avoided, the waste of hardware resources is reduced, the storage pressure of a storage space is reduced, and the stability of the cloud storage system for storing the video data is improved.

Fig. 4 is a flowchart illustrating a video data storage method applied to the cloud storage system, where the cloud storage system includes a storage management node and a plurality of storage nodes, according to an exemplary embodiment. Referring to fig. 4, the method may include the following steps:

step 401: the storage management node reads an additional recording task, wherein the additional recording task is generated under the condition that the corresponding monitoring equipment has data storage capacity and video data recorded by the monitoring equipment and stored by the first storage node is missing, or the additional recording task is generated by the first storage node under the condition that the video data recorded by the monitoring equipment cannot be acquired and the monitoring equipment has data storage capacity, the additional recording task is a task for storing the missing video data, and the first storage node is one of the plurality of storage nodes.

In an implementation, the storage management node may store the logging task therein. The completion task may be generated by the storage management node or the first storage node. That is, the entry-supplementing task in the storage management node may include that generated by the storage management node, may also include that generated by the storage node, or may further include that generated by the storage management node and that generated by the storage node. And, the storage management node may store the additional tasks in the form of a task list. The storage management node can periodically patrol the task list, and if the task list comprises the additional task, the additional task can be read. For example, the period may be half an hour, 1 hour, 2 hours, etc.

In implementation, the additional tasks may be generated in two cases as follows.

In the first case: the additional recording task is generated under the condition that the corresponding monitoring equipment has data storage capacity and the video data recorded by the monitoring equipment stored by the first storage node is missing.

In this case, the specific implementation of generating the additional recording task may include: and determining storage capacity information of the monitoring equipment, wherein the storage capacity information is used for indicating whether the monitoring equipment has data storage capacity. And if the monitoring equipment is determined to have the data storage capacity based on the storage capacity information, and the video data recorded by the monitoring equipment and stored by the first storage node is determined to have loss based on the video plan of the monitoring equipment, generating an additional recording task.

The recording plan may be used to describe a time plan for the corresponding monitoring device to record the video data. As an example, the Cloud storage system may further include a monitoring platform, the video recording Plan may be set by a user through the monitoring platform, and sent to the storage management node by the monitoring platform, and the storage management node may receive and store the video recording Plan in a CPM (Cloud plane management) layer. Further, the video schedule may further include a device identifier of the monitoring device, so that the storage management node may record the monitoring device corresponding to the video schedule. Illustratively, the device identification may be a symbol, a number, a model number of the monitoring device, and the like.

That is to say, some monitoring devices do not have data storage capability, and thus cannot store the acquired video data, and for such monitoring devices, even if a supplementary recording task is generated, the storage node cannot acquire the missing video data. Therefore, the storage management node may determine the storage capacity information of the monitoring device, determine whether the video data recorded by the monitoring device and stored in the first storage node is missing based on the video plan if it is determined that the monitoring device has the data storage capacity, and generate the supplementary recording task if the video data recorded by the monitoring device and stored in the first storage node is missing.

In an implementation, determining the specific implementation of the storage capability information of the monitoring device may include: and acquiring the storage capacity information of the monitoring equipment from the video recording plan corresponding to the monitoring equipment. Or, acquiring the storage capability information of the monitoring device according to the device identifier of the monitoring device.

Further, after receiving the video recording plan of the monitoring platform, the storage management node may send the video recording plan to the storage node. The storage node receives the video plan from the storage management node, and may send a second request to the monitoring device corresponding to the video plan, where the second request is used to request the monitoring device to feed back the storage capability information, and then the storage node receives the storage capability information fed back by the monitoring device, and sends the storage capability information to the storage management node for storage.

That is to say, the storage management node may send the received video recording plan to the storage node, after receiving the video recording plan, the storage node may send a second request for obtaining storage capability information to the monitoring device corresponding to the video recording plan, and then receive the storage capability information fed back by the monitoring device, and the storage node sends the storage capability information to the storage management node, and the storage management node stores the storage capability information.

In some embodiments, the image plan may be received by a CVA (Cloud Video Access) layer of the storage node, and the storage capability information of the monitoring device may be obtained by the CVA layer through an SDK (Software Development Kit). The SDK is an interface call set provided by the storage node for the external service.

As an example, referring to fig. 5, the CPM of the storage management node issues the video schedule to the CVA scheduling module, then the CVA scheduling module sends the second request to the CVA video module, the CVA video module sends the second request to the monitoring device through the SDK, after receiving the second request, the monitoring device returns the storage capacity information to the CVA video module through the SDK, then the CVA video module returns the storage capacity information to the CVA scheduling module, and then the CVA scheduling module returns the storage capacity information to the CPM, and the CPM stores the storage capacity information.

As an example, the storage node may send the second request to the monitoring device before fetching the stream from the monitoring device, or the storage node may send the second request to the monitoring device during fetching the stream from the monitoring device.

As an example, the storage management node may store the received storage capability information in a video recording plan corresponding to the monitoring device, or the storage management node may store the received storage capability information in correspondence with the video recording plan corresponding to the monitoring device. Correspondingly, the storage management node may determine the storage capability information of the monitoring device from the video recording plan corresponding to the monitoring device, or the storage management node may obtain the stored storage capability information of the monitoring device.

In an implementation, the video recording plan may include a first time range, and the specific implementation of determining that video data recorded by the monitoring device and stored in the first storage node is missing based on the video recording plan of the monitoring device may include: and acquiring storage state information of the video data recorded by the monitoring equipment stored in the first storage node, wherein the storage state information comprises a second time range of the stored video data recorded by the monitoring equipment. And determining whether the video data recorded by the monitoring equipment is missing or not according to the first time range and the second time range.

And the first time range is the time range of the video data recorded by the monitoring equipment corresponding to the video plan. For example, the first time range may be 00:00-24:00, indicating that the monitoring device needs to record video data continuously for 24 hours per day.

That is, the second time range of the video data recorded by the monitoring device, which has been stored by the first storage node, may be obtained, and then it may be determined whether there is a deletion in the video data recorded by the monitoring device according to the first time range and the second time range.

In some embodiments, the storage node may send the storage status of the video data to the storage management node, and therefore, a CPM layer of the storage management node may call an AMS (Application Manager Service) layer interface to obtain storage status information of the video data recorded by the monitoring device stored in the first storage node from other layers of the storage management node.

In some embodiments, the specific implementation of determining whether the video data recorded by the monitoring device is missing according to the first time range and the second time range may include: and determining a fourth time range between the starting time point of the second time range and the current time point, and if one or more time periods in the fourth time range are not included in the second time range, determining that the video data recorded by the monitoring equipment is missing.

For example, assuming that the second time range is 1 month, 1 day 00:00-1 month, 3 days, 12:20, the current time point is 13:00, the first time range is 00:00-24:00, the fourth time range may be determined to be 00: 00-13:00, it may be determined that the second time range does not include the time period of 12:20-13:00 in the fourth time range, which indicates that the video data recorded by the monitoring device at 12:20-13:00 is not stored in the first storage node, i.e., it is determined that the video data recorded by the monitoring device is missing.

It should be noted that the foregoing embodiment is only one implementation manner of determining whether video data recorded by a monitoring device is missing, and in other embodiments, whether video data recorded by the monitoring device is missing may also be determined in other manners, which is not limited in this application embodiment.

In implementation, the specific implementation of generating the additional recording task may include: based on the first time range and the second time range, a missing time range is determined, the missing time range being a time range corresponding to the missing video data. And generating an additional recording task based on the missing time range and the equipment identifier of the monitoring equipment.

As an example, the second time range may be subtracted from the first time range to obtain the missing time range, and then an entry supplementing task may be generated, where the missing time range and the device identifier of the monitoring device may be included in the entry supplementing task, so that the storage node may determine which monitoring device stores the video data in which time range.

Further, before generating the supplementary recording task, a task list may be further queried to determine whether the task list includes a supplementary recording task for storing the video data of the monitoring device in the missing time period, if the task list does not include the supplementary recording task for storing the video data of the monitoring device in the missing time period, the supplementary recording task is generated, and if the task list includes the supplementary recording task for storing the video data of the monitoring device in the missing time period, the supplementary recording task is not required to be generated.

In addition, the supplementary recording task in the task list may be generated by the storage management node in the process of traversing the stored video recording plan.

As an example, a process of generating an entry supplementing task by a storage management node in the embodiment of the present application is briefly described below with reference to fig. 6.

If the automatic recording supplementing switch is in an on state, the storage management node can traverse a plurality of video plans in the stored task list, read the video plans, and then acquire the storage capacity information of the monitoring equipment corresponding to the video plans.

Judging whether the monitoring equipment has data storage capacity, if the monitoring equipment has the data storage capacity, acquiring storage state information of video data recorded by the monitoring equipment and stored by a first storage node through an AMS (automatic monitoring system), determining whether the video data recorded by the monitoring equipment and stored by the first storage node is missing or not based on a video plan and the storage state information, if the video data recorded by the monitoring equipment and stored by the first storage node is missing, generating an automatic re-recording task, and further adding the automatic re-recording task into a task list. And then judging whether the last video plan in the task list is traversed or not, if the last video plan in the task list is not traversed, acquiring the storage capacity information of the monitoring equipment corresponding to the next video plan, and returning to the step of judging whether the monitoring equipment has the data storage capacity or not.

And if the monitoring equipment does not have the data storage capacity, continuously judging whether the monitoring equipment traverses to the last video recording plan of the task list, if the monitoring equipment does not traverse to the last video recording plan of the task list, acquiring the storage capacity information of the monitoring equipment corresponding to the next video recording plan, and returning to the step of judging whether the monitoring equipment has the data storage capacity.

If the video data recorded by the monitoring equipment and stored by the first storage node is not missing, whether the last video plan of the task list is traversed or not can be continuously judged, if the last video plan of the task list is not traversed, the storage capacity information of the monitoring equipment corresponding to the next video plan is obtained, and the step of judging whether the monitoring equipment has the data storage capacity or not is returned.

It should be noted that the processes of generating the additional recording task and reading and issuing the additional recording task by the storage management node are parallel, that is, in the process of generating the additional recording task by the storage management node, the additional recording task can be read and issued in parallel, the two tasks do not interfere with each other, and the storage efficiency of the video data can be improved.

In the second case: the additional recording task is generated by the first storage node under the condition that the video data recorded by the monitoring equipment cannot be acquired and the monitoring equipment is determined to have the data storage capacity.

In this case, the specific implementation of generating the additional recording task may include: in the process of storing the video data, if the video data recorded by the monitoring equipment cannot be acquired by the first storage node, the storage capacity information of the monitoring equipment can be determined, and if the monitoring equipment is determined to have the data storage capacity based on the storage capacity information, the additional recording task can be generated based on the current time point.

That is to say, if the first storage node suddenly fails to acquire video data recorded by the monitoring device during the normal video data storage process, which indicates that a fault may occur, in order to restore the video data during the fault after the fault is recovered, the first storage node may determine whether the monitoring device has a data storage capability, and generate a supplementary recording task when it is determined that the monitoring device has the data storage capability.

In implementation, after receiving the video recording plan sent by the storage management node, the first storage node may send a second request for obtaining storage capability information to the monitoring device corresponding to the video recording plan, and receive the storage capability information fed back by the monitoring device, and the first storage node may store the storage capability information, so that the first storage node may directly obtain the storage capability information of the monitoring device, and determine whether the monitoring device has a data storage capability.

In implementation, the specific implementation of generating the supplementary task based on the current time point may include: the storage node generates an additional recording task, wherein the additional recording task comprises a missing time range, the starting time point of the missing time range is the current time point, and the duration of the missing time range can be the designated duration. In addition, the supplementary recording task may further include a device identifier of the monitoring device.

The specified duration may be set by a user according to actual needs, or may be set by default by the storage node, which is not limited in the embodiment of the present application. For example, the specified time period may be 1 minute.

Further, after the first storage node generates the additional recording task, the additional recording task may be sent to the storage management node, and accordingly, the storage management node may receive the additional recording task reported by the first storage node and store the additional recording task in the task list.

Therefore, when the storage management node next patrols the video plan to determine whether to generate the additional recording task, the additional recording task for storing the video data of the monitoring equipment in the missing time range can be prevented from being repeatedly generated.

Further, under the condition that the automatic additional recording task is in an open state in the monitoring platform of the cloud storage system, the storage management node may periodically inspect the stored video plans, and for each video plan, the additional recording task may be generated under the condition that it is determined that the monitoring device corresponding to the video plan has a data storage capability and that video data recorded by the monitoring device stored by the first storage node is missing. Wherein the period is generally less than 24 hours, for example, the period can be 1 hour, 2 hours, and the like.

Step 402: and the storage management node issues the additional recording task to a second storage node, wherein the second storage node is one of the plurality of storage nodes.

The storage management node can establish communication connection with each storage node in the plurality of storage nodes, so that after reading the additional recording task, the storage management node can send the additional recording task to the second storage node, so that the second storage node can execute the additional recording task, acquire the missing video data and store the video data.

As an example, the second storage node may be the same storage node as the first storage node. That is, the storage node that lacks the stored video data and the storage node that supplements the missing video data are the same storage node. Of course, in another embodiment, the second storage node may not be the same storage node as the first storage node.

Step 403: and the second storage node acquires the additional recording task.

The method comprises the steps that a storage management node generates a supplementary recording task when determining that corresponding monitoring equipment has data storage capacity and video data recorded by the monitoring equipment and stored by a first storage node is missing, or the supplementary recording task is generated when the first storage node cannot acquire the video data recorded by the monitoring equipment and determines that the monitoring equipment has the data storage capacity, and the supplementary recording task is a task for storing the missing video data.

In implementation, the second storage node may obtain the supplementary recording task in two implementation manners:

the first implementation mode comprises the following steps: and the second storage node receives the supplementary recording task from the storage management node.

In this implementation manner, the entry-supplementing task from the storage management node may be generated by the storage management node, or may be generated by the first storage node and reported to the storage management node for storage.

The second implementation mode comprises the following steps: and acquiring the generated supplementary recording task.

In this implementation manner, the second storage node may generate the entry supplementing task and obtain the entry supplementing task generated by itself.

It should be noted that the process of generating the entry supplementing task by the second storage node is the same as the process of generating the entry supplementing task by the first storage node, and for a specific implementation process, reference may be made to the related description of the above steps, and this step is not described herein again. The first storage node may be the same storage node or may be a different storage node.

Step 404: and the second storage node stores the missing video data based on the supplementary recording task.

In an implementation, a specific implementation of storing the missing video data based on the dubbing task may include: and sending a first request to the monitoring equipment indicated by the equipment identification, wherein the first request comprises a missing time range, and the first request is used for requesting the monitoring equipment to feed back the video data recorded in the missing time range. And receiving and storing the video data fed back by the monitoring equipment.

That is to say, the storage node may send a first request for acquiring video data to the monitoring device indicated by the device identifier, then receive video data recorded in the missing time range and fed back by the monitoring device, and store the received video data.

In implementation, the second storage node may also report task state information of the entry-supplementing task to the storage management node, where the task state information is used to indicate a completion condition of the entry-supplementing task by the first storage node.

That is to say, in the process of executing the entry-supplementing task, the storage node may report the task state information to the storage management node, so that the storage management node may update the completion condition of the entry-supplementing task in real time.

Accordingly, the storage management node may receive the task state information fed back by the second storage node. And if the task state information comprises a third time range corresponding to video data which is not stored in the second storage node in the missing video data, updating the missing time range in the supplementary recording task into the third time range.

That is to say, the storage management node may receive the task state information from the second storage node, and if the task state information includes a third time range corresponding to video data that is not stored by the second storage node in the missing video data, it indicates that the second storage node has not completely stored the video data in the missing time range, and further, the video data recorded in the third time range is not stored, the storage management node may update the missing time range in the dubbing task to the third time range.

Therefore, if the second storage node fails, the storage management node can send the additional recording task to other storage nodes, and the other storage nodes store the video data in the missing time range based on the third time range, so that the video data in some time period can be prevented from being missed and not stored, and the video data in some time period can be prevented from being stored repeatedly.

As an example, if the task state information is used to indicate that the task is completed, the storage management node may delete the entry-added task from the task list, so as to avoid repeatedly issuing the entry-added task to the second storage node, which may cause the entry-added task to be repeatedly executed, and thus, the storage burden may be brought to the storage node.

In the embodiment of the application, the supplementary recording task is a task for storing the missing video data, some monitoring devices have storage capacity and can store the recorded video data, while some monitoring devices cannot store the recorded video data, and for the monitoring devices without storage capacity, the generated supplementary recording task cannot acquire the missing video data for storage. Therefore, whether the monitoring equipment has the data storage capacity or not can be judged before the supplementary recording task is generated. Therefore, the supplementary recording task may be generated by the storage management node when it is determined that the corresponding monitoring device has the data storage capability and the video data recorded by the monitoring device and stored by the first storage node is missing, or the supplementary recording task may be generated by the first storage node when it is determined that the monitoring device has the data storage capability and the video data recorded by the monitoring device cannot be acquired by the first storage node, where the first storage node is one storage node of a plurality of storage nodes included in the cloud storage system. The storage management node can read the supplement and record task and then sends the read supplement and record task to the second storage node, after the second storage node obtains the supplement and record task, the second storage node can perform supplement storage on the missing video data based on the supplement and record task, and the second storage node is one of the plurality of storage nodes. The additional recording task is generated under the condition that the monitoring equipment can store the video data, so that after the additional recording task is issued, the second storage node can be used for performing additional storage on the missing video data, the problem that the video data are lost can be avoided, the condition that a large number of useless additional recording tasks are generated is also avoided, the waste of hardware resources is reduced, the storage pressure of a storage space is reduced, and the stability of the cloud storage system for storing the video data is further improved.

Fig. 7 is a schematic structural diagram illustrating a storage apparatus for video data, which may be implemented by software, hardware, or a combination of the two as part or all of a device, which may be a storage management node shown in fig. 1, according to an exemplary embodiment. Referring to fig. 7, the apparatus includes: areading module 701 and a sendingmodule 702.

Areading module 701, configured to read an additional recording task, where the additional recording task is generated when it is determined that a corresponding monitoring device has a data storage capability and video data recorded by the monitoring device and stored by a first storage node is missing, or the additional recording task is generated by the first storage node when it is determined that the video data recorded by the monitoring device cannot be acquired and the monitoring device has the data storage capability, the additional recording task is a task of storing the missing video data, and the first storage node is one storage node of a plurality of storage nodes;

the sendingmodule 702 is configured to issue an entry supplementing task to a second storage node, where the second storage node is one of the plurality of storage nodes.

In one possible implementation manner of the present application, the sendingmodule 702 is further configured to:

the additional recording task is generated under the condition that the corresponding monitoring equipment has data storage capacity and the video data recorded by the monitoring equipment and stored by the first storage node is lost, and storage capacity information of the monitoring equipment is determined, wherein the storage capacity information is used for indicating whether the monitoring equipment has the data storage capacity or not;

and if the monitoring equipment is determined to have the data storage capacity based on the storage capacity information, and the video data recorded by the monitoring equipment and stored by the first storage node is determined to have loss based on the video plan of the monitoring equipment, generating an additional recording task.

In one possible implementation manner of the present application, the sendingmodule 702 is further configured to:

the video recording plan comprises a first time range, and the storage state information of the video data recorded by the monitoring equipment and stored in the first storage node is obtained, wherein the storage state information comprises a second time range of the stored video data recorded by the monitoring equipment;

and determining whether the video data recorded by the monitoring equipment is missing or not according to the first time range and the second time range.

In one possible implementation manner of the present application, the sendingmodule 702 is further configured to:

determining a missing time range based on the first time range and the second time range, wherein the missing time range refers to a time range corresponding to the missing video data;

and generating an additional recording task based on the missing time range and the equipment identifier of the monitoring equipment.

In one possible implementation manner of the present application, the sendingmodule 702 is further configured to:

the additional recording task is generated by the first storage node under the condition that the video data recorded by the monitoring equipment cannot be acquired and the monitoring equipment is determined to have the data storage capacity, and the additional recording task reported by the first storage node is received.

In one possible implementation manner of the present application, the sendingmodule 702 is further configured to:

receiving task state information fed back by a second storage node;

and if the task state information comprises a third time range corresponding to video data which is not stored in the second storage node in the missing video data, updating the missing time range in the supplementary recording task into the third time range, wherein the missing time range refers to the time range corresponding to the missing video data.

In the embodiment of the application, the supplementary recording task is a task for storing the missing video data, some monitoring devices have storage capacity and can store the recorded video data, while some monitoring devices cannot store the recorded video data, and for the monitoring devices without storage capacity, the generated supplementary recording task cannot acquire the missing video data for storage. Therefore, whether the monitoring equipment has the data storage capacity or not can be judged before the supplementary recording task is generated. Therefore, the supplementary recording task may be generated by the storage management node when it is determined that the corresponding monitoring device has the data storage capability and the video data recorded by the monitoring device and stored by the first storage node is missing, or the supplementary recording task may be generated by the first storage node when it is determined that the monitoring device has the data storage capability and the video data recorded by the monitoring device cannot be acquired by the first storage node, where the first storage node is one storage node of a plurality of storage nodes included in the cloud storage system. The storage management node may read the entry-supplementing task, and then issue the entry-supplementing task to a second storage node, where the second storage node executes the entry-supplementing task, and the second storage node is one of the plurality of storage nodes. The additional recording task is generated under the condition that the monitoring equipment can store the video data, so that after the additional recording task is issued, the second storage node can be used for performing additional storage on the missing video data, the problem that the video data are lost is avoided, the condition that a large number of useless additional recording tasks are generated is also avoided, the waste of hardware resources is reduced, the storage pressure of a storage space is reduced, and the stability of the cloud storage system for storing the video data is further improved.

It should be noted that: in the storage device for video data provided in the above embodiment, when storing video data, only the division of the above functional modules is taken as an example, and in practical applications, the above function distribution may be completed by different functional modules according to needs, that is, the internal structure of the device is divided into different functional modules to complete all or part of the above described functions. In addition, the storage apparatus for video data and the storage method embodiment for video data provided by the foregoing embodiments belong to the same concept, and specific implementation processes thereof are detailed in the method embodiment and are not described herein again.

Fig. 8 is a schematic structural diagram illustrating a storage apparatus for video data, which may be implemented by software, hardware, or a combination of the two as part or all of a device, which may be the second storage node shown in fig. 1, where the second storage node is one of a plurality of storage nodes included in a cloud storage system according to another exemplary embodiment. Referring to fig. 8, the apparatus includes: anacquisition module 801 and astorage module 802.

An obtainingmodule 801, configured to obtain an additional recording task, where the additional recording task is generated by a storage management node when it is determined that a corresponding monitoring device has a data storage capability and video data recorded by the monitoring device and stored by a first storage node is missing, or the additional recording task is generated by the first storage node when it is determined that the monitoring device cannot obtain video data recorded by the monitoring device and the monitoring device has the data storage capability, and the additional recording task is a task of storing the missing video data;

astorage module 802, configured to store the missing video data based on the dubbing task.

In one possible implementation manner of the present application, thestorage module 802 is configured to:

the supplementary recording task comprises a missing time range and a device identifier of the monitoring device, wherein the missing time range refers to a time range corresponding to missing video data, a first request is sent to the monitoring device indicated by the device identifier, the first request comprises the missing time range, and the first request is used for requesting the monitoring device to feed back the video data recorded in the missing time range;

and receiving and storing the video data fed back by the monitoring equipment.

In one possible implementation manner of the present application, thestorage module 802 is further configured to:

and reporting task state information of the additional recording task to the storage management node, wherein the task state information is used for indicating the completion condition of the first storage node on the additional recording task.

In one possible implementation manner of the present application, thestorage module 802 is further configured to:

receiving a video recording plan from a storage management node;

sending a second request to the monitoring equipment corresponding to the video plan based on the video plan, wherein the second request is used for requesting the monitoring equipment to feed back the storage capacity information;

and receiving and storing the storage capacity information fed back by the monitoring equipment.

In one possible implementation manner of the present application, thestorage module 802 is further configured to:

and sending the storage capacity information to a storage management node for storage.

In the embodiment of the application, the supplementary recording task is a task for storing the missing video data, some monitoring devices have storage capacity and can store the recorded video data, while some monitoring devices cannot store the recorded video data, and for the monitoring devices without storage capacity, the generated supplementary recording task cannot acquire the missing video data for storage. Therefore, whether the monitoring equipment has the data storage capacity or not can be judged before the supplementary recording task is generated. Therefore, the supplementary recording task may be generated by the storage management node when it is determined that the corresponding monitoring device has the data storage capability and the video data recorded by the monitoring device and stored by the first storage node is missing, or the supplementary recording task may be generated by the first storage node when it is determined that the monitoring device has the data storage capability and the video data recorded by the monitoring device cannot be acquired by the first storage node, where the first storage node is one storage node of a plurality of storage nodes included in the cloud storage system. The supplement and record task is generated under the condition that the monitoring equipment can store the video data, so that after the second storage node acquires the supplement and record task, the second storage node can supplement and store the missing video data based on the supplement and record task, the problem that the video data are lost can be avoided, the condition that a large number of useless supplement and record tasks are generated is also avoided, the waste of hardware resources is reduced, the storage pressure of a storage space is reduced, and the stability of the cloud storage system for storing the video data is improved.

It should be noted that: in the storage device for video data provided in the above embodiment, when storing video data, only the division of the above functional modules is taken as an example, and in practical applications, the above function distribution may be completed by different functional modules according to needs, that is, the internal structure of the device is divided into different functional modules to complete all or part of the above described functions. In addition, the storage apparatus for video data and the storage method embodiment for video data provided by the foregoing embodiments belong to the same concept, and specific implementation processes thereof are detailed in the method embodiment and are not described herein again.

FIG. 9 is a schematic diagram illustrating the structure of an apparatus according to an exemplary embodiment. The device may be a storage management node or a storage node. Thedevice 900 includes a Central Processing Unit (CPU)901, asystem memory 904 including a Random Access Memory (RAM)902 and a Read Only Memory (ROM)903, and asystem bus 905 connecting thesystem memory 904 and thecentral processing unit 901. Thedevice 900 also includes a basic input/output system (I/O system) 906 for facilitating the transfer of information between devices within the computer, and amass storage device 907 for storing anoperating system 913,application programs 914, andother program modules 915.

The basic input/output system 906 includes adisplay 908 for displaying information and aninput device 909 such as a mouse, keyboard, etc. for user input of information. Wherein adisplay 908 and aninput device 909 are connected to thecentral processing unit 901 through an input-output controller 910 connected to thesystem bus 905. The basic input/output system 906 may also include an input/output controller 910 for receiving and processing input from a number of other devices, such as a keyboard, mouse, or electronic stylus. Similarly, input-output controller 910 also provides output to a display screen, a printer, or other type of output device.

Themass storage device 907 is connected to thecentral processing unit 901 through a mass storage controller (not shown) connected to thesystem bus 905. Themass storage device 907 and its associated computer-readable media provide non-volatile storage for thedevice 900. That is,mass storage device 907 may include a computer-readable medium (not shown) such as a hard disk or CD-ROM drive.

Without loss of generality, computer readable media may comprise computer storage media and communication media. Computer storage media includes volatile and nonvolatile, removable and non-removable media implemented in any method or technology for storage of information such as computer readable instructions, data structures, program modules or other data. Computer storage media includes RAM, ROM, EPROM, EEPROM, flash memory or other solid state memory technology, CD-ROM, DVD, or other optical storage, magnetic cassettes, magnetic tape, magnetic disk storage or other magnetic storage devices. Of course, those skilled in the art will appreciate that computer storage media is not limited to the foregoing. Thesystem memory 904 andmass storage device 907 described above may be collectively referred to as memory.

According to various embodiments of the present application,device 900 may also operate as a remote computer connected to a network through a network, such as the Internet. That is, thedevice 900 may be connected to thenetwork 912 through thenetwork interface unit 911 coupled to thesystem bus 905, or thenetwork interface unit 911 may be used to connect to other types of networks or remote computer systems (not shown).

The memory further includes one or more programs, and the one or more programs are stored in the memory and configured to be executed by the CPU.

In some embodiments, a computer-readable storage medium is also provided, in which a computer program is stored, and the computer program, when executed by a processor, implements the steps of the storage method of video data in the above embodiments. For example, the computer readable storage medium may be a ROM, a RAM, a CD-ROM, a magnetic tape, a floppy disk, an optical data storage device, and the like.

It is noted that the computer-readable storage medium referred to herein may be a non-volatile storage medium, in other words, a non-transitory storage medium.

It should be understood that all or part of the steps for implementing the above embodiments may be implemented by software, hardware, firmware or any combination thereof. When implemented in software, may be implemented in whole or in part in the form of a computer program product. The computer program product includes one or more computer instructions. The computer instructions may be stored in the computer-readable storage medium described above.

That is, in some embodiments, there is also provided a computer program product containing instructions which, when run on a computer, cause the computer to perform the steps of the above-described method for storing video data.

The above-mentioned embodiments are provided not to limit the present application, and any modification, equivalent replacement, improvement, etc. made within the spirit and principle of the present application should be included in the protection scope of the present application.

Claims (14)

1. A method for storing video data is applied to a storage management node in a cloud storage system, wherein the cloud storage system further comprises a plurality of storage nodes, and the method comprises the following steps:

reading an additional recording task, wherein the additional recording task is generated under the condition that it is determined that corresponding monitoring equipment has data storage capacity and video data recorded by the monitoring equipment and stored by a first storage node is missing, or the additional recording task is generated by the first storage node under the condition that the video data recorded by the monitoring equipment cannot be acquired and the monitoring equipment is determined to have the data storage capacity, the additional recording task is a task for storing the missing video data, and the first storage node is one storage node in the plurality of storage nodes;

issuing the additional recording task to a second storage node, wherein the second storage node is one of the plurality of storage nodes; receiving task state information fed back by the second storage node;

if the task state information includes a third time range corresponding to video data which is not stored in the second storage node in the missing video data, updating the missing time range in the supplementary recording task to the third time range, wherein the missing time range refers to the time range corresponding to the missing video data.

2. The method of claim 1, wherein the complementary recording task is generated when it is determined that the corresponding monitoring device has data storage capability and there is a lack of video data recorded by the monitoring device and stored by the first storage node, the method further comprising:

determining storage capacity information of the monitoring equipment, wherein the storage capacity information is used for indicating whether the monitoring equipment has data storage capacity or not;

and if the monitoring equipment is determined to have the data storage capacity based on the storage capacity information and the video data recorded by the monitoring equipment and stored by the first storage node is determined to have the deficiency based on the video plan of the monitoring equipment, generating the additional recording task.

3. The method of claim 2, wherein the video recording schedule includes a first time range, and wherein the determining that there is a lack of video data recorded by the monitoring device stored by the first storage node based on the video recording schedule for the monitoring device comprises:

acquiring storage state information of the video data recorded by the monitoring equipment and stored in the first storage node, wherein the storage state information comprises a second time range of the stored video data recorded by the monitoring equipment;

and determining whether the video data recorded by the monitoring equipment is missing or not according to the first time range and the second time range.

4. The method of claim 3, wherein the generating the complementary task comprises:

determining a missing time range based on the first time range and the second time range, wherein the missing time range refers to a time range corresponding to the missing video data;

and generating the additional recording task based on the missing time range and the equipment identifier of the monitoring equipment.

5. The method of claim 1, wherein the completion task is generated by the first storage node if video data recorded by the monitoring device is unavailable and the monitoring device is determined to have data storage capability, the method further comprising:

and receiving the additional recording task reported by the first storage node.

6. A method for storing video data is applied to a second storage node in a cloud storage system, wherein the second storage node is one of a plurality of storage nodes included in the cloud storage system, the cloud storage system further includes a storage management node, and the method includes:

acquiring an additional recording task, wherein the additional recording task is generated by the storage management node when it is determined that the corresponding monitoring equipment has data storage capacity and video data recorded by the monitoring equipment and stored by a first storage node is missing, or the additional recording task is generated by the first storage node when it is determined that the monitoring equipment cannot acquire the video data recorded by the monitoring equipment and the monitoring equipment has the data storage capacity, and the additional recording task is a task for storing the missing video data;

storing the missing video data based on the supplementary recording task;

the method further comprises the following steps:

and reporting task state information of the additional recording task to the storage management node, wherein the task state information is used for indicating the completion condition of the first storage node on the additional recording task.

7. The method of claim 6, wherein the complementary task comprises a missing time range and a device identification of the monitoring device, the missing time range is a time range corresponding to the missing video data, and the storing the missing video data based on the complementary task comprises:

sending a first request to the monitoring equipment indicated by the equipment identification, wherein the first request comprises the missing time range, and the first request is used for requesting the monitoring equipment to feed back video data recorded in the missing time range;

and receiving and storing the video data fed back by the monitoring equipment.

8. The method of claim 6, wherein the method further comprises:

receiving a video recording plan from the storage management node;

sending a second request to monitoring equipment corresponding to the video plan based on the video plan, wherein the second request is used for requesting the monitoring equipment to feed back storage capacity information;

and receiving and storing the storage capacity information fed back by the monitoring equipment.

9. The method of claim 8, wherein the method further comprises:

and sending the storage capacity information to the storage management node for storage.

10. An apparatus for storing video data, applied to a storage management node in a cloud storage system, the cloud storage system further including a plurality of storage nodes, the apparatus comprising:

the device comprises a reading module and a processing module, wherein the reading module is used for reading an additional recording task, the additional recording task is generated under the condition that the corresponding monitoring equipment has data storage capacity and video data recorded by the monitoring equipment and stored by a first storage node is missing, or the additional recording task is generated by the first storage node under the condition that the video data recorded by the monitoring equipment cannot be acquired and the monitoring equipment has the data storage capacity, the additional recording task is a task for storing the missing video data, and the first storage node is one of the plurality of storage nodes;

the sending module is used for issuing the additional recording task to a second storage node, wherein the second storage node is one of the plurality of storage nodes;

the apparatus also includes means for:

receiving task state information fed back by the second storage node;

if the task state information includes a third time range corresponding to video data which is not stored in the second storage node in the missing video data, updating the missing time range in the supplementary recording task to the third time range, wherein the missing time range refers to the time range corresponding to the missing video data.

11. A video data storage apparatus, applied to a second storage node in a cloud storage system, where the second storage node is one of a plurality of storage nodes included in the cloud storage system, and the cloud storage system further includes a storage management node, the apparatus includes:

an obtaining module, configured to obtain an additional recording task, where the additional recording task is generated by the storage management node when it is determined that the corresponding monitoring device has a data storage capability and video data recorded by the monitoring device and stored by a first storage node is missing, or the additional recording task is generated by the first storage node when it is determined that the monitoring device cannot obtain the video data recorded by the monitoring device and the monitoring device has the data storage capability, and the additional recording task is a task of storing the missing video data;

the storage module is used for storing the missing video data based on the additional recording task;

the device further comprises a module for reporting task state information of the additional recording task to the storage management node, wherein the task state information is used for indicating the completion condition of the first storage node on the additional recording task.

12. A storage management node, comprising a processor, a communication interface, a memory and a communication bus, wherein the processor, the communication interface and the memory communicate with each other via the communication bus, the memory is used for storing computer programs, and the processor is used for executing the programs stored in the memory to realize the steps of the method according to any one of claims 1-5.

13. A storage node, comprising a processor, a communication interface, a memory and a communication bus, wherein the processor, the communication interface and the memory communicate with each other via the communication bus, the memory is used for storing computer programs, and the processor is used for executing the programs stored in the memory to realize the steps of the method according to any one of claims 6-9.

14. A computer-readable storage medium, in which a computer program is stored which, when being executed by a processor, carries out the steps of the method of any one of claims 1 to 5 or carries out the steps of the method of any one of claims 6 to 9.

Images