Changeset 8319 in genesis for nodes/status-monitoring.py

Timestamp:

Aug 12, 2010, 2:32:45 PM (14 years ago)

Author:

rick

Message:

Initial status output

File:

• nodes/status-monitoring.py (modified) (5 diffs)

nodes/status-monitoring.py

@@ -246 +246 @@
   status = stored_status['nmap_status']
 
+  # Data store format used for nodemap generation
+  nodemap_status_file = '/tmp/nodemap_status.yaml'
+  nodemap = { 'node' : {}, 'link' : {}}
+
+  # XXX: Pushed back till we actually store the MAC in the config files automatically
+  #configmac_to_host = dict()
+  #for host,config in configs.iteritems():
+  #  for iface_key in gformat.get_interface_keys(config):
+  #    configmac_to_host[config[iface_key]['mac']] = host
+
   # List of hosts which has some kind of problem
   for host in list(set(configs.keys()) - set(host_processed.keys())):
-     print "# Problem in host '%s'" % host
+     config = configs[host]
+     print "# Problems in host '%s'" % host
+     host_down = True
+     for ip in gformat.get_used_ips([config]):
+       if status[ip]['state'] == "up":
+         host_down = False
+       print "## -  ", ip, status[ip]['state']
+     if host_down:
+       print "## HOST is DOWN!"
+       nodemap['node'][host] = gformat.DOWN
+     else:
+       print "## SNMP problems (not reachable, deamon not running, etc)"
+       nodemap['node'][host] = gformat.UNKNOWN
+
+       
 
   # Correlation mapping
   for host, details in host_processed.iteritems():
+    nodemap['node'][host] = gformat.OK
     print "# Working on %s" % host
     for ip, arpmac in details['arpmac'].iteritems():
@@ -261 +286 @@
       else:
         print "## Interlink %s - %s"  % (host, mac_to_host[arpmac])
-
+        nodemap['link'][(host,mac_to_host[arpmac])] = gformat.OK
+
+  stream = file(nodemap_status_file,'w')
+  yaml.dump(nodemap, stream, default_flow_style=False)
+  print "# Wrote nodemap status to '%s'" % nodemap_status_file
 
 def usage():
@@ -310 +339 @@
   if not opt_force_range:
     configs = gformat.get_all_configs()
-    iplist = gformat.get_used_ips(configs)
+    iplist = gformat.get_used_ips(configs.values())
   else:
     iplist = sys.argv[1:]
@@ -330 +359 @@
     nmap_status = stored_status['nmap_status']
 
+  # Save the MAC -> HOST mappings, by default as it helps indentifing the
+  # 'unknown links'
+  mac_to_host = {}
+  if stored_status:
+     mac_to_host = stored_status['mac_to_host']
+
   # Do SNMP discovery
   if opt_snmp_scan:
@@ -335 +370 @@
   else:
     snmp_status = stored_status
+
+  # Include our saved MAC -> HOST mappings
+  mac_to_host.update(snmp_status['mac_to_host'])
+  snmp_status['mac_to_host'] = mac_to_host
  
   # Store changed data to disk