Troubleshooting utility for Azure Automation Update Management Agent

This python script is a troubleshooting tool for assessing the health of the Azure Automation Update Management agent on Linux machines.  It checks several aspects that affect the health of the agent.

You must run this script within the machine that you are troubleshooting. Python version required – 2.4 to 2.7.

#!/usr/bin/env python 
import sys 
import os 
import os.path 
import socket 
import datetime 
import imp 
import codecs 
import json 
import string 
import platform 
import re 
import subprocess 
from os import walk 
rule_info_list = [] 
output = [] 
oms_admin_conf_path = "/etc/opt/microsoft/omsagent/conf/omsadmin.conf" 
oms_agent_dir = "/var/opt/microsoft/omsagent" 
oms_agent_log = "/var/opt/microsoft/omsagent/log/omsagent.log" 
current_mof = "/etc/opt/omi/conf/omsconfig/configuration/Current.mof" 
status_passed = "Passed" 
status_failed = "Failed" 
status_debug = "Debug" 
empty_failure_reason = "" 
workspace = "" 
class RuleInfo: 
    def __init__(self, rule_id, rule_group_id, status, result_msg_id): 
        self.RuleId = rule_id 
        self.RuleGroupId = rule_group_id 
        self.CheckResult = status 
        self.CheckResultMessageId = result_msg_id 
        self.CheckResultMessageArguments = list() 
def main(output_path=None, return_json_output="False"): 
    if os.geteuid() != 0: 
        print "Please run this script as root" 
    # supported python version 2.4.x to 2.7.x 
    if not ((sys.version_info[0] == 2and ((sys.version_info[1]>=4and (sys.version_info[1] < 8))): 
        print("Unsupport python version:" + str(sys.version_info)) 
    global workspace 
    workspace = get_workspace() 
    if return_json_output == "True": 
        print json.dumps([obj.__dict__ for obj in rule_info_list]) 
        for line in output: 
            print line 
        if output_path is not None: 
            except OSError: 
                if not os.path.isdir(output_path): 
            log_path = "%s/healthcheck-%s.log" % (output_path, datetime.datetime.utcnow().isoformat()) 
            f = open(log_path, "w") 
            print "Output is written to " + log_path 
def get_machine_info(): 
    FNULL = open(os.devnull, "w") 
    if["which""hostnamectl"], stdout=FNULL, stderr=FNULL) == 0: 
        hostname_output = os.popen("hostnamectl").read() 
        write_log_output(NoneNone, status_debug, empty_failure_reason, "Machine Information:" + hostname_output) 
def check_os_version(): 
    rule_id = "Linux.OperatingSystemCheck" 
    rule_group_id = "prerequisites" 
    os_version = platform.platform() 
    supported_os_url = "" 
    # We support (Ubuntu 14.04, Ubuntu 16.04, SuSE 11, SuSE 12, Redhat 6, Redhat 7, CentOs 6, CentOs 7) 
    if"Ubuntu-14.04", os_version, re.IGNORECASE) or \"Ubuntu-16.04", os_version, re.IGNORECASE) or \"SuSE-11", os_version, re.IGNORECASE) or \"SuSE-12", os_version, re.IGNORECASE) or \"redhat-6", os_version, re.IGNORECASE) or \"redhat-7", os_version, re.IGNORECASE) or \"centos-6", os_version, re.IGNORECASE) or \"centos-7", os_version, re.IGNORECASE) : 
        write_log_output(rule_id, rule_group_id, status_passed, empty_failure_reason, "Operating system version is supported") 
        log_msg = "Operating System version (%s) is not supported. Supported versions listed here: %s" % (os_version, supported_os_url) 
        write_log_output(rule_id, rule_group_id, status_failed, empty_failure_reason, log_msg, supported_os_url) 
def check_oms_agent_installed(): 
    rule_id = "Linux.OMSAgentInstallCheck" 
    rule_group_id = "servicehealth" 
    oms_agent_troubleshooting_url = "" 
    if os.path.isfile(oms_admin_conf_path) and os.path.isfile(oms_agent_log): 
        write_log_output(rule_id, rule_group_id, status_passed, empty_failure_reason, "Microsoft Monitoring agent is installed") 
        oms_admin_file_content = "\t" 
        oms_admin_file = open(oms_admin_conf_path, "r") 
        for line in oms_admin_file: 
            oms_admin_file_content += line + "\t" 
        write_log_output(rule_id, rule_group_id, status_debug, empty_failure_reason, "omsadmin.conf file contents:\n" + oms_admin_file_content) 
        write_log_output(rule_id, rule_group_id, status_failed, empty_failure_reason, "Microsoft Monitoring agent is not installed", oms_agent_troubleshooting_url) 
        write_log_output(rule_id, rule_group_id, status_debug, empty_failure_reason, "Microsoft Monitoring agent troubleshooting guide:" + oms_agent_troubleshooting_url) 
def check_oms_agent_running(): 
    rule_id = "Linux.OMSAgentStatusCheck" 
    rule_group_id = "servicehealth" 
    oms_agent_troubleshooting_url = "" 
    is_oms_agent_running, ps_output = is_process_running("omsagent", ["omsagent.log""omsagent.conf"], "OMS Agent") 
    if is_oms_agent_running: 
        write_log_output(rule_id, rule_group_id, status_passed, empty_failure_reason, "Microsoft Monitoring agent is running") 
        write_log_output(rule_id, rule_group_id, status_failed, empty_failure_reason, "Microsoft Monitoring agent is not running", oms_agent_troubleshooting_url) 
        write_log_output(rule_id, rule_group_id, status_debug, empty_failure_reason, ps_output) 
        write_log_output(rule_id, rule_group_id, status_debug, empty_failure_reason, "Microsoft Monitoring agent troubleshooting guide:" + oms_agent_troubleshooting_url) 
def check_multihoming(): 
    rule_id = "Linux.MultiHomingCheck" 
    rule_group_id = "servicehealth" 
    if not os.path.isdir(oms_agent_dir): 
        write_log_output(rule_id, rule_group_id, status_failed, "NoWorkspace""Machine is not registered with log analytics workspace.") 
    directories = [] 
    potential_workspaces = [] 
    for (dirpath, dirnames, filenames) in walk(oms_agent_dir): 
        break # Get the top level of directories 
    for directory in directories: 
        if len(directory) >= 32: 
    workspace_id_list = str(potential_workspaces) 
    if len(potential_workspaces) > 1: 
        write_log_output(rule_id, rule_group_id, status_failed, empty_failure_reason, "Machine registered with more than one log analytics workspace. List of workspaces:" + workspace_id_list, workspace_id_list) 
        write_log_output(rule_id, rule_group_id, status_passed, empty_failure_reason, "Machine registered with log analytics workspace:" + workspace_id_list, workspace_id_list) 
def check_hybrid_worker_package_present(): 
    rule_id = "Linux.HybridWorkerPackgeCheck" 
    rule_group_id = "servicehealth" 
    if os.path.isfile("/opt/microsoft/omsconfig/modules/nxOMSAutomationWorker/VERSION"and \ 
        write_log_output(rule_id, rule_group_id, status_passed, empty_failure_reason, "Hybrid worker package is present") 
        write_log_output(rule_id, rule_group_id, status_failed, empty_failure_reason, "Hybrid worker package is not present") 
def check_hybrid_worker_running(): 
    rule_id = "Linux.HybridWorkerStatusCheck" 
    rule_group_id = "servicehealth" 
    if not os.path.isfile(current_mof): 
        write_log_output(rule_id, rule_group_id, status_failed, "MissingCurrentMofFile""Hybrid worker is not running. current_mof file:(" + current_mof + ") is missing", current_mof) 
    search_text = "ResourceSettings" 
    command = "file -b --mime-encoding " + current_mof 
    current_mof_encoding = os.popen(command).read() 
    resourceSetting = find_line_in_file("ResourceSettings", current_mof, current_mof_encoding); 
    if resourceSetting is None: 
        write_log_output(rule_id, rule_group_id, status_failed, empty_failure_reason, "Hybrid worker is not running") 
        write_log_output(rule_id, rule_group_id, status_debug, empty_failure_reason, "Unable to get ResourceSettings from current_mof file:(" + current_mof + ") with file encoding:" + current_mof_encoding) 
    backslash = string.replace("\str""str", "") 
    resourceSetting = string.replace(resourceSetting, backslash, "") 
    resourceSetting = string.replace(resourceSetting, ";", "") 
    resourceSetting = string.replace(resourceSetting, "\"[""[") 
    resourceSetting = string.replace(resourceSetting, "]\"""]") 
    resourceSetting = resourceSetting.split("=")[1].strip() 
    automation_worker_path = "/opt/microsoft/omsconfig/Scripts/" 
    if (sys.version_info.major == 2) : 
        if (sys.version_info.minor >= 6) : 
            automation_worker_path += "2.6x-2.7x" 
            automation_worker_path += "2.4x-2.5x" 
    settings = nxOMSAutomationWorker.read_settings_from_mof_json(resourceSetting) 
    if not settings.auto_register_enabled: 
        write_log_output(rule_id, rule_group_id, status_failed, "UpdateDeploymentDisabled""Hybrid worker is not running", current_mof) 
        write_log_output(rule_id, rule_group_id, status_debug, empty_failure_reason, "Update deployment solution is not enabled. ResourceSettings:" + resourceSetting) 
    if nxOMSAutomationWorker.Test_Marshall(resourceSetting) == [0]: 
        write_log_output(rule_id, rule_group_id, status_passed, empty_failure_reason, "Hybrid worker is running") 
        write_log_output(rule_id, rule_group_id, status_failed, empty_failure_reason, "Hybrid worker is not running") 
        write_log_output(rule_id, rule_group_id, status_debug, empty_failure_reason, "ResourceSettings:" + resourceSetting + " read from current_mof file:(" + current_mof + ")") 
        write_log_output(rule_id, rule_group_id, status_debug, empty_failure_reason, " path:" + automation_worker_path) 
def check_general_internet_connectivity(): 
    rule_id = "Linux.InternetConnectionCheck" 
    rule_group_id = "connectivity" 
    if check_endpoint(None""and check_endpoint(None""): 
        write_log_output(rule_id, rule_group_id, status_passed, empty_failure_reason, "Machine is connected to internet") 
        write_log_output(rule_id, rule_group_id, status_failed, empty_failure_reason, "Machine is not connected to internet") 
def check_agent_service_endpoint(): 
    rule_id = "Linux.AgentServiceConnectivityCheck" 
    rule_group_id = "connectivity" 
    agent_endpoint = get_agent_endpoint() 
    if  agent_endpoint is None: 
        write_log_output(rule_id, rule_group_id, status_failed, "UnableToGetEndpoint""Unable to get the registration (agent service) endpoint") 
    elif  check_endpoint(None, agent_endpoint): 
        write_log_output(rule_id, rule_group_id, status_passed, empty_failure_reason, "TCP test for {" + agent_endpoint + "} (port 443) succeeded", agent_endpoint) 
        write_log_output(rule_id, rule_group_id, status_failed, empty_failure_reason, "TCP test for {" + agent_endpoint + "} (port 443) failed", agent_endpoint) 
def check_jrds_endpoint(workspace): 
    rule_id = "Linux.JRDSConnectivityCheck" 
    rule_group_id = "connectivity" 
    jrds_endpoint = get_jrds_endpoint(workspace) 
    if jrds_endpoint is None: 
        write_log_output(rule_id, rule_group_id, status_failed, "UnableToGetEndpoint""Unable to get the operations (JRDS) endpoint") 
    elif jrds_endpoint is not None and check_endpoint(workspace, jrds_endpoint): 
        write_log_output(rule_id, rule_group_id, status_passed, empty_failure_reason, "TCP test for {" + jrds_endpoint + "} (port 443) succeeded", jrds_endpoint) 
        write_log_output(rule_id, rule_group_id, status_failed, empty_failure_reason, "TCP test for {" + jrds_endpoint + "} (port 443) failed", jrds_endpoint) 
def check_log_analytics_endpoints(): 
    rule_id = "Linux.LogAnalyticsConnectivityCheck" 
    rule_group_id = "connectivity" 
    i = 0 
    if is_fairfax_region() is True: 
        fairfax_log_analytics_endpoints = ["""", 
                    "*""*" ] 
        for endpoint in fairfax_log_analytics_endpoints: 
            i += 1 
            if "*" in endpoint and workspace is not None: 
                endpoint = endpoint.replace("*", workspace) 
            if check_endpoint(workspace, endpoint): 
                write_log_output(rule_id + str(i), rule_group_id, status_passed, empty_failure_reason, "TCP test for {" + endpoint + "} (port 443) succeeded", endpoint) 
                write_log_output(rule_id + str(i), rule_group_id, status_failed, empty_failure_reason, "TCP test for {" + endpoint + "} (port 443) failed", endpoint) 
        log_analytics_endpoints = ["*""*"""] 
        for endpoint in log_analytics_endpoints: 
            i += 1 
            if "*" in endpoint and workspace is not None: 
                endpoint = endpoint.replace("*", workspace) 
            if check_endpoint(workspace, endpoint): 
                write_log_output(rule_id + str(i), rule_group_id, status_passed, empty_failure_reason, "TCP test for {" + endpoint + "} (port 443) succeeded", endpoint) 
                write_log_output(rule_id + str(i), rule_group_id, status_failed, empty_failure_reason, "TCP test for {" + endpoint + "} (port 443) failed", endpoint) 
def check_endpoint(workspace, endpoint): 
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
    new_endpoint = None 
    if "*" in endpoint and workspace is not None: 
        new_endpoint = endpoint.replace("*", workspace) 
    elif "*" not in endpoint: 
        new_endpoint = endpoint 
    if new_endpoint is not None: 
            response = sock.connect_ex((new_endpoint, 443)) 
            if response == 0: 
                return True 
                return False 
        except Exception as ex: 
            return False 
        return False 
def get_jrds_endpoint(workspace): 
    if workspace is not None: 
        worker_conf_path = "/var/opt/microsoft/omsagent/%s/state/automationworker/worker.conf" % (workspace) 
        line = find_line_in_file("jrds_base_uri", worker_conf_path) 
        if line is not None: 
            return line.split("=")[1].split("/")[2].strip() 
    return None 
def get_agent_endpoint(): 
    line = find_line_in_file("agentservice", oms_admin_conf_path) 
    # Fetch the text after https:// 
    if line is not None: 
        return line.split("=")[1].split("/")[2].strip() 
    return None 
def is_process_running(process_name, search_criteria, output_name): 
    command = "ps aux | grep %s | grep -v grep" % (process_name) 
    grep_output = os.popen(command).read() 
    if any(search_text in grep_output for search_text in search_criteria): 
        return True, grep_output 
        return False, grep_output 
def get_workspace(): 
    line = find_line_in_file("WORKSPACE", oms_admin_conf_path) 
    if line is not None: 
        return line.split("=")[1].strip() 
    return None 
def is_fairfax_region(): 
    oms_endpoint = find_line_in_file("OMS_ENDPOINT", oms_admin_conf_path) 
    if oms_endpoint is not None: 
        return ".us" in oms_endpoint.split("=")[1] 
def find_line_in_file(search_text, path, file_encoding=""): 
    if os.path.isfile(path): 
        if file_encoding == "": 
            current_file = open(path, "r") 
            current_file =, "r", file_encoding) 
        for line in current_file: 
            if search_text in line: 
                return line 
    return None 
def write_log_output(rule_id, rule_group_id, status, failure_reason, log_msg, *result_msg_args): 
    global output, rule_info_list 
    if(type(log_msg) != str): 
        log_msg = str(log_msg) 
    if status != status_debug: 
        if failure_reason == empty_failure_reason: 
            result_msg_id = rule_id + "." + status 
            result_msg_id = rule_id + "." + status + "." + failure_reason 
        current_rule_info = RuleInfo(rule_id, rule_group_id, status, result_msg_id) 
        result_msg_args_list = [] 
        for arg in result_msg_args: 
    output.append(status + ": " + log_msg + "\n") 
if __name__ == "__main__": 
    if len(sys.argv) > 2: 
        main(sys.argv[1], sys.argv[2]) 
    elif len(sys.argv) > 1: 

Be the first to comment

Leave a Reply

Your email address will not be published.