第python監(jiān)控某個(gè)進(jìn)程內(nèi)存的情況問(wèn)題目錄python監(jiān)控某個(gè)進(jìn)程內(nèi)存python監(jiān)控進(jìn)程并重啟分析了具體思路相關(guān)代碼很簡(jiǎn)單

python監(jiān)控某個(gè)進(jìn)程內(nèi)存

測(cè)試場(chǎng)景：

某個(gè)客戶端程序長(zhǎng)時(shí)間運(yùn)行后存在內(nèi)存泄漏問(wèn)題，現(xiàn)在開發(fā)解決了需要去驗(yàn)證這個(gè)問(wèn)題是否還存在，并要求出具相應(yīng)測(cè)試驗(yàn)證報(bào)告。

手段：

需要有一個(gè)工具能夠?qū)崟r(shí)去獲取該程序進(jìn)程一直運(yùn)行下占用內(nèi)存，CPU使用率情況。

方法：

python去實(shí)現(xiàn)這么個(gè)監(jiān)控功能

importsys

importtime

importpsutil

sys.argv

#getpidfromargs

#獲取命令行輸入的參數(shù)個(gè)數(shù),sys.ary是一個(gè)列表

#如果列表參數(shù)2，說(shuō)明只輸入了python文件名稱.py,則退出不繼續(xù)運(yùn)行

iflen(sys.argv)2:

print("沒(méi)有輸入要監(jiān)控的進(jìn)程編號(hào)")

sys.exit()

#獲取進(jìn)程

print("打印進(jìn)程號(hào):"+sys.argv[1])

pid=int(sys.argv[1])

p=psutil.Process(pid)

#監(jiān)控進(jìn)程并將獲取CPU,內(nèi)存使用情況寫入csv文件中

interval=60#獲取CPU，內(nèi)存使用情況輪詢時(shí)間間隔

num=100

withopen("process_monitor_"+()+'_'+str(pid)+".csv","a+")asf:

f.write("時(shí)間,cpu使用率（%）,內(nèi)存使用率（%）,內(nèi)存使用值MB\n")#csv文件表頭列名：time,cpu使用率,內(nèi)存使用率,內(nèi)存占用值MB

whilenum0:

num=num-1

current_time=time.strftime('%Y%m%d-%H%M%S',time.localtime(time.time()))

cpu_percent=p.cpu_percent()#bettersetintervalsecondtocalculatelike:p.cpu_percent(interval=0.5)

mem_percent=p.memory_percent()

mem_info=p.memory_info().rss

mem_MB=4096/mem_percent

print('當(dāng)前進(jìn)程的內(nèi)存使用：',mem_info)

print('當(dāng)前進(jìn)程的內(nèi)存使用：%.4fMB'%mem_MB)

line=current_time+','+str(cpu_percent)+','+str(mem_percent)+','+str(mem_MB)

print(line)

f.write(line+"\n")

time.sleep(interval)

python監(jiān)控進(jìn)程并重啟

最近公司的游戲服務(wù)器經(jīng)常掉線，老板只能讓員工不定時(shí)登陸服務(wù)器看死掉沒(méi)有，都快成機(jī)器人了，因此python自動(dòng)化監(jiān)測(cè)進(jìn)程運(yùn)用腳本就產(chǎn)生了。

分析了具體思路

1.做個(gè)線程定時(shí)器，每隔20s執(zhí)行系統(tǒng)命令查詢指定進(jìn)程名稱是否存在

2.如果不存在，就重啟；不存在就不進(jìn)行后續(xù)的操作。

相關(guān)代碼很簡(jiǎn)單

defrestart_process(process_name):

red=subprocess.Popen('tasklist',stdout=subprocess.PIPE,stderr=subprocess.PIPE,shell=True)

tasklist_str=red.stdout.read().decode(encoding='gbk')

re_path=process_name.split("\\")[-1]

formattime=datetime.datetime.now().strftime('%Y-%m-%d%H:%M:%S')

ifre_pathnotintasklist_str:

#obj=connect_emai()

#sendmail('程序卡掉正在重啟。。。',obj)

#發(fā)送HTTP請(qǐng)求

#url="48/server_offline.html"

#request=urllib.request(url)

globalcount

count+=1

print(formattime+'第'+str(count)+'次檢測(cè)發(fā)現(xiàn)異常重連')

cmd=process_name

os.system(process_name)

#res=subprocess.Popen(cmd,stdout=subprocess.PIPE,stderr=subprocess.PIPE,shell=True)

#print(res.stderr.read().decode(encoding='gbk'),res.stdout.read().decode(encoding='gbk'))

#sendmail('重啟連接成功！',obj)

print('yes,connected')

else:

globalerror_count

error_count+=1

print(formattime+'第'+str(error_count)+'次檢測(cè)正在運(yùn)行中')

globaltimer

timer=Timer(20,restart_process,("startC:\Progra~1\CloudControlServer\CloudControlServer.exe",))

timer.start()

count=0

error_count=0

timer=Timer(20,restart_process,("startC:\Progra~1\CloudControlServer\CloudControlServer.exe",))

timer.start()

搞定！！！

接下來(lái)有了新的需求~~需要監(jiān)控CPU的運(yùn)行狀態(tài)，如果CPU一直維持在80%以上就主動(dòng)殺死進(jìn)程，并重啟進(jìn)程,使用了牛逼的psutil跨系統(tǒng)平臺(tái)操作庫(kù)。實(shí)現(xiàn)代碼如下：

deflook_cpu(process_name):

res=subprocess.Popen('wmiccpugetLoadPercentage',stdout=subprocess.PIPE,stderr=subprocess.PIPE,shell=True)

res_str=res.stdout.read().decode(encoding='gbk')

num=re.findall('\d+',res_str)[0]

ifint(num)80:

print('cup負(fù)載超過(guò)10%')

time.sleep(10)

res_twice=subprocess.Popen('wmiccpugetLoadPercentage',stdout=subprocess.PIPE,stderr=subprocess.PIPE,

shell=True)

res_twice_str=res_twice.stdout.read().decode(encoding='gbk')

num_twice=re.findall('\d+',res_twice_str)[0]

#判斷兩次監(jiān)測(cè)穩(wěn)定在5%以內(nèi)殺死進(jìn)程并重啟

ifabs(int(num)-int(num_twice))5:

tasklist=subprocess.Popen('tasklist|findstrCloudControlServer.exe',stdout=subprocess.PIPE,

stderr=subprocess.PIPE,shell=True)

res=tasklist.stdout.read().decode(encoding='gbk')

pid=re.search('\d{1,4}',res).group()

cmd='taskkill-f/pid%s'%pid

time.sleep(0.5)

print(cmd)

os.system('taskkill-f/pid%s'%pid)

os.system(process_name)

print('正在監(jiān)測(cè)cpu，cpu占用率：%s'%num)

globaltimer

timer=Timer(30,look_cpu,("startC:\Progra~1\CloudControlServer\CloudControlServer.exe",))

timer.start()

但是第三天老板有了新的需求，需要做個(gè)web端將CPU和內(nèi)存信息開放api并且支持遠(yuǎn)程重啟，我的思路是利用python自帶的http服務(wù)類庫(kù)，省去了socket編程的麻煩，直接輸入IPport即可，這里使用了wsgiref.simple_server

#web服務(wù)應(yīng)用函數(shù)

defapplication(environ,start_response):

path=environ.get('PATH_INFO')

start_response('200OK',[])

#提供cpu狀態(tài)信息

ifpath=='/cpu':

res=subprocess.Popen('wmiccpugetLoadPercentage',stdout=subprocess.PIPE,stderr=subprocess.PIPE,

shell=True)

res_str=res.stdout.read().decode(encoding='gbk')

resp={'cpu':re.findall('\d+',res_str)[0]}

return[json.dumps(resp).encode(encoding='utf-8')]

#提供cpu+memory信息

elifpath=='/state':

cpu=psutil.cpu_percent()

memory=psutil.virtual_memory()

memory_lv=float(memory.used)/float(memory.total)*100

res={'cpu':cpu,'memory':memory_lv}

return[json.dumps(res).encode(encoding='utf-8')]

#提供重啟進(jìn)程api

elifpath=='/restart_process':

#os.system('shutdowm.exe-r')

res=remote_restart_process("startC:\Progra~1\CloudControlServer\CloudContr