Systems, methods, apparatus, and computer-readable media for monitoring a data stream
AssigneeMastercard International Incorporated
InventorKenneth L. Long
Life of this patent
Estimating the term…
Abstract
Systems, methods, and apparatus for monitoring flow of data traffic are described. For each of a plurality of transfer units from a data stream (e.g., messages from a message queue), a value of a first field of the transfer unit is mapped to a corresponding counter in random-access memory and the counter is updated. Counter values are periodically copied to a user-accessible region. In one example, message field values are obtained from database log files. In another example, message field values are obtained via an interface called by a database management system.
Claims20
A method of monitoring a data stream, said method comprising:
- providing a data structure in random-access memory, including a plurality of counters, and a user-accessible data structure that is separate from the data structure;
- for each of a plurality of transfer units from the data stream, receiving a first field of the transfer unit;
- for each of the received first fields:
- determining whether a value of the field corresponds to any counter among the plurality of counters based on a predetermined mapping function;
- and
- in response to determining that the value of the field corresponds to a counter among the plurality of counters, incrementing the corresponding counter;
- upon expiration of a fixed interval, and for each of the plurality of counters, copying a current value of the counter to the user-accessible data structure;
- and
- resetting the plurality of counters to an initial value.
An apparatus for monitoring a data stream, said apparatus comprising:
- a log reader configured to obtain, for each of a plurality of transfer units from the data stream, a first field of the transfer unit from a log file;
- a random-access memory configured to store a data structure that includes a plurality of counters;
- a mapping module configured to determine, for each of the received first fields, whether a value of the field corresponds to any counter among the plurality of counters based on a predetermined mapping function and, in response to determining the value of the field corresponds to a counter among the plurality of counters, to increment the corresponding counter;
- an interval timer configured to indicate expiration of a fixed interval;
- a user-accessible data structure that is separate from the data structure;
- and
- a refresh module configured to, upon said expiration indication and for each of the plurality of counters, copy a current value of the counter to the user-accessible data structure and reset the plurality of counters to an initial value.
An apparatus for monitoring a data stream, said apparatus comprising:
- an interface configured to obtain, for each of a plurality of transfer units from the data stream and in response to at least one function call by a calling application, a first field of the transfer unit;
- a random-access memory configured to store a data structure that includes a plurality of counters;
- a mapping module configured to determine, for each of the received first fields, whether a value of the field corresponds to any counter among the plurality of counters based on a predetermined mapping function and, in response to determining the value of the field corresponds to a counter among the plurality of counters, to increment the corresponding counter;
- an interval timer configured to indicate expiration of a fixed interval;
- a user-accessible data structure that is separate from the data structure;
- and
- a refresh module configured to, upon said expiration indication and for each of the plurality of counters, copy a current value of the counter to the user-accessible data structure and reset the plurality of counters to an initial value.
Dependencies are inferred from the claim text.