Load shedding in a data stream management system

摘要

It is presented a method for notifying at least a first condition in an industrial system by means of a monitoring system in order to draw the attention of an operator monitoring the industrial system to the at least one condition. The method comprises displaying (S1) the first condition in a first portion of a display screen of the monitoring system, determining (S2) by means of eye tracking an area where a user focuses on the display screen, the area where the user focuses differing from the first portion, and alerting (S3) the user of the first condition in order to allow the user to be notified of the first condition in the industrial system. A monitoring system is also presented herein.

主权项

1. A data stream processing system, comprising:
a data stream management system (DSMS) comprising:
a data store comprising a first memory arranged to store data items received via an input data stream in a data store; anda first processor comprising:
a continuous query execution circuit configured to execute a continuous query against the received data items to generate an output data stream comprising one or more data items; anda load shedding circuit configured to execute a load shedding process for discarding some of the data items as received by the DSMS or that have been partially processed by the DSMS; a DSMS client comprising a second processor and a second memory, the second processor comprising:
a communication circuit configured to receive and process the one or more data items in the output data stream generated by the DSMS; anda processing circuit configured to execute an action when triggered by the processing of the one or more data items in the output data stream, the action comprising sending a signal, by the DSMS client, to a recipient different from the DSMS client; and a feedback loop arranged to convey a feedback signal to the DSMS notifying the execution of the action by the DSMS client; wherein the DSMS is further configured to determine at least one rule governing the load shedding process on the basis of the received feedback signal and the stored data items.