Distributed data processing system, center server, edge server, mobile terminal, and method

• US 10,412,578 B2
• Filed: 11/24/2017
• Issued: 09/10/2019
• Est. Priority Date: 12/06/2016
• Status: Active Grant

• Current Assignee: Hyundai Motor Company (Hyundai Motor Group), Kia Motors Corporation (Kia Corp.), Toyota Jidosha Kabushiki Kaisha (Toyota Motor Corporation)
• Original Assignee: Toyota Jidosha Kabushiki Kaisha (Toyota Motor Corporation)
• Inventors: Onishi, Ryokichi, Sasahara, Masaaki
• Primary Examiner(s): Afshar, Kamran
• Assistant Examiner(s): Seyedvosoghi, Farid
• Application Number:
  US15/822,032
• Publication Number:
  US 20180160299A1
• Time in Patent Office: 655 Days
• Field of Search: 455419
• CPC Class Codes: H04W 4/40 for vehicles, e.g. vehicle-to-pedestrians [V2P]
• CPC Class Codes: H04W 8/24 Transfer of terminal data

Abstract

An information request describing an attribute of necessary data is distributed from a center server to a mobile terminal via an edge server; the mobile terminal transmits data, which is requested in the information request, to the edge server; the edge server notifies the center server to the effect that the data, which is requested in the information request, has been acquired; the center server distributes, with respect to data acquired by the edge server from the mobile terminal, non-necessity information indicating that collection of the data is unnecessary to the edge server and to the mobile terminal via the edge server; and when the mobile terminal receives the non-necessity information, the mobile terminal suspends acquisition of data, of which collection is deemed unnecessary in the non-necessity information, and, when the data is stored, discards the data.

Claims

1. A distributed data processing system comprising a center server, a plurality of edge servers, and a mobile terminal, and collecting, in the center server, data acquired by the mobile terminal, wherein

the center server is adapted to distribute an information request describing an attribute of at least one piece of necessary data to the mobile terminal via an edge server,

the mobile terminal is adapted to transmit requested data, which is data having the attribute in the information request, to the edge server,

the edge server is adapted to send, in response to receiving the requested data, a notification to the center server without forwarding the requested data to the center server, the notification indicating that the edge server is in possession of the requested data,

the center server is adapted to distribute, in response to receiving the notification from the edge server indicating that the edge server is in possession of the requested data and without having received the requested data, non-necessity information to the edge server and to the mobile terminal via the edge server, the non-necessity information indicating that collection of unnecessary data, which includes at least the requested data, is unnecessary, and

the mobile terminal is adapted to, when the mobile terminal receives the non-necessity information, suspend acquisition of the unnecessary data indicated in the non-necessity information, and to discard the unnecessary data if the unnecessary data is stored in the mobile terminal.

2. The distributed data processing system according to claim 1, wherein after the edge server acquires and integrates a prescribed number of pieces of data having an attribute deemed necessary in the information request, the edge server notifies the center server to the effect that the requested data has been acquired.

3. The distributed data processing system according to claim 2, wherein the center server distributes the information request by including the prescribed number in the information request.

4. The distributed data processing system according to claim 1, wherein after the mobile terminal acquires and integrates a prescribed number of pieces of data having an attribute deemed necessary in the information request, the mobile terminal transmits the integrated data to the edge server.

5. The distributed data processing system according to claim 1, wherein the mobile terminal is adapted to:

determine, in accordance with a prescribed criterion, which mobile terminals, from among the mobile terminal and other mobile terminals, are on the upstream side and on the downstream side respectively,

distribute, to the other mobile terminal on the downstream side, the information request and the non-necessity information distributed from the edge server or the other mobile terminal on the upstream side, and

when the information request is acquired from the other mobile terminal on the upstream side, transmit the requested data to the edge server or the other mobile terminal on the upstream side, and when the non-necessity information is acquired, discard the unnecessary data if the data is stored.

6. The distributed data processing system according to claim 1,

wherein the data is point group data obtained by a laser scanner measurement, and

wherein the information request includes a measurement position of the point group data as an attribute of necessary data.

7. An edge server collecting data from a mobile terminal in accordance with an information request from a center server, the edge server comprising:

an information request receiving unit adapted to receive an information request describing an attribute of at least one piece of necessary data from the center server;

an information request transmitting unit adapted to transmit the information request to the mobile terminal;

an information receiving unit adapted to receive requested data, which is data having the attribute in the information request from the mobile terminal;

a possession notification transmitting unit adapted to send, in response to receiving the requested data, a notification to the center server indicating that the edge server is in possession of the requested data without sending the requested data to the center server;

a non-necessity information receiving unit adapted to receive from the center server non-necessity information sent by the center server in response to the notification indicating that the edge server is in possession of the requested data and without the center server having received the requested data, the non-necessity information indicating that collection of unnecessary data, which includes at least the requested data, is unnecessary; and

a non-necessity information transmitting unit adapted to transmit the non-necessity information to the mobile terminal.

8. A data collection method in a distributed data processing system including a center server, a plurality of edge servers, and a mobile terminal and collecting, in the center server, data acquired by the mobile terminal, the method comprising:

distributing, by the center server, an information request describing an attribute of at least one piece of necessary data to the mobile terminal via an edge server;

transmitting, by the mobile terminal, requested data which is data having the attribute in the information request to the edge server;

notifying, by the edge server and in response to receiving the requested data, the center server that the edge server is in possession of the requested data without forwarding the requested data to the center server;

distributing, by the center server, in response to receiving the notification from the edge server indicating that the edge server is in possession of the requested data and without the center server having received the requested data, non-necessity information to the edge server and to the mobile terminal via the edge server, the non-necessity information indicating that collection of unnecessary data, which includes at least the requested data, is unnecessary; and

in response to receiving the non-necessity information, suspending, by the mobile terminal, acquisition of unnecessary data, of which collection is deemed unnecessary in the non-necessity information, and discard the data if the data is stored.

9. The data collection method according to claim 8, wherein, in the step of notifying, the edge server notifies the center server to the effect that the requested data has been acquired after the edge server acquires and integrates a prescribed number of pieces of data having an attribute deemed necessary in the information request.

10. The data collection method according to claim 9, wherein in the step of distribution of an information request, the center server distributes the information request by including the prescribed number in the information request.

11. The data collection method according to claim 8, wherein the step of transmitting the requested data includes acquiring and integrating a prescribed number of pieces of data having an attribute deemed necessary in the information request, and transmitting the integrated data to the edge server.

12. The data collection method according to claim 8, further comprising:

determining, by the mobile terminal, in accordance with a prescribed criterion, which mobile terminals, from among the mobile terminal and other mobile terminals, are on the upstream side and on the downstream side respectively;

distributing, by the mobile terminal, to the other mobile terminal on the downstream side, the information request and the non-necessity information distributed from the edge server or the other mobile terminal on the upstream side; and

transmitting, by the mobile terminal, when the information request is acquired from the other mobile terminal on the upstream side, requested data which is requested in the information request to the edge server or the other mobile terminal on the upstream side, and when the non-necessity information is acquired, discarding the unnecessary data if the data is stored.

13. The data collection method according to claim 8,

wherein the data is point group data obtained by a laser scanner measurement, and

wherein the information request includes a measurement position of the point group data as an attribute of necessary data.