2017-01-07 11:46:50 +00:00
|
|
|
#!/usr/bin/python
|
|
|
|
|
|
|
|
import web
|
2017-01-07 12:53:08 +00:00
|
|
|
import requests
|
|
|
|
import xmltodict
|
|
|
|
import json
|
|
|
|
import os
|
|
|
|
import sys
|
2017-01-07 11:46:50 +00:00
|
|
|
import datetime
|
2019-08-14 11:01:29 +00:00
|
|
|
from collections import OrderedDict
|
|
|
|
from operator import itemgetter
|
2017-01-07 11:46:50 +00:00
|
|
|
|
|
|
|
urls = ('/', 'index',
|
|
|
|
'/help', 'help'
|
2017-01-07 12:53:08 +00:00
|
|
|
)
|
2017-01-07 11:46:50 +00:00
|
|
|
|
|
|
|
app = web.application(urls, globals())
|
|
|
|
render = web.template.render('templates/', base="layout")
|
|
|
|
|
2017-01-07 12:53:08 +00:00
|
|
|
# Uncomment to turn debug off
|
2017-01-07 11:46:50 +00:00
|
|
|
web.config.debug = False
|
|
|
|
|
2017-01-07 12:53:08 +00:00
|
|
|
# Variables
|
2017-01-07 11:46:50 +00:00
|
|
|
output = []
|
|
|
|
|
2017-01-07 12:53:08 +00:00
|
|
|
# Functions
|
|
|
|
|
2019-10-25 15:48:24 +00:00
|
|
|
def calculate_count(data):
|
|
|
|
count = {}
|
2019-08-16 17:07:50 +00:00
|
|
|
ls = data.values()
|
|
|
|
z, nz = 0,0
|
|
|
|
for v in ls:
|
|
|
|
if v == 0:
|
|
|
|
z += 1
|
|
|
|
else:
|
|
|
|
nz += 1
|
2019-10-25 15:48:24 +00:00
|
|
|
count['green'] = z
|
|
|
|
count['red'] = nz
|
|
|
|
return count
|
2019-08-16 17:07:50 +00:00
|
|
|
|
|
|
|
|
2017-01-07 11:46:50 +00:00
|
|
|
def getMonit():
|
|
|
|
output = []
|
|
|
|
xmlQuery = "/_status?format=xml"
|
|
|
|
|
|
|
|
with open('{0}/conf/servers.json'.format(os.path.expanduser('.'))) as f:
|
|
|
|
cf = json.loads(f.read())
|
|
|
|
|
|
|
|
for site in cf:
|
|
|
|
s = cf[site]
|
2017-01-07 12:53:08 +00:00
|
|
|
r = requests.get(s['url'] + xmlQuery,
|
|
|
|
auth=(s['user'], s['passwd']))
|
2017-01-07 11:46:50 +00:00
|
|
|
|
|
|
|
allstat = json.loads(json.dumps(xmltodict.parse(r.text)['monit']))
|
|
|
|
|
|
|
|
services = allstat['service']
|
|
|
|
status = {}
|
2019-08-14 11:10:54 +00:00
|
|
|
server = {}
|
2019-08-14 11:01:29 +00:00
|
|
|
checks = OrderedDict()
|
2017-01-07 11:46:50 +00:00
|
|
|
|
|
|
|
for service in services:
|
|
|
|
name = service['name']
|
|
|
|
status[name] = int(service['status'])
|
2019-08-14 11:10:54 +00:00
|
|
|
checks[name] = status[name]
|
2017-01-07 11:46:50 +00:00
|
|
|
|
2019-08-14 11:01:29 +00:00
|
|
|
sorted_checks = OrderedDict()
|
|
|
|
sorted_checks = OrderedDict(sorted(checks.iteritems(), key=itemgetter(1), reverse=True))
|
2019-10-25 15:48:24 +00:00
|
|
|
count = calculate_count(sorted_checks)
|
|
|
|
server = dict(name=site, url=s['url'], result=sorted_checks, s_rate=count)
|
2017-01-07 11:46:50 +00:00
|
|
|
|
|
|
|
output.append(server)
|
|
|
|
|
|
|
|
print(datetime.datetime.now())
|
2019-08-22 08:52:18 +00:00
|
|
|
output.append({'url': u'https://monit.xxx.xxx', 'result': OrderedDict([(u'staging', 32), (u'monitoring1', 0)]), 's_rate': {'green': 70.0, 'red': 30.0}, 'name': u'MY Environment2'})
|
2019-10-25 15:14:40 +00:00
|
|
|
output.append({'url': u'https://monit.xxx.xxx', 'result': OrderedDict([(u'staging', 0), (u'monitoring1', 0)]), 's_rate': {'green': 100.0, 'red': 0.0}, 'name': u'MY Environment3'})
|
2017-01-07 11:46:50 +00:00
|
|
|
return(output)
|
|
|
|
|
2017-01-07 12:53:08 +00:00
|
|
|
# Classes
|
|
|
|
|
2017-01-07 11:46:50 +00:00
|
|
|
class monitDashboard(web.application):
|
2017-01-07 12:53:08 +00:00
|
|
|
|
2017-01-07 11:46:50 +00:00
|
|
|
def run(self, port=8080, *middleware):
|
|
|
|
func = self.wsgifunc(*middleware)
|
|
|
|
return web.httpserver.runsimple(func, ('0.0.0.0', port))
|
|
|
|
|
2017-01-07 12:53:08 +00:00
|
|
|
|
2017-01-07 11:46:50 +00:00
|
|
|
class index(object):
|
2017-01-07 12:53:08 +00:00
|
|
|
|
2017-01-07 11:46:50 +00:00
|
|
|
def GET(self):
|
2017-01-07 12:53:08 +00:00
|
|
|
return render.index(output=getMonit(), now=datetime.datetime.now())
|
|
|
|
|
2017-01-07 11:46:50 +00:00
|
|
|
|
|
|
|
class help(object):
|
2017-01-07 12:53:08 +00:00
|
|
|
|
2017-01-07 11:46:50 +00:00
|
|
|
def GET(self):
|
|
|
|
return render.help()
|
|
|
|
|
2017-01-07 12:53:08 +00:00
|
|
|
# Main
|
2017-01-07 11:46:50 +00:00
|
|
|
if __name__ == "__main__":
|
|
|
|
app = monitDashboard(urls, globals())
|
|
|
|
app.run(port=8080)
|