System, method, computer-readable medium and apparatus

• US 9,641,600 B2
• Filed: 05/16/2014
• Issued: 05/02/2017
• Est. Priority Date: 05/24/2013
• Status: Expired due to Fees

• Current Assignee: Fujitsu Limited
• Original Assignee: Fujitsu Limited
• Inventors: Nakatsugawa, Keiichi, Kano, Shinya
• Primary Examiner(s): Nguyen, Dustin
• Assistant Examiner(s): Turriate Gastulo, Juan C
• Application Number:
  US14/279,703
• Publication Number:
  US 20140351311A1
• Time in Patent Office: 1,082 Days
• 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/566 Grouping or aggregating service requests, e.g. for unified processing
• CPC Class Codes: H04L 67/62 Establishing a time schedule for servicing the requests
• CPC Class Codes: H04L 69/28 Timers or timing mechanisms used in protocols

Abstract

A system includes a terminal apparatus configured to generate pieces of data, each of the pieces of data including time information indicating when each of the pieces of data is generated; a destination apparatus configured to accumulate the pieces of data; a relay apparatus configured to store the pieces of data transmitted from the terminal apparatus based on the time information and to relay the pieces of data to the destination apparatus; and a processing apparatus configured to acquire the pieces of data that are stored in the relay apparatus and to process the pieces of data, wherein the relay apparatus is configured to store an amount of the pieces of data in the relay apparatus based on the time information, the amount corresponding to an amount of data that the processing apparatus processes based on a time range of the pieces of data.

Claims

1. A system comprising:

a terminal apparatus connected to a network and including a first processor configured to transmit data via the network in a first time interval, the data including time information indicating when the data is generated and a terminal identification of the terminal apparatus;

a first relay apparatus connected to the network and including a first storage and a second processor;

a second relay apparatus connected to the network;

a destination apparatus connected to the network; and

a first processing apparatus connected to the network and including a third processor,

wherein the second processor of the first relay apparatus is configured to;

receive the data from the terminal apparatus in the first time interval;

identify a rule relating to the terminal identification included in the data, the rule including the terminal identification and an accumulation period of the data in the first storage;

calculate an accumulation end time of the data based on the accumulation period and the time information included in the data;

store, into the first storage, the data at or before the accumulation end time;

in response to a request for the data, transmit the data acquired from the first storage to a source of the request for the data;

relay the data to at least one of the second relay apparatus and the destination apparatus which accumulates the data after the accumulation end time; and

delete the data from the first storage after the data is relayed,

wherein the third processor of the first processing apparatus is configured to;

transmit the request for the data to the first relay apparatus in a second time interval; and

acquire the data from the first relay apparatus,

wherein the accumulation period is set based on the second time interval, and

wherein the first time interval is equal to or shorter than the second time interval.

2. The system of claim 1, wherein

the terminal apparatus is a sensor configured to monitor information relating to a service and to generate the data based on the information monitored.

3. The system of claim 2, wherein

the sensor is set up at a sales position relating to the service.

4. The system of claim 2, wherein

the destination apparatus is included in a data center being configured to manage the service based on the data.

5. The system of claim 2, wherein

the first processing apparatus is configured to do an activity relating to a delivery of a product of the service based on the data.

6. The system of claim 1 wherein the second relay apparatus includes a second storage and a fourth processor configured to:

store, into the second storage, the data relayed from the first relay apparatus on or before another accumulation end time, the another accumulation end time being calculated based on another rule and the time information, the another rule including the terminal identification and another accumulation period;

in response to another request for the data, transmit the data acquired from the second storage to a source of the another request relay the pieces of data to the destination apparatus after the another accumulation end time; and

delete the data from the second storage after the data is relayed,

further comprising a second processing apparatus configured to;

transmit the another request to the second relay apparatus in a third time interval; and

acquire the data from the second relay apparatus,

wherein the another accumulation period is set based on the third time interval in which the second processing apparatus transmits the another request, and

wherein the second time interval is equal to or shorter than the third time interval.

7. The system of claim 6, wherein

the terminal apparatus is a sensor configured to monitor information relating to a service and to generate the pieces of data based on the information,

the second processing apparatus is configured to perform an activity relating to a manufacturing of a product of the service based on the pieces of data.

8. The system of claim 6, wherein

a capacity of the first storage is equal to or smaller than a capacity of the second storage.

9. The system of claim 6, wherein

the second relay apparatus is configured to request data that is included in the third time interval but is not stored in the second relay apparatus to the first relay apparatus.

10. The system of claim 8, wherein

the first relay apparatus is configured to transmit the data to the second relay apparatus after the first processing apparatus acquires the data.

11. The system of claim 7, wherein

the destination apparatus is configured to process the accumulated data during a time range equal to or longer than the accumulation period and another accumulation period.

12. The system of claim 1, wherein

the first relay apparatus is configured to copy the stored data and to relay the copied data to the destination apparatus.

13. The system of claim 1, wherein

the first relay apparatus is configured to store the data in the first relay apparatus based on the time information by delaying the relaying of the data to the destination apparatus.

14. A method comprising:

receiving data, from a terminal apparatus in a first time interval, the data including time information indicating when the data is generated and a terminal identification of the terminal apparatus;

identifying a rule relating to the terminal identification included in the data, the rule including the terminal identification and an accumulation period of the data in a first storage;

calculating an accumulation end time of the data based on the accumulation period and the time information included in the data;

storing, into the first storage, the data at or before the accumulation end time;

receiving a request for the data from a processing apparatus during a second time interval;

in response to the request for the data, transmitting the data acquired from the first storage to a source of the request for the data;

relaying the data to at least one of a relay apparatus and a destination apparatus which accumulates the data after the accumulation end time; and

deleting the data from the first storage after the data is relayed,

wherein the accumulation period is set based on the second time interval, and

wherein the first time interval is equal to or shorter than the second time interval.

15. A non-transitory computer-readable medium including a program, which when executed by a system, causes the system to:

receive data, from a terminal apparatus in a first time interval, the data including time information indicating when the data is generated and a terminal identification of the terminal apparatus;

identify a rule relating to the terminal identification included in the data, the rule including the terminal identification and an accumulation period of the data in a first storage;

calculate an accumulation end time of the data based on the accumulation period and the time information included in the data;

store, into the first storage, the data at or before the accumulation end time;

receive a request for the data from a processing apparatus during a second time interval;

in response to the request for the data, transmit the data acquired from the first storage to a source of the request for the data;

relay the data to at least one of a relay apparatus and a destination apparatus which accumulates the data after the accumulation end time; and

delete the data from the first storage after the data is relayed,

wherein the accumulation period is set based on the second time interval, and

wherein the first time interval is equal to or shorter than the second time interval.

16. An apparatus comprising;

a memory; and

a processor coupled to the memory and configured to;

receive data transmitted from a terminal apparatus in a first time interval, the data including time information indicating the data is generated and a terminal identification of the terminal apparatus;

identify a rule relating to the terminal identification included in the data, the rule including the terminal identification and an accumulation period of the data in a first storage;

calculate an accumulation end time of the data based on the accumulation period and the time information included in the data;

store, into the first storage, the data at or before the accumulation end time;

receive a request for the data from a processing apparatus during a second time interval;

in response to the request for the data, transmit the data acquired from the first storage to a source of the request for the data;

relay the data to at least one of a relay apparatus and a destination apparatus which accumulates the data after the accumulation end time; and

delete the data from the first storage after the data is relayed,

wherein the accumulation period is set based on the second time interval, and

wherein the first time interval is equal to or shorter than the second time interval.