Mirrors/Munin-Contrib
1
0
Fork 0
mirror of https://github.com/munin-monitoring/contrib.git synced 2025-07-21 18:41:03 +00:00
Code Issues Releases Wiki Activity

Plugin nutcracker_requests_: migrate to Python3, format documentation

Browse source
This commit is contained in:
Lars Kruse 2020-11-26 02:18:11 +01:00
parent 7cf2dda94a
commit 518644057e
2 changed files with 44 additions and 33 deletions
Download patch file Download diff file Expand all files Collapse all files

76
plugins/twemproxy/nutcracker_requests_
View file

@ -1,62 +1,74 @@
#!/usr/bin/env python #!/usr/bin/env python3
"""
=head1 NAME
# This is a monitoring plugin for twemproxy (aka: nutcracker) nutcracker_requests_ - monitor twemproxy (aka: nutcracker)
# config in /etc/munin/plugin-conf.d/nutcracker.conf
#
# [nutcracker_*]
# env.NUTCRACKER_STATS_HOST 127.0.0.1
# env.NUTCRACKER_STATS_PORT 22222
#
# any questions to edgarmveiga at gmail dot com
#
=head1 CONFIGURATION
Config in /etc/munin/plugin-conf.d/nutcracker.conf:
[nutcracker_*]
env.NUTCRACKER_STATS_HOST 127.0.0.1
env.NUTCRACKER_STATS_PORT 22222
=head1 AUTHORS
Copyright 2013 Edgar Veiga <edgarmveiga@gmail.com>
=cut
"""
import json
import socket import socket
import sys
import os import os
import sys
try:
import json
except ImportError:
import simplejson as json
def get_stats(): def get_stats():
data = ''; data = ''
HOST = os.environ.get('NUTCRACKER_STATS_HOST', '127.0.0.1'); HOST = os.environ.get('NUTCRACKER_STATS_HOST', '127.0.0.1')
PORT = int(os.environ.get('NUTCRACKER_STATS_PORT', 22222)) PORT = int(os.environ.get('NUTCRACKER_STATS_PORT', 22222))
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((HOST, PORT)) s.connect((HOST, PORT))
file = s.makefile('r') file = s.makefile('r')
data = file.readline(); data = file.readline()
s.close() s.close()
return json.loads(data); return json.loads(data)
def process_data(): def process_data():
data = get_stats(); data = get_stats()
# get pools # get pools
for key, value in data.iteritems(): for key, value in data.items():
if(type(value) == dict): if isinstance(value, dict):
total = 0 total = 0
# get server requests # get server requests
for pool_key, pool_value in value.items(): for pool_key, pool_value in value.items():
if(type(pool_value) == dict): if isinstance(pool_value, dict):
total += pool_value["requests"] total += pool_value["requests"]
print "requests_"+key+".value"+" "+str(total) print("requests_" + key + ".value" + " " + str(total))
def process_config(): def process_config():
print "graph_title Nutcracker requests/s" print("graph_title Nutcracker requests/s")
print "graph_category other" print("graph_category other")
print "graph_vlabel requests/s" print("graph_vlabel requests/s")
data = get_stats(); data = get_stats()
for key, value in data.items(): for key, value in data.items():
if(type(value) == dict): if isinstance(value, dict):
print "requests_"+key+".label "+key print("requests_" + key + ".label " + key)
print "requests_"+key+".type COUNTER" print("requests_" + key + ".type COUNTER")
print "requests_"+key+".min 0" print("requests_" + key + ".min 0")
if __name__ == "__main__": if __name__ == "__main__":
if len(sys.argv) > 1 and sys.argv[1] == "config": if len(sys.argv) > 1 and sys.argv[1] == "config":

1
t/test-exception-wrapper.expected-failures
View file

@ -453,7 +453,6 @@ plugins/tinydns/tinydns_err
plugins/tor/tor_traffic plugins/tor/tor_traffic
plugins/trafic_ro/trafic_ro_24h plugins/trafic_ro/trafic_ro_24h
plugins/tv/hdhomerun_ plugins/tv/hdhomerun_
plugins/twemproxy/nutcracker_requests_
plugins/unicorn/unicorn_ plugins/unicorn/unicorn_
plugins/unicorn/unicorn_memory_status plugins/unicorn/unicorn_memory_status
plugins/unicorn/unicorn_status plugins/unicorn/unicorn_status