使用python编写一个监控使用内存并使用flask模块出图

使用python编写一个监控使用内存情况的网页界面

1. 获取内存信息

[root@cml10 web_mem]# cat /proc/meminfo
MemTotal:        1001332 kB
MemFree:          147800 kB
MemAvailable:     257776 kB
Buffers:               0 kB
Cached:           201032 kB

2. 存储信息

[root@cml10 web_mem]# yum  install  -y  mariadb-server  mariadb

[root@cml10 web_mem]# systemctl start mariadb

[root@cml10 web_mem]# mysql_secure_installation

[root@cml10 web_mem]#  mysql  -uroot  -predhat
mysql> create database  mem;
mysql> use mem;
mysql> create table mem (mem int(10), date int(20));

[root@cml10 web_mem]# cat save_mem.py
#_*_coding:utf-8_*_

import time
import MySQLdb as mysql

db = mysql.connect(user="root",passwd="redhat",db="mem",host="localhost")

db.autocommit(True)  #自动提交模式，把每个查询都当做一个单独的事务自动执行
cur = db.cursor()   #获取一个 “游标”，用来执行sql语句

def save_mem():
f = open("/proc/meminfo")
total = int(f.readlines()[0].split()[1])
f = open("/proc/meminfo")
aviable = int(f.readlines()[2].split()[1])
mem = (total-aviable)/1024              # unit: MB（把已用内存转成MB单位）
cur_time = int(time.time())
sql = 'insert into mem(mem,date) values(%s,%s)' %(mem,cur_time)
cur.execute(sql)
while True:
save_mem()
time.sleep(1)                              # sleep 1 second（等待一秒时间）

s1 = "Today is good   day! "
s2 = s1 * 10000

for i in range(1,100):
for j in range(1,100):
s2.count(s1)

3. 展示信息构建web服务

安装flask

[root@cml10 web_mem]# cd  /usr/local/src
[root@cml10 src]# wget  --no-check-certificate  https://bootstrap.pypa.io/get-pip.py [root@cml10 src]# python  get-pip.py

[root@cml10 src]# pip  install  flask

编辑后台页面

[root@cml10 web_mem]# flask_web.py
from  flask  import  Flask    #导入flask中的Flask模块=import flask 引用时要flask.Flask

app = Flask(__name__)  #产生一个flask实例，即一个网站应用程序。

@app.route('/')   #表示访问网站的根目录时，触发函数index()
def index():
return 'hello flask'

if __name__=='__main__':     #指的是只能自己运行的才可以运行网站。
app.run(host='0.0.0.0', port=9092, debug=True)
#任意主机可以访问，使用9092端口，启用调试模式

[root@cml10 web_mem]# systemctl stop firewalld

[root@cml10 web_mem]# python   flask_web.py

使用真实数据渲染图标

[root@cml10 web_mem]# cat flask_web.py
#_*_coding:utf-8_*_
from flask import Flask,render_template
import MySQLdb as mysql
import json

con = mysql.connect(user="root",passwd="redhat",db="mem",host="localhost")
con.autocommit(True)
cur = con.cursor()

app = Flask(__name__)

last_time = 0

@app.route('/')
def index():
#     return "cml test"
return render_template('index.html')

@app.route('/cml')
def cml():
global last_time
if (last_time > 0):
sql = 'select * from mem where date > %s' %(last_time/1000)
else:
sql = 'select * from mem'
cur.execute(sql)
arr = []
for i in cur.fetchall():
#            print i
arr.append([i[1]*1000,i[0]])
#     return "ok"
if (len(arr) > 0):
last_time = arr[-1][0]
return json.dumps(arr)

if __name__=='__main__':
app.run(host='0.0.0.0',port=9092,debug=True)

动静态文件分离和使用图表展现

测试图表显示

[root@cml10 web_mem]# mkdir  static
[root@cml10 web_mem]# cp   jquery.js  highstock.js   static

[root@cml10 web_mem]# tree
.
├── flask_web.py
├── save_mem.py
├── static
│   ├── highstock.js
│   └── jquery.js
└── templates
└── index.html

2 directories, 5 files

[root@cml10 web_mem]# cat templates/index.html
from flask import Flask,render_template
import MySQLdb as mysql
import  json

con = mysql.connect(user="root", passwd="redhat", db="mem", host="localhost")
con.autocommit(True)
cur = con.cursor()

app = Flask(__name__)

@app.route('/')
def index():
#return 'cml test'
return render_template('index.html')

@app.route('/cml')
def cml():
sql = 'select * from memory'
cur.execute(sql)
arr = []
for i in cur.fetchall():
#print i
arr.append([i[1]*1000, i[0])   #如果写入数据库使没转这里可以，除以1024，以MB为单位
#return 'ok'
return json.dumps(arr)

if __name__=='__main__':
app.run(host='0.0.0.0', port=9092, debug=True)

[root@cml10 web_mem]# python save_mem.py
[root@cml10 web_mem]# python flask_web.py

4. 扩展获取增量数据

[root@cml10 web_mem]# cat flask_web.py
#_*_coding:utf-8_*_
from flask import Flask,render_template
import MySQLdb as mysql
import json

con = mysql.connect(user="root",passwd="redhat",db="mem",host="localhost")
con.autocommit(True)
cur = con.cursor()

app = Flask(__name__)

last_time = 0

@app.route('/')
def index():
#     return "cml test"
return render_template('index.html')

@app.route('/cml')
def cml():
global last_time
if (last_time > 0):
sql = 'select * from mem where date > %s' %(last_time/1000)
else:
sql = 'select * from mem'
cur.execute(sql)
arr = []
for i in cur.fetchall():
#            print i
arr.append([i[1]*1000,i[0]])
#     return "ok"
if (len(arr) > 0):
last_time = arr[-1][0]           ##意思是取最新的值
return json.dumps(arr)

if __name__=='__main__':
app.run(host='0.0.0.0',port=9092,debug=True)

[root@cml10 web_mem]# cat templates/index.html
<html>
<head>
<title> my memory monitor </title>
</head>

<body>
<div id="container" style="min-width:400px;height:400px"></div>

<script src='/static/jquery.js'></script>
<script src='/static/highstock.js'></script>
<script type="text/javascript">
Highcharts.setOptions({ global: { useUTC: false } });
</script>
<script>
$(function () {
$.getJSON('/cml', function (cml) {
$('#container').highcharts('StockChart', {
chart: {
events: {
load:function() {
var series = this.series[0]
setInterval(
// 表示每隔3000ms(参数2),就执行指定的函数(参数1)
function(){
$.getJSON('/cml',function(res){
$.each(res, function(i,v){
series.addPoint(v)
})
})
},
3000)
}
}
},

rangeSelector : {
selected : 1
},
title : {
text : '服务器以用内存使用情况'
},
series : [{
name : 'AAPL',
data : cml,
tooltip: {
valueDecimals: 2
}
}]
});
});
});

</script>
</body>
</html>