Data Cloud Storage System, Client Terminal, Storage Server and Application Method

Patent metadata

Field	Value
Publication number	US-2018359331-A1
Application number	US-201615781312-A
Country	US
Kind code	A1
Filing date	Aug 23, 2016
Priority date	Dec 3, 2015
Publication date	Dec 13, 2018
Grant date	—

Abstract

A data cloud storage system, client terminal, storage server and application method, wherein the data storage method includes: sending a storage server query request to a scheduling management service center; receiving and caching first address information when the scheduling management service center is under normal operation, and selecting first address information from the cached first address information; sending a resource request to a storage server corresponding to the first address information; such that the storage server allocates a storage unit for the target data and generates storage resource information; sending a data storage request to the storage server, such that the storage server generates data index information based on attribute information of the target data, and storing the target data in the storage unit allocated to the target data. The embodiments of the present application can guarantee data storage, query and downloading in the event of a failure of the scheduling management service center. Thus, the sensitivity of the data cloud storage system to the failure of the scheduling management service center is reduced.

First claim

1 . A data storage method, wherein it is applied in a client terminal in a data cloud storage system comprising a scheduling management service center, a plurality of storage servers and a plurality of client terminals, wherein the client terminals are communicatively connected with the scheduling management service center, the client terminals are communicatively connected with the plurality of storage servers, and the scheduling management service center is communicatively connected with the plurality of storage servers, the method comprising:
sending a storage server query request containing an identifier of target data to the scheduling management service center; when the scheduling management service center is under normal operation, receiving first address information of a storage server for storing the target data sent by the scheduling management service center, and caching the identifier of the target data and the corresponding first address information; when the scheduling management service center is under abnormal operation, selecting the first address information of the storage server for storing the target data from the cached first address information; sending a resource request to the storage server corresponding to the first address information, such that the storage server generates data index information and storage resource information for the target data based on the resource request and feeds a resource request response back to the client terminal, wherein the storage resource information contains the identifier of the target data and second address information of a storage unit for storing the target data; upon receipt of the resource request response fed back by the storage server, sending a data storage request containing the target data to be stored to the storage server corresponding to the first address information, such that the storage server stores the target data in the storage unit corresponding to the second address information based on the storage resource information of the target data.

2 . The data storage method of claim 1 , wherein
when receiving failure information of the scheduling management service center sent by the scheduling management service center after sending the storage server query request containing the identifier of the target data to the scheduling management service center, or when detecting an abnormality in the network connection with the scheduling management service center, determining that the scheduling management service center is under abnormal operation.

3 . A data access method, wherein it is applied in a client terminal in a data cloud storage system comprising a scheduling management service center, a plurality of storage servers and a plurality of client terminals, wherein the client terminals are communicatively connected with the scheduling management service center, the client terminals are communicatively connected with the plurality of storage servers, and the scheduling management service center is communicatively connected with the plurality of storage servers, the method comprising:
sending a storage server query request containing an identifier of target data to the scheduling management service center; when the scheduling management service center is under normal operation, receiving first address information of a storage server for storing the target data sent by the scheduling management service center, and caching the identifier of the target data and the corresponding first address information; when the scheduling management service center is under abnormal operation, searching for the cached first address information corresponding to the target data based on the identifier of the target data; sending a data query request containing the identifier of the target data to the storage server corresponding to the first address information, such that the storage server searches for storage resource information generated during the storage of the target data based on the identifier of the target data, wherein the storage resource information contains the identifier of the target data and second address information of a storage unit for storing the target data, and returning the second address information to the client terminal.

4 . The method of claim 3 , wherein it further comprises:
sending a data download request, containing the identifier of the target data and the second address information, to the storage server corresponding to the first address information, such that the storage server searches for data index information generated during the storage of the target data based on the identifier of the target data; obtaining the target data from the storage unit storing the target data based on the found data index information and the second address information, and returning the target data to the client terminal.

5 . A data storage method, wherein it is applied in a storage server in a data cloud storage system comprising a scheduling management service center, a plurality of storage servers and a plurality of client terminals, wherein the storage servers are communicatively connected with the scheduling management service center, the storage servers are communicatively connected with the client terminals, and the client terminals are communicatively connected with the scheduling management service center, the method comprising:
receiving a resource request containing an identifier of target data, sent by a client terminal; allocating a storage unit for the target data and generating storage resource information for the target data based on the resource request, wherein the storage resource information contains the identifier of the target data and second address information of the storage unit for storing the target data; feeding a resource request response back to the client terminal, such that upon receipt of the resource request response, the client terminal sends a data storage request containing the target data to be stored to the storage server corresponding to first address information; generating data index information for the target data based on attribute information of the target data; storing the target data in the storage unit corresponding to the second address information based on the storage resource information of the target data.

6 . The method of claim 5 , wherein the target data comprise video stream data or video file data, wherein when the target data are video stream data of a surveillance system, the identifier of the target data is the unique ID of a video encoder that encodes the video stream data;
the generated storage resource information for the target data at least comprises the correspondence between the unique ID of the video encoder and the storage unit for storing the video stream data in the storage server corresponding to the first address information; the generated data index information for the target data at least comprises the correspondence between the unique ID of the video encoder and the point in time of a key video frame in the video stream data; storing the target data in the storage unit allocated for the target data based on the storage resource information of the target data, comprises: obtaining the unique ID of the video encoder corresponding to the video stream data contained in the resource request sent by the client terminal; determining the storage unit for storing the video stream data based on the correspondence between the unique ID of the video encoder and the storage unit in the storage server corresponding to the first address information; storing the target data in the determined storage unit in the storage server.

7 . (canceled)

8 . The method of claim 5 , wherein the method comprises: sending the storage re

Assignees

• Hangzhou Hikvision Digital Tec

Inventors

• Jin Shengpeng
• Lin Qiqian
• Wang Weichun
• Xiong Yinmei

Classifications

• H04L69/40

  for recovering from a failure of a protocol instance or entity, e.g. service redundancy protocols, protocol state redundancy or protocol service redirection (management of faults, events, alarms or notifications in data switching networks H04L41/06) · CPC title

• G06F3/067

  Distributed or networked storage systems, e.g. storage area networks [SAN], network attached storage [NAS] · CPC title

• G06F3/0656

  Data buffering arrangements · CPC title

• G06F3/0619

  in relation to data integrity, e.g. data losses, bit errors · CPC title

• G06F9/5027

  the resource being a machine, e.g. CPUs, Servers, Terminals · CPC title