mirror of
https://github.com/munin-monitoring/contrib.git
synced 2025-07-25 02:18:08 +00:00
Update mongodb plugins
* Update mongodb plugins * fix category * chmod +x * flake8-CI * flake8 adjustments for mongo_collection_ and env python3
This commit is contained in:
Alban
GitHub
parent
52144bc277
commit
276169a6c9
9 changed files with 360 additions and 146 deletions
|
|
@ -1,4 +1,4 @@
|
|||
#!/usr/bin/env python
|
||||
#!/usr/bin/env python3
|
||||
# -*- coding: utf-8 -*-
|
||||
# vim: set sts=4 sw=4 encoding=utf-8
|
||||
|
||||
|
|
@ -29,8 +29,8 @@
|
|||
# (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
|
||||
# SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
||||
|
||||
#%# family=auto
|
||||
#%# capabilities=suggest autoconf
|
||||
# #%# family=auto
|
||||
# #%# capabilities=suggest autoconf
|
||||
|
||||
|
||||
import pymongo
|
||||
|
|
@ -40,7 +40,7 @@ settings_host = '127.0.0.1'
|
|||
settings_port = 27017
|
||||
# mongodb_uri will override host and port
|
||||
settings_mongodb_uri = ''
|
||||
settings_db = 'mydb'
|
||||
settings_db = 'admin'
|
||||
settings_user = ''
|
||||
settings_password = ''
|
||||
settings_ignoredb = {}
|
||||
|
|
@ -88,98 +88,97 @@ typeIndex['indexsize']['category'] = 'db'
|
|||
|
||||
|
||||
def getCollstats(graphtype):
|
||||
if settings_mongodb_uri:
|
||||
con = pymongo.MongoClient(settings_mongodb_uri)
|
||||
else:
|
||||
con = pymongo.MongoClient(settings_host, int(settings_port))
|
||||
if settings_mongodb_uri:
|
||||
con = pymongo.MongoClient(settings_mongodb_uri)
|
||||
else:
|
||||
con = pymongo.MongoClient(settings_host, int(settings_port))
|
||||
|
||||
if settings_user:
|
||||
db = con['admin']
|
||||
db.authenticate(settings_user, settings_password)
|
||||
if settings_user:
|
||||
db = con[settings_db]
|
||||
db.authenticate(settings_user, settings_password)
|
||||
|
||||
stats_tmp = {}
|
||||
for dbname in con.database_names():
|
||||
if dbname in settings_ignoredb:
|
||||
continue
|
||||
db = con[dbname]
|
||||
for coll in db.collection_names():
|
||||
if coll.startswith('system.'):
|
||||
continue
|
||||
stats = db.command("collstats", coll)
|
||||
collname = dbname + "_" + coll.replace('.', '_')
|
||||
if not stats_tmp.has_key(collname):
|
||||
stats_tmp[collname] = {}
|
||||
stats_tmp[collname]['value'] = 0
|
||||
stats_tmp[collname]['dbname'] = dbname
|
||||
if typeIndex[graphtype]['index'] in stats:
|
||||
stats_tmp[collname]['value'] += long(stats[typeIndex[graphtype]['index']])
|
||||
stats_tmp = {}
|
||||
for dbname in con.list_database_names():
|
||||
if dbname in settings_ignoredb:
|
||||
continue
|
||||
db = con[dbname]
|
||||
for coll in db.list_collection_names():
|
||||
if coll.startswith('system.'):
|
||||
continue
|
||||
stats = db.command("collstats", coll)
|
||||
collname = dbname + "_" + coll.replace('.', '_')
|
||||
if collname not in stats_tmp:
|
||||
stats_tmp[collname] = {}
|
||||
stats_tmp[collname]['value'] = 0
|
||||
stats_tmp[collname]['dbname'] = dbname
|
||||
if typeIndex[graphtype]['index'] in stats:
|
||||
stats_tmp[collname]['value'] += int(stats[typeIndex[graphtype]['index']])
|
||||
|
||||
con.close()
|
||||
|
||||
for collname, item in sorted(stats_tmp.items()):
|
||||
yield ("%s" % collname, item['value'], item['dbname'])
|
||||
|
||||
|
||||
con.close()
|
||||
|
||||
for collname, item in sorted(stats_tmp.items()):
|
||||
yield ("%s" % collname, item['value'], item['dbname'])
|
||||
|
||||
|
||||
def doData(base,graphtype):
|
||||
def doData(base, graphtype):
|
||||
lastdb = ""
|
||||
for coll, stats, db in sorted(getCollstats(graphtype), key=itemgetter(2)):
|
||||
if lastdb != db:
|
||||
print "multigraph " + base + "_" + graphtype + "_" + db
|
||||
print("multigraph " + base + "_" + graphtype + "_" + db)
|
||||
lastdb = db
|
||||
print "%s_%s.value %s" % (graphtype, coll, stats)
|
||||
print("%s_%s.value %s" % (graphtype, coll, stats))
|
||||
|
||||
|
||||
def doConfig(base,graphtype):
|
||||
def doConfig(base, graphtype):
|
||||
|
||||
lastdb = ""
|
||||
for k,v,d in sorted(getCollstats(graphtype), key=itemgetter(2)):
|
||||
for k, v, d in sorted(getCollstats(graphtype), key=itemgetter(2)):
|
||||
if lastdb != d:
|
||||
print "multigraph " + base + "_" + graphtype + "_" + d
|
||||
print("multigraph " + base + "_" + graphtype + "_" + d)
|
||||
lastdb = d
|
||||
# print "graph_total total"
|
||||
print "graph_title MongoDB " + typeIndex[graphtype]['title'] + " for database " + d
|
||||
print "graph_args --base " + typeIndex[graphtype]['base'] + " " + typeIndex[graphtype]['scale']
|
||||
print "graph_vlabel " + typeIndex[graphtype]['yaxis']
|
||||
print "graph_category db"
|
||||
print "%s_%s.label %s" % (graphtype, k, k)
|
||||
print "%s_%s.min 0" % (graphtype, k)
|
||||
print "%s_%s.draw LINE1" % (graphtype, k)
|
||||
print("graph_title MongoDB " + typeIndex[graphtype]['title'] + " for database " + d)
|
||||
print("graph_args --base " + typeIndex[graphtype]['base'] + " " + typeIndex[graphtype]['scale'])
|
||||
print("graph_vlabel " + typeIndex[graphtype]['yaxis'])
|
||||
print("graph_category db")
|
||||
print("%s_%s.label %s" % (graphtype, k, k))
|
||||
print("%s_%s.min 0" % (graphtype, k))
|
||||
print("%s_%s.draw LINE1" % (graphtype, k))
|
||||
|
||||
|
||||
def doSuggest():
|
||||
print "keys"
|
||||
for k in typeIndex.keys():
|
||||
print k
|
||||
print("keys")
|
||||
for k in typeIndex.keys():
|
||||
print(k)
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
from sys import argv,exit
|
||||
from os import environ,path
|
||||
from sys import argv, exit
|
||||
from os import environ, path
|
||||
import re
|
||||
|
||||
# Could be done by a for loop
|
||||
# but i think if's are faster
|
||||
if 'HOST' in environ:
|
||||
settings_host = environ['HOST']
|
||||
if 'PORT' in environ:
|
||||
settings_port = environ['PORT']
|
||||
if 'DB' in environ:
|
||||
settings_db = environ['DB']
|
||||
if 'MONGO_USER' in environ:
|
||||
settings_user = environ['MONGO_USER']
|
||||
if 'PASSWORD' in environ:
|
||||
settings_password = environ['PASSWORD']
|
||||
if 'IGNOREDB' in environ:
|
||||
settings_ignoredb = environ['IGNOREDB'].split(',')
|
||||
if 'host' in environ:
|
||||
settings_host = environ['host']
|
||||
if 'port' in environ:
|
||||
settings_port = environ['port']
|
||||
if 'db' in environ:
|
||||
settings_db = environ['db']
|
||||
if 'username' in environ:
|
||||
settings_user = environ['username']
|
||||
if 'password' in environ:
|
||||
settings_password = environ['password']
|
||||
if 'ignoredb' in environ:
|
||||
settings_ignoredb = environ['ignoredb'].split(',')
|
||||
m = re.search('^(.*)_([a-zA-Z0-9]*)$', path.basename(argv[0]))
|
||||
if len(argv) < 2:
|
||||
doData(m.group(1),m.group(2))
|
||||
doData(m.group(1), m.group(2))
|
||||
elif argv[1] == "config":
|
||||
doConfig(m.group(1),m.group(2))
|
||||
doConfig(m.group(1), m.group(2))
|
||||
elif argv[1] == "autoconf":
|
||||
print "yes"
|
||||
print("yes")
|
||||
elif argv[1] == "suggest":
|
||||
doSuggest()
|
||||
else:
|
||||
print "invalid argument"
|
||||
print("invalid argument")
|
||||
exit(1)
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue