本主題主要考察的是python os模組呼叫linux命令、模組、函式呼叫以及通過python操縱資料庫。

假設已經可以正常連線mysql資料庫了，儲存系統資訊的資料庫名稱為hostinfo,相關的四個資料表分別名為cpuinfo、meminfo、diskinfo、loadinfo（資料庫和表都是程式執行過程中自動建立的）

1.在開發目錄下新建一個python的包，然後包含四個python檔案：mem.py、load.py、disk.py、cpu.py以及一個程式執行的主檔案main.py，結構如下：

2. 編寫mem.py 檔案

import os
def mem_usage
 
():
    f = os.popen("free -m |grep Mem |awk '{print $2,$3,$4}'")
    return f.read()

if __name__ == "__main__":
    print  mem_usage()

3. 編寫load.py檔案

import os
def load_avg():
    f = os.popen("uptime | sed 's/,//g' | awk '{print $8,$9,$10}'")
    return f.read().strip()

if __name__ == "__main__":
    print
 
 load_avg()

4. 編寫disk.py檔案

import os
def disk_usage():
    f = os.popen("df -h | head -2 | tail -1 | awk '{print $2,$3,$4,$5}'")
    return f.read().strip()

if __name__ == "__main__":
    print disk_usage()

5. 編寫cpu.py檔案

import os
def cpu_usage():
    f = os.popen("top -bi -n 1| awk '{print $2,$4}'"
 
).read().split('\n')[2]
    return f

if __name__ == "__main__":
    print cpu_usage()

6. 編寫main.py檔案

#!/usr/bin/env python
#coding:utf-8
'''
file:main.py
date:9/8/17 10:21 AM
author:lockey
email:[email protected]
desc:
'''
from __future__ import division
import MySQLdb as mysql
import time
import cpu,disk,load,mem

username = 'root'
password  = 'redhat'
host = 'localhost'
deleteall = False
conn = mysql.connect(host,username,password)
cur = conn.cursor()
sqldisk = 'insert into diskinfo values(%s,%s,%s,%s,%s)'
sqlmem = 'insert into meminfo values(%s,%s,%s,%s)'
sqlcpu = 'insert into cpuinfo values(%s,%s,%s,%s)'
sqlload = 'insert into loadinfo values(%s,%s,%s,%s)'
try:
    cur.execute('CREATE DATABASE hostinfo')
except:
    pass
finally:
    conn.select_db('hostinfo')
    try:
        cur.execute('CREATE TABLE diskinfo (total varchar(10), used varchar(10), avail varchar(10), usedPercent varchar(10), getTime varchar(30))')
        cur.execute('CREATE TABLE meminfo (total varchar (20), used varchar(10), free varchar(10),getTime varchar(30))')
        cur.execute('CREATE TABLE loadinfo (time1 varchar(10), time5 varchar(10), time10 varchar(10), getTime varchar(30))')
        cur.execute('CREATE TABLE cpuinfo (usrused varchar(10), sysused varchar(10), usedPercent varchar(10), getTime varchar(30))')
    except:
        pass
    finally:
            diskuseinfo = disk.disk_usage().split(' ')
            disksize = diskuseinfo[0]
            diskuse = diskuseinfo[1]
            diskfree = diskuseinfo[2]
            diskused = diskuseinfo[3]

            memuseinfos = map(int,mem.mem_usage().split(' '))
            memtotal = memuseinfos[0]
            memused = memuseinfos[1]
            memfree = memuseinfos[2]
            memusedp = str(round(memused/memtotal,5))+'%'
            memfreep = str(round(memfree/memtotal,5))+'%'

            load = load.load_avg().split(' ')
            load1s = load[0]+'%'
            load5s = load[1]+'%'
            load15s = load[2]+'%'



            cpuinfo = cpu.cpu_usage()
            cpuinfo2 = cpuinfo.split(' ')
            cpuusr = cpuinfo2[0]+'%'
            cpusys = cpuinfo2[1]+'%'
            cpuusage = str(float(cpuinfo2[0]) + float(cpuinfo2[1]))+'%'

            timestr = time.time()
            cur.execute(sqldisk,(disksize,diskuse,diskfree,diskused,timestr))
            cur.execute(sqlmem, (memtotal, memusedp, memfreep, timestr ))
            cur.execute(sqlload, (load1s, load5s, load15s, timestr))
            cur.execute(sqlcpu, (cpuusr, cpusys, cpuusage, timestr))
            if deleteall == True:
                cur.execute('drop table cpuinfo')
                cur.execute('drop table meminfo')
                cur.execute('drop table diskinfo')
                cur.execute('drop table loadinfo')
                print 'All tables have been deleted!'
            else:
                cur.execute('select * from cpuinfo')
                cpus = cur.fetchall()
                print cpus

                cur.execute('select * from meminfo')
                mems = cur.fetchall()
                print mems

                cur.execute('select * from diskinfo')
                disks = cur.fetchall()
                print disks

                cur.execute('select * from loadinfo')
                loads = cur.fetchall()
                print loads

            conn.commit()

    cur.close()
    conn.close()
    print 'Database closed!'

執行結果截圖：

當main.py檔案中deleteall = False時的執行結果：

當main.py檔案中deleteall = True時的執行結果：