Data distribution storing method and system thereof

• US 10,379,965 B2
• Filed: 10/11/2016
• Issued: 08/13/2019
• Est. Priority Date: 09/28/2016
• Status: Active Grant

• Current Assignee: Hanwha Vision Company Limited (Hanwha Corporation)
• Original Assignee: Hanwha Techwin Co., Ltd. (Hanwha Corporation)
• Inventors: Jujjuru, Durga Prasad, Kim, Joon Young, Hong, Sek Rai, Kim, Eun Min
• Primary Examiner(s): Padmanabhan, Mano
• Assistant Examiner(s): Cheong, Andrew J
• Application Number:
  US15/741,681
• Publication Number:
  US 20190079832A1
• Time in Patent Office: 1,036 Days
• CPC Class Codes: G06F 11/14 Error detection or correction of the data by redundancy in operation G06F11/16 takes precedence
• CPC Class Codes: G06F 11/1446 Point-in-time backing up or restoration of persistent data
• CPC Class Codes: G06F 11/1464 for networked environments
• CPC Class Codes: G06F 16/00 Information retrieval; Database structures therefor; File system structures therefor
• CPC Class Codes: G06F 16/2228 Indexing structures
• CPC Class Codes: G06F 16/24578 using ranking
• CPC Class Codes: G07C 5/008 communicating information to a remotely located station transmission systems for measured values G08C
• CPC Class Codes: G08G 1/0112 from the vehicle, e.g. floating car data [FCD]
• CPC Class Codes: G08G 1/123 indicating the position of vehicles, e.g. scheduled vehicles; Managing passenger vehicles circulating according to a fixed timetable, e.g. buses, trains, tramstransmission of navigation instructions to vehicles G08G1/0968
• CPC Class Codes: H04L 67/10 in which an application is distributed across nodes in the network software deployment G06F8/60; multiprogramming arrangements G06F9/46
• CPC Class Codes: H04L 67/1097 for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS]
• CPC Class Codes: H04L 67/12 specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
• CPC Class Codes: H04N 21/222 Secondary servers, e.g. proxy server, cable television Head-end provisioning of proxy services in data packet switching networks H04L67/56
• CPC Class Codes: H04N 21/23109 by placing content in organized collections, e.g. EPG data repository details of retrieval of video data and associated meta data in video databases G06F16/739
• CPC Class Codes: H04N 7/18 Closed-circuit television [CCTV] systems, i.e. systems in which the video signal is not broadcast
• CPC Class Codes: H04N 7/183 for receiving images from a single remote source

Abstract

There is provided a data distribution storing method including: recognizing, by a cluster manager managing a cluster of a plurality of nodes, a vehicle storage installed in a vehicle; transmitting, by the cluster manager, a vehicle index request including identification information about the vehicle storage to an index server; receiving, by the cluster manager, a first vehicle index including information about a first time section during which first vehicle data is recorded in the vehicle storage from the index server; selecting, by the cluster manager, a node from the cluster; transmitting, by the vehicle storage, second vehicle data recorded in the vehicle storage during a second time section which is after the first time section, to the node; generating, by the cluster manager, a second vehicle index based on the first vehicle index and information about the second time section and the node.

Claims

1. A data distribution storing method comprising:

recognizing, by a cluster manager managing a cluster comprising a plurality of nodes, a vehicle storage installed in a vehicle;

transmitting, by the cluster manager, a vehicle index request comprising identification information about the vehicle storage to an index server;

receiving, by the cluster manager, a first vehicle index corresponding to the vehicle index request from the index server, the first vehicle index comprising information about first vehicle data recorded in the vehicle storage;

selecting, by the cluster manager, a node from among the nodes of the cluster;

transmitting, by the cluster manager, a backup request comprising the identification information about the vehicle storage to the node;

transmitting, by the vehicle storage, second vehicle data recorded in the vehicle storage to the node for storing therein;

receiving, by the cluster manager, a backup response corresponding to the backup request from the node;

generating, by the cluster manager, a second vehicle index based on the first vehicle index and the backup response, the second vehicle index comprising information about the second vehicle data; and

transmitting, by the cluster manager, the second vehicle index to the index server,

wherein the information about the first vehicle data included in the first vehicle index comprises a first recording time section during which the first vehicle data is recorded in the vehicle storage.

2. The method of claim 1, wherein the backup request further comprises a second recording time section during which the second vehicle data is recorded in the vehicle storage, wherein a start time point of the second recording time section is the same as or after a finish time point of the first recording time section.

3. The method of claim 2, further comprising:

transmitting, by the node, a vehicle data request to the vehicle storage, the vehicle data request comprising at least one of the start time point of the second recording time section and identification information about the node; and

receiving, by the node, the second vehicle data recorded in the second recording time section from the vehicle storage.

4. The method of claim 2, wherein the backup response comprises at least one of the second recording time section and identification information about the node.

5. The method of claim 4, wherein the second vehicle index comprises at least one of the identification information about the vehicle storage, the second recording time section, and the identification information about the node.

6. The method of claim 1, further comprising determining, by the cluster manager, ranking of the nodes included in the cluster,

wherein the selecting the node, the transmitting the backup request, and the receiving the backup response, performed by the cluster manager, comprises;

selecting a higher ranking node from among the nodes;

transmitting the backup request to the higher ranking node; and

in response to not receiving the backup response from the higher ranking node, selecting a lower ranking node from among the nodes.

7. The method of claim 1, wherein the recognizing the vehicle storage, performed by the cluster manager, comprises receiving, from the vehicle storage, at least one of identification information about the vehicle, the identification information about the vehicle storage, global positioning system (GPS) information about the vehicle, a data parameter regarding the second vehicle data, and

wherein the method further comprises:

determining, by the cluster manager, whether the second vehicle data is important data based on at least one of the identification information about the vehicle, the identification information about the vehicle storage, the GPS information about the vehicle, and the data parameter; and

in response to determining that the second vehicle data is important data, selecting, by the cluster manager, an external server different from the cluster, transmitting, by the cluster manager, the backup request to the external server, transmitting, by the vehicle storage, the second vehicle data to the external server, and receiving, by the cluster manager, the backup response from the external server.

8. The method of claim 1, further comprising:

recognizing, by the vehicle storage, a mobile storage;

receiving, by the vehicle storage, mobile data from the mobile storage; and

generating, by the vehicle storage, an initial mobile index corresponding to identification information about the mobile storage,

wherein the method further comprises;

receiving, by the cluster manager, the identification information about the mobile storage and the initial mobile index;

transmitting, by the cluster manager, a mobile backup request comprising the identification information about the mobile storage to the node;

transmitting, by the vehicle storage, the mobile data to the node;

receiving, by the cluster manager, a mobile backup response comprising identification information about the node from the node;

generating, by the cluster manager, a final mobile index based on the initial mobile index and the mobile backup response, the final mobile index comprising at least one of the identification information about the mobile storage and the identification information about the node in which the mobile data are stored; and

transmitting the final mobile index to the index server.

9. The method of claim 1, further comprising:

receiving, by the index server, from a client device, a data request comprising the identification information about the vehicle storage, a recording time of the vehicle storage, and identification information about the client device;

retrieving, by the index server, the first or the second vehicle index corresponding to the identification information about the vehicle storage and the recording time;

extracting, by the index server, identification information about the node included in the first or the second vehicle index;

transmitting, by the index server, the data request to the node; and

transmitting, by the node, the first or the second vehicle data corresponding to the identification information about the vehicle storage and the recording time to the client device.

10. A data distribution storing system comprising a cluster manager which comprises:

a sensor configured to recognize a vehicle storage installed in a vehicle;

a cluster communication interface, under control of a cluster processor, configured to;

transmit a vehicle index request to an index server;

receive a first vehicle index corresponding to the vehicle index request from the index server, the first vehicle index comprising information about first vehicle data recorded in the vehicle storage;

transmit a backup request to a node, included in a cluster comprising a plurality of nodes;

receive a backup response corresponding to the backup request from the node;

transmit second vehicle data recorded in the vehicle storage to the node; and

transmit a second vehicle index to the index server, the second vehicle index comprising information about the second vehicle data; and

the cluster processor configured to;

generate the vehicle index request comprising identification information about the vehicle storage in response to the sensor recognizing the vehicle storage;

select the node from among the nodes in the cluster to transmit the backup request and the second vehicle data to the node;

generate the backup request comprising the identification information about the vehicle storage; and

generate the second vehicle index based on the first vehicle index and the backup response,

wherein the information about the first vehicle data included in the first vehicle index comprises a first recording time section during which the first vehicle data is recorded in the vehicle storage.

11. The system of claim 10, wherein the backup request further comprises identification information about the node and a second recording time section during which the second vehicle data is recorded in the vehicle storage,

wherein a start time point of the second recording time section is the same as or after a finish time point of the first recording time section, and

wherein the second vehicle index comprises at least one of the identification information about the vehicle storage, the second recording time section, and the identification information about the node.

12. The system of claim 10, wherein the sensor receives, from the vehicle storage, at least one of identification information about the vehicle, the identification information about the vehicle storage, global positioning system (GPS) information about the vehicle, a data parameter regarding the second vehicle data, and

wherein the cluster processor determines whether the second vehicle data is important data based on at least one of the identification information about the vehicle, the identification information about the vehicle storage, the GPS information about the vehicle, and the data parameter, and

wherein, in response to determining the second vehicle data is the important data, the cluster processor selects an external server different from the cluster instead of the node, controls the cluster communication interface to transmit the backup request to the external server instead of the node, and receives the backup response from the external server, instead of the node, through the cluster communication interface.

13. The system of claim 10, wherein the cluster communication interface receives identification information about a mobile storage related to the vehicle, and an initial mobile index related to mobile data stored in the mobile storage, transmits a mobile backup request comprising the identification information about the mobile storage to the node, transmits the mobile data to the node, receives a mobile backup response comprising identification information about the node from the node, and transmits a final mobile index to the index server, and

wherein the cluster processor generates the final mobile index corresponding to the identification information about the mobile storage based on the initial mobile index and the mobile backup response.

14. The system of claim 10, further comprising the index server, wherein the index server comprises:

an index communication interface, under control of an index processor, configured to;

receive, from the cluster manager, the vehicle index request;

transmit, to the cluster manager, the first vehicle index and receive the second vehicle index from the cluster manager;

a database configured to store the first vehicle index and the second vehicle index corresponding to the identification information about the vehicle storage; and

the index processor configured to;

retrieve, from the database, the first vehicle index in response to receiving the vehicle index request; and

update a most recent vehicle index corresponding to the identification information about the vehicle storage stored in the database based on the second vehicle index.

15. The system of claim 14, wherein the index communication interface receives, from the cluster manager, a final mobile index,

wherein the database stores the final mobile index, and

wherein the index processor updates the final mobile index in the database.

16. The system of claim 14, wherein the index communication interface receives a data request from a client device, and transmits the data request to the node, the data request comprising the identification information about the vehicle storage, a recording time of the vehicle storage, and identification information about the client device, and

wherein the index processor retrieves, from the database, the first or the second vehicle index corresponding to the identification information about the vehicle storage and the recording time in response to receiving the data request, extracts the identification information about the node included in the first or the second vehicle index, and controls the index communication interface to transmit the data request to the node.

17. A data distribution storing method comprising:

recognizing, by a cluster manager managing a cluster comprising a plurality of nodes, at least one of a vehicle and a vehicle storage installed in the vehicle;

transmitting, by the cluster manager, a vehicle index request, comprising identification information about at least one of the vehicle and the vehicle storage, to an index server;

receiving, by the cluster manager, a first vehicle index comprising information about a first time section during which first vehicle data is recorded in the vehicle storage from the index server, in response to the vehicle index request;

selecting, by the cluster manager, a node from among the nodes of the cluster;

transmitting, by the cluster manager, second vehicle data recorded in the vehicle storage during a second time section which is after the first time section, to the node;

storing, by the node, the second vehicle data; and

generating, by the cluster manager, a second vehicle index based on the first vehicle index and information about the second time section and the node,

wherein the first time section is the most recent time section during which the first vehicle data is recorded in the vehicle storage prior to the second time section.

18. The data distribution storing method of claim 17, wherein a start time point of the second time section is the same as or after a final time point of the first time section.

19. The data distribution storing method of claim 17, further comprising:

transmitting, by the cluster manager, the second vehicle index to the index server; and

storing, by the index server, the second vehicle index at the index server.