Monitoring IBM v7000 using Graphite and Grafana
From MyWiki
(Difference between revisions)
Line 130: | Line 130: | ||
The end result looks like this | The end result looks like this | ||
- | [[ | + | [[File:monitoring-with-Graphana.png]] |
Revision as of 23:07, 14 October 2014
Cron job
*/5 * * * * /home/alex/bin/v7k2graphite.py /home/alex/bin/v7k2graphite.ini
The script /home/alex/bin/v7k2graphite.py collects 5 minutes history and shoots it to Graphite:
#!/usr/bin/python2.7 # Filename: v7k2graphite.py __author__ = "amarkelo, SysEng, Smartbox Experience Ltd." __copyright__ = "Smartbox Experience Ltd." __credits__ = ["The SysEng team"] __license__ = "GPL" __version__ = "1.0" __maintainer__ = "amarkelo" __email__ = "alex.markelov@smartandco.com" __status__ = "Production" import statsd import sys import os import string import paramiko import ConfigParser import time import socket def read_config(section): cfg = {} # Read ini-style configuration file try: config = ConfigParser.ConfigParser() config.readfp(open(cfg_file)) except IOError as e: print "I/O error({0}): {1}".format(e.errno, e.strerror) sys.exit("Please check the configuration file " + cfg_file + "exists!") except: print "Unexpected error:", sys.exc_info()[0] raise sys.exit(1) try: # graphite server details cfg['host'] = config.get(section,'host') cfg['port'] = config.get(section,'port') # SSH configuration to get to SAN storage cfg['ssh_host'] = config.get(section,'ssh_host') cfg['ssh_username'] = config.get(section,'ssh_username') cfg['ssh_key'] = config.get(section,'ssh_key') # what metrics to collect cfg['metric'] = config.get(section, 'metric') except: sys.exit("Error reading the configuration parameters from " + cfg_file + ". Exiting...") return cfg def get_stats( ssh_host, ssh_username, ssh_key, cmd) : # Establish SSH connection with SAN storage management interface try: ssh = paramiko.SSHClient() ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy()) ssh.connect(ssh_host, username=ssh_username, password='', key_filename=ssh_key) except: sys.exit("Error establishing SSH connection to server (" + ssh_username + "@" + ssh_host + ")!") stdin, stdout, stderr = ssh.exec_command(cmd) stdout = stdout.readlines() ssh.close() return stdout def send_msg(host, port, message): # print 'sending message:\n%s to %s:%s' % (message, host, port) sock = socket.socket() sock.connect((host, int(port))) sock.sendall(message) sock.close() if __name__ == '__main__': help_str = "\nUsage: " + sys.argv[0] + " <configuration_file>\n" # parsing command line parameters first # if we don't have it the right way - exit if len(sys.argv) < 2: print help_str sys.exit(1) else: cfg_file = sys.argv[1] if not os.path.exists(cfg_file): print "Configuration file " + cfg_file + " doesn't exist!" sys.exit(1) config = {} config = read_config('graphite') # two controllers in the SAN nodes = ['node1','node2'] for metric in config['metric'].split(',') : for node in nodes : out = get_stats(config['ssh_host'], config['ssh_username'], config['ssh_key'], 'lsnodecanisterstats -history ' + metric + ' -nohdr ' + node) for line in out : # 1 node1 140911134627 mdisk_r_mb 0 timestamp = int(time.mktime(time.strptime(line.split()[2], '%y%m%d%H%M%S'))) send_msg(config['host'], config['port'], "storage"+"."+line.split()[1]+"."+line.split()[3]+" "+line.split()[4]+" "+str(timestamp)+"\n")
Ini file /home/alex/bin/v7k2graphite.ini
[graphite] host = 10.10.10.10 port = 2003 ssh_host = 10.5.5.5 ssh_username = zabbix ssh_key = /home/alex/.ssh/zabbix_v7000_rsa metric = mdisk_w_mb,mdisk_r_mb,mdisk_w_io,mdisk_w_io,mdisk_w_ms,mdisk_r_ms,vdisk_w_mb,vdisk_r_mb,vdisk_w_io,vdisk_w_io,vdisk_w_ms,vdisk_r_ms,fc_mb,fc_io,sas_mb,sas_io,write_cache_pc,total_cache_pc,cpu_pc
The end result looks like this