Data processing device, monitoring method, and program

1. A data processing apparatus comprising:

first processing circuitry configured to execute real-time processing with respect to data that is collected periodically from a device on a production line of a factory;

second processing circuitry configured to execute batch processing aperiodically with respect to data that is output from the first processing circuitry as a result of processing by the first processing circuitry; and

a monitor to monitor a first status of the processing by the first processing circuitry and a second status of processing by the second processing circuitry, wherein

each of the first processing circuitry and the second processing circuitry, includes:

a plurality of subprocessing circuitries configured to execute subprocesses included in the processing executed with respect to data; and

buffers to store data output from the plurality of subprocessing circuitries, each of the buffers storing data output from a corresponding subprocessing circuitry,

the second processing circuitry further includes a storage to store the data output from the first processing circuitry and to provide the stored data to a first subprocessing circuitry of the plurality of subprocessing circuitries included in the second processing circuitry, the first subprocessing circuitry serving as a starting point,

the second processing circuitry, when an amount of data stored in a buffer of the buffers included in the second processing circuitry is equal to or larger than a threshold value, temporarily stops execution of a subprocess by a subprocessing circuitry of the subprocessing circuitries included in the second processing circuitry, the temporary stopping execution of the subprocess by the subprocessing circuitry stopping outputting of data to the buffer, and

the monitor includes:

a first monitor to monitor, for each of the buffers included in the first processing circuitry, an amount of the data stored in the corresponding buffer;

a second monitor to monitor a total amount of (i) the data stored in the buffers included in the second processing circuitry and (ii) the data stored in the storage of the second processing circuitry; and

a determiner to determine, based on a result of the monitoring by the first monitor and the second monitor, whether at least one of the processing by the first processing circuitry or the processing by the second processing circuitry is in a predetermined abnormal state.

2. The data processing apparatus according to claim 1 , wherein the first monitor monitors the amount of the data stored in the storage.

3. The data processing apparatus according to claim 1 , wherein the storage has larger capacity than any of the buffers included in the first processing circuitry and the second processing circuitry.

4. The data processing apparatus according to claim 1 , further comprising:

a notifier to receive a setting relating to notification to a user of a result of the determination by the determiner and to send notification of the result of the determination in accordance with the received setting.

5. The data processing apparatus according to claim 1 , further comprising:

a controller to control, based on a result of the monitoring by the first monitor and the second monitor, at least one of a first operation of the first processing circuitry or a second operation of the second processing circuitry.

6. The data processing apparatus according to claim 1 ,

wherein at least some of the subprocesses of the first processing circuitry overlap in time, and

wherein at least some of the subprocesses of the second processing circuitry overlap in time.

7. The data processing apparatus according to claim 1 , wherein length of time of some or all of the subprocesses per batch processing changes with respect to a prior batch processing and/or a subsequent batch processing.

8. The data processing apparatus according to claim 1 , wherein when the determining determines that the second processing circuitry is in the predetermined abnormal state, a timing of the periodic collection of the data associated with the real-time processing of the first circuitry is increased.

9. A monitoring method comprising:

a. first monitoring step of monitoring amounts of buffering data buffered in a plurality of buffering processes of buffering data output from a plurality of subprocesses included in first processing of executing real-time processing with respect to data that is collected periodically from a device on a production line of a factory, each of the plurality of buffering processes including buffering data output from a corresponding subprocess of the plurality of subprocesses included in the first processing and each of the amounts of the buffering data being monitored for a corresponding buffering process of the plurality of buffering processes;

a second monitoring step of monitoring a total amount of buffering data buffered in a plurality of buffering processes of buffering data output from a plurality of subprocesses included in second processing of executing batch processing aperiodically with respect to data indicating a result of processing in the first processing, each of the plurality of buffering processes including buffering data output from a corresponding subprocess of the plurality of subprocesses included in the second processing;

a stopping step of, when an amount of buffering data buffered in a buffering process of the plurality of buffering processes included in the second processing is equal to or larger than a threshold value, temporarily stopping execution of a subprocess of the plurality of subprocesses included in the second processing, the temporary stopping execution of the subprocess including stopping outputting of data to be buffered in the buffering process; and

a determination step of determining, based on a result of the monitoring in the first monitoring step and the second monitoring step, whether at least one of the processing in the first processing or processing in the second processing is in a predetermined abnormal state.

10. The monitoring method according to claim 9 , further comprising changing length of time of some or all of subprocesses per the aperiodic batch processing with respect to a prior aperiodic batch processing and/or a subsequent aperiodic batch processing.

11. Monitoring method according to claim 9 , wherein, when said determining determines that the at least one of the processing in the first processing or the processing in the second processing is in the predetermined abnormal state, increasing a timing of the periodic collection of the data associated with the real-time processing.

12. A non-transitory computer-readable recording medium storing a program causing a computer to:

monitor amounts of buffering data buffered in a plurality of buffering processes of buffering data output from a plurality of subprocesses included in first processing of executing real-time processing with respect to data that is collected periodically from a device on a production line of a factory, each of the plurality of buffering processes including buffering data output from a corresponding subprocess of the plurality of subprocesses included in the first processing and each of the amounts of the buffering data being monitored for a corresponding buffering process of the plurality of buffering processes;

monitor a total amount of buffering data buffered in a plurality of buffering processes of buffering data output from a plurality of subprocesses included in second processing of executing batch processing aperiodically with respect to data indicating a result of processing in the first processing, each of the plurality of buffering processes including buffering data output from a corresponding subprocess of the plurality of subprocesses included in the second processing;

when an amount of buffering data buffered in a buffering process of the plurality of buffering processes included in the second processing is equal to or larger than a threshold value, temporarily stop execution of a subprocess of the plurality of subprocesses included in the second processing, the temporary stopping execution of the subprocess including stopping outputting of data to be buffered in the buffering process; and

determine, based on (i) a result of the monitoring of the amounts of buffering data buffered in the plurality of buffering processes included in the first processing and (ii) a result of the monitoring of the total amount of buffering data buffered in the plurality of buffering processes included in the second processing, whether at least one of the processing in the first processing or processing in the second processing is in a predetermined abnormal state.

13. The non-transitory computer-readable recording medium according to claim 12 , wherein the program further causing the computer to change length of time of some or all of subprocesses per the aperiodic batch processing with respect to a prior aperiodic batch processing and/or a subsequent aperiodic batch processing.

14. The non-transitory computer-readable recording medium according to claim 12 , wherein the program further causing the computer to when said determining determines that the at least one of the processing in the first processing or the processing in the second processing is in the predetermined abnormal state, increasing a timing of the periodic collection of the data associated with the real-time processing.