Scalable software monitoring infrastructure, using parallel task queuing, to operate in elastic cloud environments

• US 10,103,959 B2
• Filed: 01/07/2014
• Issued: 10/16/2018
• Est. Priority Date: 01/07/2014
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Klein, Paul F.
• Primary Examiner(s): Blair, Douglas B
• Assistant Examiner(s): Boustany, Jihad K
• Application Number:
  US14/149,763
• Publication Number:
  US 20150195164A1
• Time in Patent Office: 1,743 Days
• CPC Class Codes: G06F 2009/45591 Monitoring or debugging support
• CPC Class Codes: G06F 8/60 Software deployment
• CPC Class Codes: G06F 9/45558 Hypervisor-specific management and integration aspects
• CPC Class Codes: H04L 43/0876 Network utilisation, e.g. volume of load or congestion level
• CPC Class Codes: H04L 67/02 based on web technology, e.g. hypertext transfer protocol [HTTP]
• CPC Class Codes: H04L 67/1001 for accessing one among a plurality of replicated servers
• CPC Class Codes: H04L 67/60 Scheduling or organising the servicing of application requests, e.g. requests for application data transmissions using the analysis and optimisation of the required network resources admission control or resource allocation H04L47/70

Abstract

Provided are a method, a system, and a computer program product in which a plurality of cloud images that execute in a plurality of nodes are maintained by a monitoring server, in a cloud computing environment. The monitoring server maintains information on an increase and a decrease in number of the plurality of cloud images in the cloud computing environment.

Claims

1. A system, comprising:

a memory; and

a processor coupled to the memory, wherein the processor performs operations, the operations comprising;

tracking, by a monitoring server via a registry, a plurality of cloud images that execute in a plurality of nodes, in a cloud computing environment, wherein the monitoring server offloads tasks to one or more signaling agents of a plurality of signaling agents that are included in the plurality of cloud images, and wherein in response to a startup of a cloud image, a signaling agent of the cloud image registers the cloud image with the monitoring server and indicates to the monitoring server that a data collection agent is present in the cloud image;

updating the registry of the monitoring server with information on a change in number of the plurality of cloud images in the cloud computing environment;

in response to updating the registry of the monitoring server, querying by a monitoring application of the monitoring server, the registry to determine names of data collection agents available to call;

subsequent to determining the names of the data collection agents available to call, determining how many of the determined data collection agents that are available to call are needed by the monitoring application to call for a request for information;

generating a list of one or more data collection agents and packaging the list of one or more data collection agents in a wrapping protocol and sending the request for information to one signaling agent selected from the plurality of signaling agents via a round robin mechanism;

receiving, by the one signaling agent, the list and determining, by the one signaling agent that the request for information is made of one or more requests packaged together;

decomposing the list, and creating parallel threads to send the one or more requests to the one or more data collection agents named within the list; and

determining, by the one or more data collection agents, the information in parallel, and transmitting the information to the one signaling agent, wherein the one signaling agent repackages and sends the information transmitted by the one or more data collection agents to the monitoring server.

2. The system of claim 1, the operations further comprising:

performing, by a data collection agent of a cloud image, data collection from at least one or more of the plurality of cloud images to which tasks are offloaded.

3. The system of claim 2, wherein the monitoring server aggregates a plurality of requests for data collection and sends the plurality of requests in a single package to the one or more signaling agents that execute on the plurality of cloud images.

4. The system of claim 2, wherein the data collection agent in association with other data collection agents collect information in parallel on at least performance characteristics to report to a customer for the customer to allocate further tasks for execution in the cloud computing environment.

5. The system of claim 1, wherein each of the plurality of cloud images is a virtual machine that executes on one or more of the plurality of nodes of the cloud computing environment, and wherein one or more virtual machine execute on at least some nodes of the plurality of nodes.

10. The system of claim 1, the operations further comprising:

during cloud image expansion new signaling agents register with the monitoring server and keep a registry of the monitoring server up to date.

11. The system of claim 10, the operations further comprising:

during cloud image contraction heartbeats of selected signaling agents cease and an entry of the selected signaling agents in the registry of the monitoring server is updated to indicate removal of the selected signaling agents.

12. The system of claim 11, wherein a set of signaling agents create parallel threads to send requests to data collection agents indicated by the monitoring server to the set of signaling agents.

16. The system of claim 1, wherein a type of the data collection agent, security, and capabilities are indicated while a cloud image registers the cloud image with the monitoring server, wherein each of the plurality of cloud images is a virtual machine that includes at least one signaling agent and at least one data collection agent, wherein the at least one signaling agent and the at least one data collection agent are deployed as part of master image of the virtual machine.

6. A computer program product, the computer program product comprising:

a non-transitory computer readable storage medium having computer readable program code embodied therewith, the computer readable program code configured to perform operations on a processor, the operations comprising;

tracking, by a monitoring server via a registry, a plurality of cloud images that execute in a plurality of nodes, in a cloud computing environment, wherein the monitoring server offloads tasks to one or more signaling agents of a plurality of signaling agents that are included in the plurality of cloud images, and wherein in response to a startup of a cloud image, a signaling agent of the cloud image registers the cloud image with the monitoring server and indicates to the monitoring server that a data collection agent is present in the cloud image;

updating the registry of the monitoring server with information on a change in number of the plurality of cloud images in the cloud computing environment;

in response to updating the registry of the monitoring server, querying by a monitoring application of the monitoring server, the registry to determine names of data collection agents available to call;

subsequent to determining the names of the data collection agents available to call, determining how many of the determined data collection agents that are available to call are needed by the monitoring application to call for a request for information;

generating a list of one or more data collection agents and packaging the list of one or more data collection agents in a wrapping protocol and sending the request for information to one signaling agent selected from the plurality of signaling agents via a round robin mechanism;

receiving, by the one signaling agent, the list and determining, by the one signaling agent that the request for information is made of one or more requests packaged together;

decomposing the list, and creating parallel threads to send the one or more requests to the one or more data collection agents named within the list; and

determining, by the one or more data collection agents, the information in parallel, and transmitting the information to the one signaling agent, wherein the one signaling agent repackages and sends the information transmitted by the one or more data collection agents to the monitoring server.

7. The computer program product of claim 6, the operations further comprising:

performing, by a data collection agent of a cloud image, data collection from at least one or more of the plurality of cloud images to which tasks are offloaded.

8. The computer program product of claim 7, wherein the monitoring server aggregates a plurality of requests for data collection and sends the plurality of requests in a single package to the one or more signaling agents that execute on the plurality of cloud images.

9. The computer program product of claim 7, wherein the data collection agent in association with other data collection agents collect information in parallel on at least performance characteristics to report to a customer for the customer to allocate further tasks for execution in the cloud computing environment.

13. The computer program product of claim 6, the operations further comprising:

during cloud image expansion new signaling agents register with the monitoring server and keep a registry of the monitoring server up to date.

14. The computer program product of claim 13, the operations further comprising:

during cloud image contraction heartbeats of selected signaling agents cease and an entry of the selected signaling agents in the registry of the monitoring server is updated to indicate removal of the selected signaling agents.

15. The computer program product of claim 14, wherein a set of signaling agents create parallel threads to send requests to data collection agents indicated by the monitoring server to the set of signaling agents.

17. The computer program product of claim 6, wherein a type of the data collection agent, security, and capabilities are indicated while a cloud image registers the cloud image with the monitoring server, wherein each of the plurality of cloud images is a virtual machine that includes at least one signaling agent and at least one data collection agent, wherein the at least one signaling agent and the at least one data collection agent are deployed as part of a master image of the virtual machine.