实现Python连接Mysqln以及应用
python 连接mysql数据库,是python应用的一个非常重要的模块,Pytho连接Mysqln需要连接导入python的mysql模块,通过python连接数据库,我们可以实现对本地的资源状态实现实时监控。
1、首先我们需要先安装MySQL模块
代码语言:javascript复制[root@centos mem]# yum install MySQL-python -y
2、接下来我们就可以直接脚本了
代码语言:javascript复制[root@centos pytonjiaoben]# cat mysql.py
import MySQLdb as mysql ###这是导入 MySQL-python模块
con = mysql.connect(user="root", passwd="123456",
db="mem", host="127.0.0.1") ###连接本地的数据库mem,指定数据库的名称,主机地址,用户名和密码
con.autocommit(True) ###设置为自动提交模式,表示把每一个查询操作,作为1个独立的事务处理,马上执行
cur = con.cursor() ###创建1个游标对象
for i in range(10): ###这里做个for循环写入数据
sql = 'insert into mem values(%d, "user%d")'%(i,i) ###定义sql语句
cur.execute(sql) ##执行sql语句
注意:
##数据库和数据表必须是你先创建的,而且mysql一定要设置密码才行。
3、执行结果
代码语言:javascript复制mysql> select * from mem;
------ ---------
| id | name |
------ ---------
| 0 | user0 |
| 1 | user1 |
| 2 | user2 |
| 3 | user3 |
| 4 | user4 |
| 5 | user5 |
| 6 | user6 |
| 7 | user7 |
| 8 | user8 |
| 9 | user9 |
当我们执行脚本后,我们发现数据已经写得数据库里面了
4、现在我们可能会有疑问,这样写进去又有什么用,那好,我们接着写个脚本,关于mysql的应用的。现在我们对服务器的内存使用情况,写入到mysql上,写得mysql上就可以通过flask调用,实现对本地资源实现监控。
我们查看一下我们内存文件
代码语言:javascript复制[root@centos pytonjiaoben]# cat /proc/meminfo
MemTotal: 1528700 kB
MemFree: 224072 kB
Buffers: 130432 kB
Cached: 604432 kB
SwapCached: 8440 kB
6、编写脚本,获取内存的使用量
代码语言:javascript复制[root@centos pytonjiaoben]# cat mem/mysql.py
# -*- coding:utf-8 -*-
import time
import os
import MySQLdb as mysql
db = mysql.connect(user="root", passwd="123456", db="memory", host="localhost")
db.autocommit(True)
cur=db.cursor()
def saveMem(): ##获取memory的total、free、buff的量
a="awk 'NR==1{print $2}' /proc/meminfo"
file = os.popen(a)
total=int(file.read())
b="awk 'NR==2{print $2}' /proc/meminfo"
file =os.popen(b)
free =int(file.read())
c="awk 'NR==3{print $2}' /proc/meminfo"
file = os.popen(c)
buffer =int(file.read())
d="awk 'NR==4{print $2}' /proc/meminfo"
file =os.popen(d)
cache =int(file.read())
mem_used=total-free-buffer-cache
print mem_used/1024
#mem = mem_used/1024
cur_time = int(time.time())
sql = 'insert into memory (memory, time) value (%s,%s)'%(mem_used,cur_time)
cur.execute(sql)
while True:
saveMem()
time.sleep(1) # sleep 1 second
7、查看结果
代码语言:javascript复制[root@centos pytonjiaoben]# python mem/mysql.py
562
563
563
563
###查看数据库
代码语言:javascript复制mysql> select * from memory;
-------- ------------
| memory | time |
-------- ------------
| 577012 | 1511869204 |
| 577004 | 1511869205 |
| 576872 | 1511869206 |
-------- ------------
8、我们会发现它会实时获取内存的使用情况,这样我们的目的也达到了,只要有数据输入到mysql中,接下来只要通过flask调用,做成图,就可以实现监控了。