Metrics processing service
First Claim
Patent Images
1. A system comprising:
- one or more computing nodes operable as a service, the service generating a plurality of log entries during operation; and
one or more memories having stored thereon computer-readable instructions that, upon execution by a computing device, cause the system at least to;
identify, based on a topology of aggregation modules, a first aggregation module corresponding to a first level of the topology;
identify, based on the topology, a second aggregation module corresponding to a second level of the topology;
provide a first value to the first aggregation module, the first value corresponding to an entry in the plurality of log entries;
provide a second value to the second aggregation module, the second value obtained based at least in part on output of the first aggregation module using the first value and one or more additional values corresponding to entries in the plurality of log entries;
obtain a third value based at least in part on output of the second aggregation module using the second value and one or more additional values corresponding to output of the first aggregation module;
store information indicative of a location of the entry in the plurality of log entries for retrieval by a client process to provide a real-time view of the operation of the service.
1 Assignment
0 Petitions
Accused Products
Abstract
A distributed services platform may generate a plurality of log files containing metric values. Metric values may be provided to a first level of a topology of aggregation modules. The first level of aggregation modules may provide output to a second level of the topology. Subsequent levels of the topology may perform greater amounts of aggregation while providing stream-based access to the aggregated values. State information for the aggregation topology may be saved subsequent to each cycle of values through the topology.
19 Citations
20 Claims
-
1. A system comprising:
-
one or more computing nodes operable as a service, the service generating a plurality of log entries during operation; and one or more memories having stored thereon computer-readable instructions that, upon execution by a computing device, cause the system at least to; identify, based on a topology of aggregation modules, a first aggregation module corresponding to a first level of the topology; identify, based on the topology, a second aggregation module corresponding to a second level of the topology; provide a first value to the first aggregation module, the first value corresponding to an entry in the plurality of log entries; provide a second value to the second aggregation module, the second value obtained based at least in part on output of the first aggregation module using the first value and one or more additional values corresponding to entries in the plurality of log entries; obtain a third value based at least in part on output of the second aggregation module using the second value and one or more additional values corresponding to output of the first aggregation module; store information indicative of a location of the entry in the plurality of log entries for retrieval by a client process to provide a real-time view of the operation of the service. - View Dependent Claims (2, 3, 4, 5)
-
-
6. A method comprising:
-
providing a first value to a first aggregation module corresponding to a first level of a topology of aggregation modules, the first value corresponding to an entry in a plurality of log entries; providing a second value to a second aggregation module corresponding to a second level of the topology, the second value obtained based at least in part on output of the first aggregation module using the first value and one or more additional values corresponding to entries in the plurality of log entries; obtaining a third value based at least in part on output of the second aggregation module using the second value and one or more additional values corresponding to output of the first aggregation module; storing information indicative of a location of the entry in the plurality of log entries; and providing the second value to a client process, wherein the second value is provided prior to obtaining the third value. - View Dependent Claims (7, 8, 9, 10, 11, 12, 13)
-
-
14. A non-transitory computer-readable storage medium having stored thereon instructions that, upon execution by one or more computing devices, cause the one or more computing devices at least to:
-
provide a first value to a first aggregation module corresponding to a first level of a topology, the first value corresponding to an entry in a plurality of log entries; provide a second value to a second aggregation module corresponding to a second level of the topology, the second value obtained based at least in part on output of the first aggregation module using the first value and one or more additional values corresponding to entries in the plurality of log entries; obtain a third value based at least in part on output of the second aggregation module using the second value and one or more additional values corresponding to output of the first aggregation module; store a timestamp associated with the entry in the plurality of log entries; and provide, prior to obtaining the third value, the second value to a client process. - View Dependent Claims (15, 16, 17, 18, 19, 20)
-
Specification