Techniques for filtering data from a data stream of a web services application
First Claim
1. A method for filtering data from a data stream of a web services application comprising:
- receiving a message;
evaluating, using data from the message, a current set of one or more rules producing a current set of evaluated rules; and
collecting data associated with the message in accordance with the current set of evaluated rules.
1 Assignment
0 Petitions
Accused Products
Abstract
Described are techniques used with application monitoring in connection with performing Web Services. Associated with each application performing a service are one or more application servers and associated stream sensors. The stream sensors filter received XML messages in accordance with a set of rules to gather data. The filtered data is gathered at each point and then may be aggregated locally for each transaction by an aggregation service. Data may be gathered from each aggregation service by a global aggregator. Rules are specified initially and may be revised during runtime while gathering data. Rules are evaluated at runtime in accordance with the data stream.
-
Citations
88 Claims
-
1. A method for filtering data from a data stream of a web services application comprising:
-
receiving a message;
evaluating, using data from the message, a current set of one or more rules producing a current set of evaluated rules; and
collecting data associated with the message in accordance with the current set of evaluated rules. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15, 16, 17, 18, 19, 20, 21, 22, 23, 24, 25, 26, 27, 28, 29, 30, 31, 32, 33, 34, 35, 36, 37, 38)
-
-
39. A system for filtering data comprising:
-
at least one application providing a service;
at least one application server and stream sensor associated with each of said at least one application, said stream sensor filtering a data stream of said at least one application in accordance with a dynamically evaluated current set of rules producing filtered data, said current set of rules being dynamically evaluated with each received message; and
a context engine associated with each of said at least one application, said context engine including an aggregation service that aggregates said filtered data for said application in accordance with at least one local aggregation condition. - View Dependent Claims (40, 41, 42)
-
-
43. A method for capturing data from a data stream of an application comprising:
-
receiving a first message from said data stream of said application;
storing first context information including a copy of a first set of one or more rules, said first context information describing a processing state of said first message used during a first processing lifetime of said first message, said first set of one or more rules used in obtaining first data related to said first message, said first set of one or more rules being said current set of rules;
defining a second set of one or more rules at runtime of said application while said application is servicing a request such that any subsequently received messages are processed in accordance with said second set of one or more rules, said second set of one or more rules replacing said first set of one or more rules as said current set;
receiving a second message from said data stream during said first processing lifetime of said first message; and
storing second context information including a copy of said second set of one or more rules, said second context information describing a processing state of said second message used during a second processing lifetime of said second message, said second set of rules used in obtaining second data related to said second message, said first processing lifetime and said second processing lifetime overlapping for at least a portion of both lifetimes such that said first and second messages are concurrently processed. - View Dependent Claims (44, 45, 46)
-
-
47. A computer program product for filtering data from a data stream of a web services application comprising:
-
executable code that receives a message;
executable code that evaluates, using data from the message, a current set of one or more rules producing a current set of evaluated rules; and
executable code that collects data associated with the message in accordance with the current set of evaluated rules. - View Dependent Claims (48, 49, 50, 51, 52, 53, 54, 55, 56, 57, 58, 59, 60, 61, 62, 63, 64, 65, 66, 67, 68, 69, 70, 71, 72, 73, 74, 75, 76, 77, 78, 79, 80, 81, 82, 83, 84)
-
-
85. A computer program product for capturing data from a data stream of an application comprising:
-
executable code that receives a first message from said data stream of said application;
executable code that stores first context information including a copy of a first set of one or more rules, said first context information describing a processing state of said first message used during a first processing lifetime of said first message, said first set of one or more rules used in obtaining first data related to said first message, said first set of one or more rules being said current set of rules;
executable code that defines a second set of one or more rules at runtime of said application while said application is servicing a request such that any subsequently received messages are processed in accordance with said second set of one or more rules, said second set of one or more rules replacing said first set of one or more rules as said current set;
executable code that receives a second message from said data stream during said first processing lifetime of said first message; and
executable code that stores second context information including a copy of said second set of one or more rules, said second context information describing a processing state of said second message used during a second processing lifetime of said second message, said second set of rules used in obtaining second data related to said second message, said first processing lifetime and said second processing lifetime overlapping for at least a portion of both lifetimes such that said first and second messages are concurrently processed. - View Dependent Claims (86, 87, 88)
-
Specification