View source

Cron job

<pre>
*/5 * * * * /home/alex/bin/v7k2graphite.py /home/alex/bin/v7k2graphite.ini
</pre>

The script <tt>/home/alex/bin/v7k2graphite.py</tt> collects 5 minutes history and shoots it to Graphite:
<pre>
#!/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")
</pre>

Ini file <tt>/home/alex/bin/v7k2graphite.ini</tt>

<pre>
[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
</pre>

The end result looks like this

[[file:v7000 monitoring with Graphana.png]]