I use something like this:
(it has a few things that are specific to my implementation)
#!/usr/bin/python
import os
import csv
import urllib2
import pprint
import time
datadir = '/home/rrdcollect/haproxy-stats/rrds'
hostlist = ['a.network.com']
haproxycreds = ['url','user','pass']
key_values = ['scur', 'bin', 'bout']
for host in hostlist:
print host
url = 'http://%s/%s;csv;norefresh' % (host, haproxycreds[0])
print url
pp = pprint.PrettyPrinter(indent=4)
passman = urllib2.HTTPPasswordMgrWithDefaultRealm()
passman.add_password(None, url, haproxycreds[1], haproxycreds[2])
authhandler = urllib2.HTTPBasicAuthHandler(passman)
opener = urllib2.build_opener(authhandler)
urllib2.install_opener(opener)
f = urllib2.urlopen(url)
firstrow = True
e = dict()
for row_ind,row in enumerate(csv.reader(f)):
if firstrow:
mapping = row
firstrow = False
if "FRONTEND" in row or "BACKEND" in row:
d = {}
for ind,col_val in enumerate(row):
col_name = mapping[ind]
d[col_name]=col_val
row_key = row[0],row_ind
e[row_key]=d
for keys in key_values:
for key_tuple,row_dict in e.iteritems():
row_val = row_dict.get(keys,'')
if keys == "scur":
pitem = "CurrentSessionRate"
elif keys == "bin":
pitem = "bpsIn"
row_val = int(row_val)*8
row_val = str(row_val)
elif keys == "bout":
pitem = "bpsOut"
row_val = int(row_val)*8
row_val = str(row_val)
rrd = "%s/haproxyStat_%s_%s_%s.rrd" % (datadir,
pitem, key_tuple[0], host)
print rrd
cmd = "rrdtool update %s N:%s" % (rrd, row_val)
print cmd
if not os.path.isfile(rrd):
print 'RRD does not exist!'
from time import time
now = int(time())
print now
now-=300
print now
maxvalue = 10000000000000000000000000000000000000
if "bps" in pitem:
cmd = 'rrdtool create %s --start %s
--step 300 DS:data:DERIVE:600:0:%s RRA:AVERAGE:0.5:1:9000
RRA:AVERAGE:0.5:12:4000 RRA:AVERAGE:0.5:72:5000
RRA:AVERAGE:0.5:288:2500' % (rrd, now, maxvalue)
else:
cmd = 'rrdtool create %s --start %s
--step 300 DS:data:COUNTER:600:0:%s RRA:AVERAGE:0.5:1:9000
RRA:AVERAGE:0.5:12:4000 RRA:AVERAGE:0.5:72:5000
RRA:AVERAGE:0.5:288:2500' % (rrd, now, maxvalue)
print cmd
os.system(cmd)
os.system(cmd)
On Tue, Oct 2, 2012 at 11:17 AM, Saul Waizer <[email protected]> wrote:
> Hello List,
>
> This is a general question, has anyone developed a method of polling
> statistics from HAproxy to determine the current requests per second rate? I
> am building a custom nagios plugin that will also work with graphite and
> cacti, i am trying to find the best approach to gather RPS statistics. Any
> suggestions?
>
> Thank You,
> Saul
