Information processing system with circuitry to sequentially process received data
There is provided an information processing system capable of suppressing arising of unprocessed data and depreciation of data with the lapse of time. The information processing system ( 1 ) includes a buffer unit ( 5 ), a processing unit ( 6 ), and a control unit ( 9 ). The buffer unit ( 5 ) sequentially receives data acquired by an observation terminal ( 2 ) from the observation terminal ( 2 ). The processing unit ( 6 ) sequentially processes the data received by the buffer unit ( 5 ). The control unit ( 9 ) controls an index value indicating information freshness by adjusting a resource of processing of the processing unit ( 6 ). The index value indicating the information freshness is calculated based on elapsed time from the time when the data is acquired by the observation terminal ( 2 ).
1. An information processing system comprising:
circuitry
to sequentially receive data acquired by an observation terminal from the observation terminal;
to sequentially process the received data; and
to control an index value indicating information freshness by adjusting a resource for processing the received data, the index value being calculated based on elapsed time from a time when the data is acquired by the observation terminal, wherein
the circuitry calculates an acquisition rate of the data by the observation terminal and a service rate of the processing, and
the circuitry controls the service rate by adjusting the resource for the processing the received data so that, when a relation between a utilization rate for which the acquisition rate is divided by the service rate and the index value is predetermined by a queueing model, the utilization rate obtained from the acquisition rate and the calculated service rate becomes a utilization rate corresponding to a target value of the index value predetermined based on the acquisition rate and the queueing model.
2. The information processing system according to claim 1 , wherein:
the circuitry calculates the index value based on the elapsed time; and
the circuitry adjusts the resource for processing the received data so as to increase the information freshness indicated by the calculated index value.
3. The information processing system according to claim 1 , wherein:
the circuitry calculates the index value based on the elapsed time; and
the circuitry adjusts the resource for the processing the received data so that the calculated index value becomes a predetermined target value.
4. The information processing system according to claim 1 , wherein the circuitry calculates a time average of the elapsed time value in a steady state as the index value.
5. The information processing system according to claim 1 , wherein the resource for processing the received data includes at least one of a selection of a processing circuit from a plurality of processing circuits having different processing performance, a clock frequency of a processing circuit, and a number of cores in the processing circuit to perform the processing.
6. The information processing system according to claim 1 , wherein the circuitry to control the index value is configured to adjust the resource for processing the received data by Proportional-Integral-Differential (PID) control.
7. The information processing system according to claim 1 , wherein the circuitry to control the index value is configured to adjust the resource for processing the received data based on a reinforcement learning, wherein a reward of the reinforcement learning is calculated based on a value of a service rate of the processing.
8. An information processing method comprising:
sequentially receiving data acquired by an observation terminal from the observation terminal;
sequentially processing the received data;
calculating an index value indicating information freshness, the calculating being performed based on relapsed time from a time when the data is acquired by the observation terminal;
controlling the index value by adjusting a resource for processing the received data;
calculating an acquisition rate of the data by the observation terminal and a service rate of the processing; and
controlling the service rate by adjusting the resource for processing the received data so that, when a relation between a utilization rate for which the acquisition rate is divided by the service rate and the index value is predetermined by a queueing model, the utilization rate obtained from the acquisition rate and the calculated service rate becomes a utilization rate corresponding to a target value of the index value predetermined based on the acquisition rate and the queueing model.