Managing operation of data processing systems using time-weighted telemetry data

A non-transitory machine-readable medium having instructions stored therein, which when executed by a processor, cause the processor to perform operations for managing operation of a distributed system comprising data processing systems, the operations comprising:

• obtaining telemetry data for a data processing system of the data processing systems;
• making a first determination regarding whether the data processing system drifted from a previous state using the telemetry data and historic telemetry data for the data processing system;
• in a first instance of the first determination where the data processing system has drifted:
• updating a similarity map using the telemetry data and a global time-weighted telemetry data cache for the data processing systems, the updated similarity map indicating a portion of the data processing systems as being similar to the data processing system;
• updating a local time-weighted telemetry data cache for the portion of the data processing systems to obtain an updated local time-weighted telemetry data cache;
• making a second determination regarding whether the telemetry data is anomalous using the updated local time-weighted telemetry data cache;
• and
• in a first instance of the second determination where the telemetry data is anomalous:
• performing a management process for the data processing system based on the telemetry data to facilitate continued provisioning of computer implemented services.

A system, comprising:

• a processor;
• and
• a memory coupled to the processor to store instructions, which when executed by the processor, cause the processor to perform operations for managing operation of a distributed system comprising data processing systems, the operations comprising:
• obtaining telemetry data for a data processing system of the data processing systems;
• making a first determination regarding whether the data processing system drifted from a previous state using the telemetry data and historic telemetry data for the data processing system;
• in a first instance of the first determination where the data processing system has drifted:
• updating a similarity map using the telemetry data and a global time-weighted telemetry data cache for the data processing systems, the updated similarity map indicating a portion of the data processing systems as being similar to the data processing system
• updating a local time-weighted telemetry data cache for the portion of the data processing systems to obtain an updated local time-weighted telemetry data cache;
• making a second determination regarding whether the telemetry data is anomalous using the updated local time-weighted telemetry data cache;
• and
• in a first instance of the second determination where the telemetry data is anomalous:
• performing a management process for the data processing system based on the telemetry data to facilitate continued provisioning of computer implemented services.