python执行shell获取硬件参数写入mysql的方法
本文实例讲述了python执行shell获取硬件参数写入mysql的方法。分享给大家供大家参考。具体分析如下：
最近要获取服务器各种参数，包括cpu、内存、磁盘、型号等信息。试用了HypericHQ、Nagios和Snmp，它们功能都挺强大的，但是于需求不是太符，亦或者太heavy。
于是乎想到用python执行shell获取这些信息，python执行shell脚本有以下三种方法：
1.os.system()
os.system('ls')
#返回结果0或者1，不能得到命令的输出2.os.popen()
output=os.popen('ls')
printoutput.read()
#打印出的是命令输出，但是得不到执行的返回值3.commands.getstatusoutput()
(status,output)=commands.getstatusoutput('ls')
printstatus,output
#打印出返回值和命令输出可以根据需要选取其中一种方法，以下是python执行shell获取硬件参数写入mysql，并定期更新的程序：
''' CreatedonDec10,2014
@author:liufei ''' #coding=utf-8 importtime,sched,os,string fromdatetimeimportdatetime importMySQLdb s=sched.scheduler(time.time,time.sleep)
defevent_func(): try: #主机名 name=os.popen("""hostname""").read() #cpu数目 cpu_num=os.popen("""cat/proc/cpuinfo|grepprocessor|wc-l""").read() #内存大小 mem=os.popen("""free|grepMem|awk'{print$2}'""").read() #机器品牌 brand=os.popen("""dmidecode|grep'Vendor'|head-1|awk-F:'{print$2}'""").read() #型号 model=os.popen("""dmidecode|grep'ProductName'|head-1|awk-F:'{print$2}'""").read() #磁盘大小 storage=os.popen("""fdisk-l|grep'Disk/dev/sd'|awk'BEGIN{sum=0}{sum=sum+$3}END{printsum}'""").read() #mac地址 mac=os.popen("""ifconfig-a|grepHWaddr|head-1|awk'{print$5}'""").read() name=name.replace("\n","").lstrip() cpu_num= cpu_num.replace("\n","").lstrip() memory_gb=round(string.atof(mem.replace("\n","").lstrip())/1000.0/1000.0,1) brand=brand.replace("\n","").lstrip() model=model.replace("\n","").lstrip() storage_gb=storage.replace("\n","").lstrip() mac=mac.replace("\n","").lstrip() printname printcpu_num printmemory_gb printstorage_gb printbrand printmodel printmac conn=MySQLdb.connect(host='xx.xx.xx.xx',user='USERNAME',passwd='PASSWORD',db='DBNAME',port=3306) cur=conn.cursor() cur.execute('selectmacfromserverswheremac=%s',mac) data=cur.fetchone()
ifdataisNone: value=[name,brand,model,memory_gb,storage_gb,cpu_num,mac,datetime.now(),datetime.now()] cur.execute("insertintoservers(name,brand,model,memory_gb,storage_gb,cpu_num,mac, created_at,updated_at)values(%s,%s,%s,%s,%s,%s,%s,%s,%s)",value) else: value1=[name,brand,model,memory_gb,storage_gb,cpu_num,datetime.now(),mac] cur.execute("updateserverssetname=%s,brand=%s,model=%s,memory_gb=%s,storage_gb=%s,cpu_num=%s,updated_at=%swheremac=%s",value1) conn.commit() cur.close() conn.close() exceptMySQLdb.Error,e: print"MysqlError%d:%s"%(e.args[0],e.args[1]) defperform(inc): s.enter(inc,0,perform,(inc,)) event_func() defmymain(inc=10): s.enter(0,0,perform,(inc,)) s.run() if__name__=="__main__": mymain()