python+flask做的简单的监控系统

#coding=utf-8 import MySQLdb as mysql import json from app import RequestUtil from flask import Flask, request, render_template app = Flask(__name__) db = mysql.connect(user="root", passwd="", db="monitor", charset="utf8", host="localhost") db.autocommit(True) c = db.cursor() t1_time = 0 t2_time = 0 t3_time = 0 @app.route("/", methods=["GET", "POST"]) def index(): if request.method == "POST": data = request.json try: sql = "INSERT INTO `stat` (`host`,`mem_free`,`mem_usage`,`mem_total`,`load_avg`,`time`) VALUES('%s', '%d', '%d', '%d', '%s', '%d')" % (data['Host'], data['MemFree'], data['MemUsage'], data['MemTotal'], data['LoadAvg'], int(data['Time'])) ret = c.execute(sql) except mysql.IntegrityError: pass return "OK" else: try: sql = "select * from host order by add_time desc" c.execute(sql) host_all = [] host_all = c.fetchall() except: pass return render_template('index.html', host_all = host_all) @app.route('/api/add', methods=['GET', 'POST']) def add_host(): add_time = RequestUtil.now_datetime() host = RequestUtil.get_parameter(request, 'host', '') if host: sql = "insert into host (ip, add_time) values ('%s', '%s')" % (host,add_time) c.execute(sql) # 提交到数据库执行 insert_id = c.lastrowid if insert_id: rst = {'success': 1, 'data': ''} else: rst = {'success': 0, 'data': 'add host error'} return RequestUtil.object_2_dict(rst) @app.route('/api/del', methods=['GET', 'POST']) def del_host(): ip = RequestUtil.get_parameter(request, 'id', '') if ip: sql = "delete from host where id='%s'" %(id) c.execute(sql) delete_id = c.lastrowid if delete_id: rst = {'success': 1, 'data': ''} else: rst = {'success': 0, 'data': 'del redis error'} return RequestUtil.object_2_dict(rst) @app.route('/monitor/load', methods=['GET']) def load(): ip = RequestUtil.get_parameter(request, 'ip', '') return render_template('top.html',ip=ip) @app.route('/monitor/mem_free', methods=['GET']) def free(): ip = RequestUtil.get_parameter(request, 'ip', '') return render_template('mem_free.html',ip=ip) @app.route('/monitor/mem_used', methods=['GET']) def used(): ip = RequestUtil.get_parameter(request, 'ip', '') return render_template('mem_used.html',ip=ip) @app.route('/test', methods=['GET']) def test(): return flask.render_template("test.html") @app.route('/test1', methods=['GET', 'POST']) def test(): if request.method == 'POST': print request.form.get('id') return "ok" else: return request.form.get('abc') @app.route('/data1') def data1(): ip = RequestUtil.get_parameter(request, 'ip', '') global t1_time if t1_time>0: sql = "select mem_usage,time from stat where time>%s and host='%s'" % (t1_time/1000,ip) else: sql = "select mem_usage,time from stat where host='%s'" %(ip) c.execute(sql) arr = [] for i in c.fetchall(): arr.append([i[1]*1000,i[0]]) if len(arr)>0: t1_time = arr[-1][0] return json.dumps(arr) @app.route('/data2') def data2(): ip = RequestUtil.get_parameter(request, 'ip', '') global t2_time if t2_time>0: sql = "select mem_free,time from stat where time>%s and host='%s'" % (t2_time/1000,ip) else: sql = "select mem_free,time from stat where host='%s'" %(ip) c.execute(sql) arr = [] for i in c.fetchall(): arr.append([i[1]*1000,i[0]]) if len(arr)>0: t2_time = arr[-1][0] return json.dumps(arr) @app.route('/data3') def data3(): ip = RequestUtil.get_parameter(request, 'ip', '') name = RequestUtil.get_parameter(request, 'name', '') global t3_time if t3_time>0: sql = "select load_avg,time from stat where time>%s and host='%s'" % (t3_time/1000,ip) else: sql = "select load_avg,time from stat where host='%s'" %(ip) c.execute(sql) arr = [] brr = [] drr = [] for i in c.fetchall(): a = float(i[0].split(',')[0]) b = float(i[0].split(',')[1]) d = float(i[0].split(',')[2]) arr.append([i[1]*1000,a]) brr.append([i[1]*1000,b]) drr.append([i[1]*1000,d]) if len(arr)>0: #t_time = arr[-1][0] if name == "avg1": return json.dumps(arr) elif name == "avg5": return json.dumps(brr) else: return json.dumps(drr) if __name__ == "__main__": app.run(host="0.0.0.0", port=8080, debug=True)