US 10,884,844 B2Granted

Data stream processor and method to counteract anomalies in data streams transiting a distributed computing system

AssigneeHomeAway.com, Inc.

InventorRene X. Parra

Life of this patent

Estimating the term…

Loading patent…

Abstract

Various embodiments relate generally to electrical and electronic hardware, computer software and systems for controlling a data stream processor configured to detect and/or resolve anomalies in data streams including message data. In particular, a system, a device and a method may be configured to access multiple data streams and to detect an anomaly, in real-time or in substantially real-time, that is associated with at least one of the data streams accessed by a data stream processor. In some examples, a method can include one or more of receiving message data to facilitate a computerized rental of property, classifying subset of messages, fetching the classified messages to form multiple data streams, accessing the data stream to indemnity a stream characteristic, detecting an anomaly based on an identified stream characteristic, and generating anomaly resolution data to counteract the detected anomaly.

Claims20

Dependent claims

A computer-implemented method comprising:

as performed by a computing system comprising one or more computer processors configured to execute specific instructions,
classifying a set of messages into a plurality of subsets of messages, wherein a message in a subset of messages of the plurality of subsets of messages represents a programmatic call;
monitoring a transmission of a data stream between computing devices, wherein the data stream comprises messages in the subset of messages;
determining a plurality of parametric values associated with a stream characteristic of the data stream, wherein a parametric value of the plurality of parametric values represents a value of the stream characteristic;
determining a first correlated subset of the plurality of parametric values based at least partly on the first correlated subset being correlated with a non-anomalous state of the data stream;
determining a second correlated subset of the plurality of parametric values based at least partly on the second correlated subset being correlated with an anomalous state of the data stream;
determining an anomaly threshold based at least partly on the first correlated subset and the second correlated subset;
detecting an anomaly associated with the data stream based at least partly on the stream characteristic and the anomaly threshold;
and
generating anomaly resolution data regarding the anomaly.

7 more elements

A system comprising:

computer-readable storage storing executable instructions;
and
one or more processors in communication with the computer-readable storage and configured by the executable instructions to at least:
classify a set of messages into a plurality of subsets of messages, wherein a message in a subset of messages of the plurality of subsets of messages represents a programmatic call;
monitor a transmission of a data stream between computing devices, wherein the data stream comprises messages in the subset of messages;
determine a plurality of parametric values associated with a stream characteristic of the data stream, wherein a parametric value of the plurality of parametric values represents a value of the stream characteristic;
determine a first correlated subset of the plurality of parametric values based at least partly on the first correlated subset being correlated with a non-anomalous state of the data stream;
determine a second correlated subset of the plurality of parametric values based at least partly on the second correlated subset being correlated with an anomalous state of the data stream;
determine an anomaly threshold based at least partly on the first correlated subset and the second correlated subset;
detect an anomaly associated with the data stream based at least partly on the stream characteristic and the anomaly threshold;
and
generate anomaly resolution data regarding the anomaly.

9 more elements

Dependencies are inferred from the claim text.

Facts

Application: 16/166,593Filed 22 Oct 2018 · continuation
Priority: 6 Nov 2015
Published: US 2019/0171516 A16 Jun 2019
Granted: 5 Jan 2021
Term ends: Not estimatedThe source records don’t support an estimate.

Classification17 codes

G06F 11/0793
Error or fault processing not based on redundancy, i.e. by taking additional measures to deal with the error or fault not making use of…
G06F 11/0709
The processing taking place on a specific hardware platform or in a specific software environment: in a distributed system consisting of a…
G06F 11/3409
Recording or statistical evaluation of computer activity, e.g. of down time, of input/output operation ; Recording or statistical evaluation of…:…
G06F 11/3428
For performance assessment: benchmarking

Family

Application14/935,215Parent of this continuation · filed 6 Nov 2015
US 2019/0171516 A1Pre-grant publication · published 6 Jun 2019
US 10,108,480 B2Parent of this continuation
US 2017/0132068 A1Published application
US 10,884,844 B2This patent

From the US filing history. Foreign family members aren’t listed.