python监控进程状态,记录重启时间及进程号的实例
本脚本为本人在性能测试过程中编写，用于对进程状态的监控，也可以用于日常的监控，适用性一般，扩展性还行
#-*-coding:UTF-8-*-
#author=baird_xiang
importos
importtime
importre
importcopy
nginxRestart_num=-1
nginxReload_num=-1
logSender_num=-1
es_num=-1
nginxParent_pid=[]
nginxChild_pid=[]
logSender_pid=[]
es_pid=[]
nginxRestart_time=[]
nginxReload_time=[]
logSender_time=[]
es_time=[]
defget_restart(thread_name):
globalnginxRestart_num,nginxReload_num,logSender_num,es_num
whileTrue:
try:
foriinthread_name:
ifi=='nginx_restart':
nP_pid=os.popen("sudopgrep-longinx|grep-vgrep|awk'{print$1}'").read()
nP_time=os.popen("sudopsaux|grepnginx|grep-vgrep|awk'NR==1{print$9}'").read()
nginx_path=os.popen("sudopsaux|grepnginx|grep-vgrep|awk'NR==1{print$11}'").read()
date=time.strftime('%Y-%m-%d',time.localtime(time.time()))
nP_time_now=date+'-'+nP_time.split('\n')[0]
ifnP_pidand(nP_pidnotinnginxParent_pid)and(nginx_path=='/usr/sbin/nginx\n'):
nginxParent_pid.append(nP_pid)
nginxRestart_num=nginxRestart_num+1
#ifnP_timeand(nP_time_nownotinnginxRestart_time)and(color!='-c\n'):
nginxRestart_time.append(nP_time_now)
elifi=='nginx_reload':
nR_pid=os.popen("sudopgrep-lnnginx|grep-vgrep|awk'{print$1}'").read()
nR_time=os.popen("sudopsaux|grepnginx|grep-vgrep|awk'NR==2{print$9}'").read()
nginx_path=os.popen("sudopsaux|grepnginx|grep-vgrep|awk'NR==1{print$11}'").read()
date=time.strftime('%Y-%m-%d',time.localtime(time.time()))
nR_time_now=date+'-'+nR_time.split('\n')[0]
ifnR_pidand(nR_pidnotinnginxChild_pid)and(nginx_path=='/usr/sbin/nginx\n'):
nginxChild_pid.append(nR_pid)
nginxReload_num=nginxReload_num+1-nginxRestart_num
#ifnR_timeand(nR_time_nownotinnginxReload_time)and(color!='-c\n'):
nginxReload_time.append(nR_time_now)
elifi=='log_sender':
lS_pid=os.popen("sudopsaux|greplog_sender|grep-vgrep|awk'NR==1{print$2}'").read()
lS_time=os.popen("sudopsaux|greplog_sender|grep-vgrep|awk'NR==1{print$9}'").read()
color=os.popen("sudopsaux|greplog_sender|grep-vgrep|awk'NR==1{print$12}'").read()
wwwdate=os.popen("sudopsaux|greplog_sender|grep-vgrep|awk'NR==1{print$1}'").read()
date=time.strftime('%Y-%m-%d',time.localtime(time.time()))
lS_time_now=date+'-'+lS_time.split('\n')[0]
iflS_pidand(color!='-c\n')and(lS_pidnotinlogSender_pid)and(wwwdate=='www-data\n'):
logSender_pid.append(lS_pid)
logSender_num=logSender_num+1
#iflS_timeand(lS_time_nownotinlogSender_time)and(color!='-c\n'):
logSender_time.append(lS_time_now)
elif(i=='elasticsearch')and(os.popen("sudops-ef|grepelasticsearch|grep-vgrep|awk'NR==1{print$2}'").read()):
time.sleep(1)
e_pid=os.popen("sudopsaux|grepelasticsearch|grep-vgrep|awk'NR==1{print$2}'").read()
e_time=os.popen("sudopsaux|grepelasticsearch|grep-vgrep|awk'NR==1{print$9}'").read()
color=os.popen("sudopsaux|grepelasticsearch|grep-vgrep|awk'NR==1{print$12}'").read()
elastic=os.popen("sudopsaux|grepelasticsearch|grep-vgrep|awk'NR==1{print$1}'").read()
date=time.strftime('%Y-%m-%d',time.localtime(time.time()))
e_time_now=date+'-'+e_time.split('\n')[0]
ife_pidand(color!='-c\n')and(e_pidnotines_pid)and(elastic=='elastic+\n'):
es_pid.append(e_pid)
es_num=es_num+1
#ife_timeand(e_time_nownotines_time)and(color!='-c\n')and(elastic=='elastic+\n'):
es_time.append(e_time_now)
else:
pass
except(OSError,IOError):#防止进入循环但是这个时候进程重启，导致popen读取不到进程信息就会出错
pass
defset_nginxRestart_txt():
now_path=os.getcwd()
file_name=now_path+'/nginxRestart_%s.txt'%(nginxRestart_time[-1])
#写入文本
file1=open(file_name,'w')
foriinrange(1,len(nginxRestart_time)):
file1.write('重启时间：'+nginxRestart_time[i]+'重启前父进程号:'+nginxParent_pid[i-1]+'重启后父进程号:'+nginxParent_pid[i]+'\n')
file1.close()
file2=open(file_name,'a+')
file2.write('nginxrestart次数为：'+str(nginxRestart_num)+'\n')
file2.close()
defset_nginxReload_txt():
now_path=os.getcwd()
file_name=now_path+'/nginxReload_%s.txt'%(nginxReload_time[-1])
#写入文本
file1=open(file_name,'w')
foriinrange(1,len(nginxReload_time)):
file1.write('重启时间：'+nginxReload_time[i]+'\n')
file1.close()
file2=open(file_name,'a+')
file2.write('nginxreload次数为：'+str(nginxReload_num)+'\n')
file2.close()
defset_logsender_txt():
now_path=os.getcwd()
file_name=now_path+'/logsender_restart_%s.txt'%(logSender_time[-1])
#写入文本
file1=open(file_name,'w')
foriinrange(1,len(logSender_time)):
file1.write('重启时间：'+logSender_time[i]+'重启前进程号:'+logSender_pid[i-1]+'重启后进程号:'+logSender_pid[i]+'\n')
file1.close()
file2=open(file_name,'a+')
file2.write('logsender重启次数为:'+str(logSender_num)+'\n')
file2.close()
defset_es_txt():
now_path=os.getcwd()
file_name=now_path+'/esRestart_%s.txt'%(es_time[-1])
#写入文本
file1=open(file_name,'w')
foriinrange(1,len(es_time)):
file1.write('重启时间：'+es_time[i]+'重启前进程号:'+es_pid[i-1]+'重启后进程号:'+es_pid[i]+'\n')
file1.close()
file2=open(file_name,'a+')
file2.write('elasticsearch重启次数为：'+str(es_num)+'\n')
file2.close()
if__name__=="__main__":
thread_name=['nginx_restart','nginx_reload','log_sender','elasticsearch']
try:
get_restart(thread_name)
except(KeyboardInterrupt,SystemExit):
set_nginxRestart_txt()
set_nginxReload_txt()
set_logsender_txt()
set_es_txt()
以上这篇python监控进程状态,记录重启时间及进程号的实例就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持毛票票。