From a72dfcc00db140375f3a31a3b9f196ac067f62a8 Mon Sep 17 00:00:00 2001 From: Brian Warner <warner@lothar.com> Date: Mon, 14 Jul 2008 13:18:11 -0700 Subject: [PATCH] munin: add plugin for storage-server operations per second --- misc/munin/tahoe_server_operations_ | 74 +++++++++++++++++++++++++++++ 1 file changed, 74 insertions(+) create mode 100644 misc/munin/tahoe_server_operations_ diff --git a/misc/munin/tahoe_server_operations_ b/misc/munin/tahoe_server_operations_ new file mode 100644 index 00000000..9fa5bddd --- /dev/null +++ b/misc/munin/tahoe_server_operations_ @@ -0,0 +1,74 @@ +#!/usr/bin/python + +# graph operations-per-second from a set of storage servers. + +# the OPERATION value should come from the following list: +# allocate: allocate_buckets, first step to upload an immutable file +# write: write data to an immutable share +# close: finish writing to an immutable share +# cancel: abandon a partial immutable share +# get: get_buckets, first step to download an immutable file +# read: read data from an immutable share +# writev: slot_testv_and_readv_and_writev, modify/create a directory +# readv: read a directory (or mutable file) + +# To use this, create a symlink from +# /etc/munin/plugins/tahoe_server_operations_OPERATION to this script. For +# example: + +# ln -s /usr/share/doc/allmydata-tahoe/munin/tahoe_server_operations_ \ +# /etc/munin/plugins/tahoe_server_operations_allocate + +# Also, you will need to put a list of node statistics URLs in the plugin's +# environment, by adding a stanza like the following to a file in +# /etc/munin/plugin-conf.d/, such as /etc/munin/plugin-conf.d/tahoe_latencies: +# +# [tahoe_server_operations*] +# env.url_storage1 http://localhost:9011/statistics?t=json +# env.url_storage2 http://localhost:9012/statistics?t=json +# env.url_storage3 http://localhost:9013/statistics?t=json +# env.url_storage4 http://localhost:9014/statistics?t=json + +# of course, these URLs must match the webports you have configured into the +# storage nodes. + +import os, sys +import urllib +import simplejson + +node_urls = [] +for k,v in os.environ.items(): + if k.startswith("url_"): + nodename = k[len("url_"):] + node_urls.append( (nodename, v) ) +node_urls.sort() + +configinfo = \ +"""graph_title Tahoe Server Operations +graph_vlabel ops per second +graph_category tahoe +graph_info This graph shows server-side storage operation rates +""" + +for nodename, url in node_urls: + configinfo += "%s.label %s\n" % (nodename, nodename) + configinfo += "%s.type DERIVE\n" % (nodename,) + configinfo += "%s.min 0\n" % (nodename,) + configinfo += "%s.draw LINE2\n" % (nodename,) + + +if len(sys.argv) > 1: + if sys.argv[1] == "config": + print configinfo.rstrip() + sys.exit(0) + +for nodename, url in node_urls: + data = simplejson.loads(urllib.urlopen(url).read()) + my_name = os.path.basename(sys.argv[0]) + PREFIX = "tahoe_server_operations_" + assert my_name.startswith(PREFIX) + operation = my_name[len(PREFIX):] + key = "storage_server.%s" % operation + value = data["counters"][key] + print "%s.value %s" % (nodename, value) + -- 2.45.2