Monitoring data streams and scaling computing resources based on the data streams

Patent metadata

Field	Value
Publication number	US-10277524-B1
Application number	US-201815904084-A
Country	US
Kind code	B1
Filing date	Feb 23, 2018
Priority date	Feb 23, 2018
Publication date	Apr 30, 2019
Grant date	Apr 30, 2019

Abstract

A device may determine values for a set of metrics related to a set of event messages being processed, by a set of server devices, from a set of queues. The values for the set of metrics may be determined as the set of event messages are being processed. Each of the set of queues may be associated with a different subset of event messages and a different subset of server devices. The device may determine to scale a quantity of server devices included in the set of server devices. The quantity of server devices may be scaled to increase the quantity of server devices or to decrease the quantity of server devices. The device may provide a set of instructions to scale the quantity of server devices. The device may perform an action to facilitate accessibility of data related to processing of the set of event messages.

First claim

What is claimed is:

1. A device, comprising:
one or more memories; and
one or more processors, communicatively coupled to the one or more memories, to:
receive a set of event messages to be processed by a set of server devices;
determine values for a set of metrics related to the set of event messages being processed, by the set of server devices, from a set of queues,
wherein the set of metrics includes lag-related metrics,
wherein the values for the set of metrics are determined as the set of event messages are being processed,
wherein each of the set of queues is associated with a different subset of event messages and a different subset of server devices;

determine to scale a quantity of server devices included in the set of server devices based on the values for the set of metrics,
wherein the quantity of server devices is to be scaled to increase the quantity of server devices or to decrease the quantity of server devices;

provide a set of instructions to scale the quantity of server devices included in the set of server devices after determining to scale the quantity of server devices;
perform an action to facilitate accessibility of data related to processing of the set of event messages in association with providing the set of instructions;
provide the data to a particular queue, of the set of queues, to provide one or more modules with accessibility to the data,
the one or more modules relating to at least one of:
a machine learning technique,
a threat detection technique, or
a fault detection technique; and

provide the data for display via a dashboard that is accessible via a user device in association with providing the set of instructions.

2. The device of claim 1 , wherein the one or more processors, when receiving the set of event messages, are to:
receive the set of event messages from a set of user devices prior to determining the values for the set of metrics,
the set of event messages are related to interactions of users of the set of user devices with user interfaces displayed by a set of displays associated with the set of user devices.

3. The device of claim 2 , wherein the one or more processors are further to:
assign the set of event messages to the set of queues to prepare the set of event messages for processing by the set of server devices after receiving the set of event messages; and
wherein the one or more processors, when determining the values for the set of metrics, are to:
determine the values for the set of metrics after assigning the set of event messages to the set of queues.

4. The device of claim 1 , wherein the one or more processors, when determining to scale the quantity of server devices, are to:
determine to scale a first subset of server devices, rather than a second subset of server devices, based on the values for the set of metrics for the first subset of server devices satisfying a threshold and the values for the set of metrics for the second subset of server devices not satisfying the threshold,
wherein the first subset of server devices is associated with a first queue of the set of queues,
wherein the second subset of server devices is associated with a second queue of the set of queues,
wherein the first queue and the second queue are different.

5. The device of claim 1 , wherein the one or more processors are further to:
process the data using a machine learning technique to identify a pattern in the data after providing the data,
wherein the pattern in the data is to be used to predictively scale the quantity of server devices included in the set of server devices.

6. The device of claim 1 , wherein the one or more processors are further to:
determine an amount by which to scale the quantity of server devices included in the set of server devices after determining to scale the quantity of server devices; and
wherein the one or more processors, when providing the set of instructions to scale the quantity of server devices, are to:
provide the set of instructions to scale the quantity of server devices by the amount after determining the amount.

7. The device of claim 1 , wherein the one or more processors, when providing the set of instructions, are to:
provide the set of instructions to a set of additional server devices to cause the set of additional server devices to power on, or
provide the set of instructions to one or more server devices in the set of server devices to cause the one or more server devices to power off.

8. The device of claim 1 , where the one or more processors are further to:
process the data to detect a threat to a system after providing the data to facilitate accessibility of the data.

9. The device of claim 1 , where the one or more processors are further to:
provide a notification for display in association with providing the set of instructions,
wherein the notification includes information identifying that the quantity of server devices included in the set of server devices is being scaled.

10. A non-transitory computer-readable medium storing instructions, the instructions comprising:
one or more instructions that, when executed by one or more processors, cause the one or more processors to:
receive a set of event messages to be processed by a set of server devices;
determine values for a set of metrics related to the set of event messages being processed, by the set of server devices, from a set of queues,
wherein each of the set of queues is associated with a different subset of event messages and a different subset of server devices;

determine to modify a quantity of server devices included in the set of server devices based on the values for the set of metrics,
wherein the quantity of server devices is to be modified to increase the quantity of server devices or to decrease the quantity of server devices,
wherein the quantity of server devices is to be modified for one or more subsets of server devices associated with the set of queues;

provide a set of instructions to modify the quantity of server devices included in the set of server devices after determining to scale the quantity of server devices,
wherein the set of instructions is associated with modifying the quantity of server devices for the one or more subsets of server devices associated with the set of queues;

perform an action to facilitate accessibility of data related to processing of the set of event messages in association with providing the set of instructions;
provide the data to a particular queue, of the set of queues, to provide one or more modules with accessibility to the data,
the one or more modules relating to at least one of:
a machine learning technique,
a threat detection technique, or
a fault detection technique; and

provide the data for display via a dashboard that is accessible via a user device in association with providing the set of instructions.

11. The non-transitory computer-readable medium of claim 10 , wherein the set of event messages is received by a first module of a device; and
wherein the one or more instructions, that cause the one or more processors to determine the values for the set of metrics, cause the one or more processors to:
determine the values for the set of metrics after receiving the set of event messages,
wherein the values for the set of metrics are determined by a second module of the device,
wherein the second module is to receive the data, from which the values are to be determined, from the first module.

12. The non-transitory computer-readable medium of claim 10 , wherein the one or more instructions, when executed by the one or more processors, further cause the on

Assignees

• Capital One Services Llc

Inventors

• Kaitha Sunil
• Bhatt Japan

Classifications

• H04L41/06

  Management of faults, events, alarms or notifications · CPC title

• H04L67/10

  in which an application is distributed across nodes in the network (software deployment G06F8/60; multiprogramming arrangements G06F9/46) · CPC title

• H04L41/14

  Network analysis or design · CPC title

• H04L65/1093

  by adding participants; by removing participants · CPC title

• H04L65/1046

  Call controllers; Call servers · CPC title