Data processing device, monitoring method, and program

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 subprocess including 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.

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 subprocess including 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.