您好,登錄后才能下訂單哦!
小編給大家分享一下怎么使用Python實(shí)現(xiàn)自動(dòng)化監(jiān)控遠(yuǎn)程服務(wù)器,希望大家閱讀完這篇文章之后都有所收獲,下面讓我們一起去探討吧!
首先我們做一個(gè)定時(shí)或者實(shí)時(shí)腳本timedtask.py,讓其定時(shí)監(jiān)控目標(biāo)服務(wù)器,兩種方式:
第一種:
#!/usr/bin/env python # -*- coding: utf-8 -*- # @Time : 2017/11/27 15:59 # @Desc : 定時(shí)任務(wù),以需要的時(shí)間間隔執(zhí)行某個(gè)命令 # @File : timedtask.py # @Software: PyCharm import time, os from monitorserver import alltask def roll_back(cmd, inc = 60): while True: #執(zhí)行方法,函數(shù) alltask() time.sleep(inc) roll_back("echo %time%", 5)
第二種:
#!/usr/bin/env python # -*- coding: utf-8 -*- # @Time : 2017/11/27 15:59 # @Desc : 定時(shí)任務(wù),以需要的時(shí)間間隔執(zhí)行某個(gè)命令 # @File : timedtask.py # @Software: PyCharm import time, os def roll_back(cmd, inc = 60): while True: #監(jiān)控代碼文件所在位置 os.system('python /home/../monitorserver.py'); time.sleep(inc) roll_back("echo %time%", 5)
做過(guò)監(jiān)控應(yīng)該都知道,我們主要監(jiān)控服務(wù)器,負(fù)載均衡、磁盤(pán)、內(nèi)存、CPU、網(wǎng)絡(luò)接口(流量)、端口代碼,主要針對(duì)這些,我做了以下遠(yuǎn)程監(jiān)控,第一種和第二種監(jiān)控代碼一樣,代碼monitorserver.py如下:
#!/usr/bin/env python # -*- coding: utf-8 -*- # @Time : 2017/11/27 15:59 # @Desc : 服務(wù)器監(jiān)控代碼 # @File : monitorserver.py # @Software: PyCharm import pexpect import re import time import threading """ 主方法 127.0.0.1#遠(yuǎn)程服務(wù)器ip地址 """ def ssh_command(user, host, password, command): ssh_new_key = 'Are you sure you want to continue connecting' child = pexpect.spawn('ssh -l %s %s %s' % (user, host, command)) i = child.expect([pexpect.TIMEOUT, ssh_new_key, 'password: ']) if i == 0: print 'ERROR!' print 'SSH could not login. Here is what SSH said:' print child.before, child.after return None if i == 1: child.sendline('yes') child.expect('password: ') i = child.expect([pexpect.TIMEOUT, 'password: ']) if i == 0: print 'ERROR!' print 'SSH could not login. Here is what SSH said:' print child.before, child.after return None child.sendline(password) return child """ 內(nèi)存監(jiān)控 """ def mem_info(): child = ssh_command("遠(yuǎn)程服務(wù)器用戶(hù)名", "127.0.0.1", "遠(yuǎn)程服務(wù)器密碼", "cat /proc/meminfo") child.expect(pexpect.EOF) mem = child.before mem_values = re.findall("(\d+)\ kB", mem) MemTotal = mem_values[0] MemFree = mem_values[1] Buffers = mem_values[2] Cached = mem_values[3] SwapCached=mem_values[4] SwapTotal = mem_values[13] SwapFree = mem_values[14] print '******************************內(nèi)存監(jiān)控*********************************' print "*******************時(shí)間:", time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()), "******************" print "總內(nèi)存:",MemTotal print "空閑內(nèi)存:", MemFree print "給文件的緩沖大小:",Buffers print "高速緩沖存儲(chǔ)器使用的大小:", Cached print "被高速緩沖存儲(chǔ)用的交換空間大小:", SwapCached print "給文件的緩沖大小:", Buffers if int(SwapTotal) == 0: print u"交換內(nèi)存總共為:0" else: Rate_Swap = 100 - 100*int(SwapFree)/float(SwapTotal) print u"交換內(nèi)存利用率:", Rate_Swap Free_Mem = int(MemFree) + int(Buffers) + int(Cached) Used_Mem = int(MemTotal) - Free_Mem Rate_Mem = 100*Used_Mem/float(MemTotal) print u"內(nèi)存利用率:", str("%.2f" % Rate_Mem), "%" """ 內(nèi)核線程、虛擬內(nèi)存、磁盤(pán)、陷阱和 CPU 活動(dòng)的統(tǒng)計(jì)信息 """ def vm_stat_info(): child = ssh_command("遠(yuǎn)程服務(wù)器用戶(hù)名", "127.0.0.1", "遠(yuǎn)程服務(wù)器密碼", "vmstat 1 2 | tail -n 1") child.expect(pexpect.EOF) vmstat_info = child.before.strip().split() processes_waiting = vmstat_info[0] processes_sleep = vmstat_info[1] swpd = vmstat_info[2] free = vmstat_info[3] buff = vmstat_info[4] cache = vmstat_info[5] si = vmstat_info[6] so = vmstat_info[7] io_bi = vmstat_info[8] io_bo = vmstat_info[9] system_interrupt = vmstat_info[10] system_context_switch = vmstat_info[11] cpu_user = vmstat_info[12] cpu_sys = vmstat_info[13] cpu_idle = vmstat_info[14] cpu_wait = vmstat_info[15] st=vmstat_info[16] print '****************************內(nèi)核線程、虛擬內(nèi)存、磁盤(pán)、陷阱和 CPU 活動(dòng)的統(tǒng)計(jì)信息監(jiān)控****************************' print "*******************時(shí)間:", time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()), "******************" print "等待運(yùn)行進(jìn)程的數(shù)量:", processes_waiting print "處于不間斷狀態(tài)的進(jìn)程:", processes_sleep print "使用虛擬內(nèi)存(swap)的總量:", swpd print "空閑的內(nèi)存總量:", free print "用作緩沖的內(nèi)存總量:", buff print "用作緩存的內(nèi)存總量:", cache print "交換出內(nèi)存總量 :", si print "交換入內(nèi)存總量 :", so print "從一個(gè)塊設(shè)備接收:", io_bi print "發(fā)送到塊設(shè)備:", io_bo print "每秒的中斷數(shù):", system_interrupt print "每秒的上下文切換數(shù):", system_context_switch print "用戶(hù)空間上進(jìn)程運(yùn)行的時(shí)間百分比:", cpu_user print "內(nèi)核空間上進(jìn)程運(yùn)行的時(shí)間百分比:", cpu_sys print "閑置時(shí)間百分比:", cpu_idle print "等待IO的時(shí)間百分比:", cpu_wait print "從虛擬機(jī)偷取的時(shí)間百分比:", st ''' cpu監(jiān)控 ''' def cpu_info(): child = ssh_command("遠(yuǎn)程服務(wù)器用戶(hù)名", "127.0.0.1", "遠(yuǎn)程服務(wù)器密碼", "cat /proc/cpuinfo") child.expect(pexpect.EOF) cpuinfo = child.before cpu_num = re.findall('processor.*?(\d+)', cpuinfo)[-1] cpu_num = str(int(cpu_num) + 1) print '***************************************cpu監(jiān)控***************************************' print "*******************時(shí)間:", time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()), "******************" print u"CPU數(shù)目:", cpu_num li = cpuinfo.replace('\t', '').split('\r') CPUinfo = {} procinfo = {} nprocs = 0 for line in li: if line.find("processor") > -1: CPUinfo['CPU%s' % nprocs] = procinfo nprocs = nprocs + 1 else: if len(line.split(':')) == 2: procinfo[line.split(':')[0].strip()] = line.split(':')[1].strip() else: procinfo[line.split(':')[0].strip()] = '' for processor in CPUinfo.keys(): print "CPU屬于的名字及其編號(hào)、標(biāo)稱(chēng)主頻:",CPUinfo[processor]['model name'] print "CPU屬于其系列中的哪一代的代號(hào):", CPUinfo[processor]['model'] print "CPU制造商:", CPUinfo[processor]['vendor_id'] print "CPU產(chǎn)品系列代號(hào):", CPUinfo[processor]['cpu family'] print "CPU的實(shí)際使用主頻:", CPUinfo[processor]['cpu MHz'] """ 負(fù)載均衡 """ def load_stat(): child = ssh_command("遠(yuǎn)程服務(wù)器用戶(hù)名", "127.0.0.1", "遠(yuǎn)程服務(wù)器密碼", "cat /proc/loadavg") child.expect(pexpect.EOF) loadavgs = child.before.strip().split() print '************************負(fù)載均衡監(jiān)控****************************' print "*******************時(shí)間:",time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()),"******************" print "系統(tǒng)5分鐘前的平均負(fù)載:", loadavgs[0] print "系統(tǒng)10分鐘前的平均負(fù)載:", loadavgs[1] print "系統(tǒng)15分鐘前的平均負(fù)載:", loadavgs[2] print "分子是正在運(yùn)行的進(jìn)程數(shù),分母為總進(jìn)程數(shù):",loadavgs[3] print "最近運(yùn)行的進(jìn)程id:", loadavgs[4] """ 獲取網(wǎng)絡(luò)接口的輸入和輸出 """ def ionetwork(): child = ssh_command("遠(yuǎn)程服務(wù)器用戶(hù)名", "127.0.0.1", "遠(yuǎn)程服務(wù)器密碼", "cat /proc/net/dev") child.expect(pexpect.EOF) netdata = child.before li = netdata.strip().split('\n') print '************************獲取網(wǎng)絡(luò)接口的輸入和輸出監(jiān)控****************************' print "*******************時(shí)間:",time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()),"******************" net = {} for line in li[2:]: line = line.split(":") eth_name = line[0].strip() # if eth_name != 'lo': net_io = {} net_io['Receive'] = round(float(line[1].split()[0]) / (1024.0 * 1024.0), 2) net_io['Transmit'] = round(float(line[1].split()[8]) / (1024.0 * 1024.0), 2) net[eth_name] = net_io print net """ 磁盤(pán)空間監(jiān)控 """ def disk_stat(): child = ssh_command("遠(yuǎn)程服務(wù)器用戶(hù)名", "127.0.0.1", "遠(yuǎn)程服務(wù)器密碼", "df -h") child.expect(pexpect.EOF) disk = child.before disklist = disk.strip().split('\n') disklists=[] for disk in disklist: disklists.append(disk.strip().split()) print '************************磁盤(pán)空間監(jiān)控****************************' print "*******************時(shí)間:", time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()), "******************" for i in disklists[1:]: print "\t文件系統(tǒng):", i[0], print "\t容量:", i[1], print "\t已用:", i[2], print "\t可用:", i[3], print "\t已用%掛載點(diǎn):", i[4] """ 端口監(jiān)控 一般是遠(yuǎn)程服務(wù)器用戶(hù)名用戶(hù) """ def getComStr(): child = ssh_command("遠(yuǎn)程服務(wù)器用戶(hù)名", "127.0.0.1", "遠(yuǎn)程服務(wù)器密碼", "netstat -tpln") child.expect(pexpect.EOF) Com = child.before print '******************************端口監(jiān)控*********************************' print "*******************時(shí)間:", time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()), "******************" print Com """ 獲取網(wǎng)絡(luò)接口的輸入和輸出 """ def cpu(): child = ssh_command("遠(yuǎn)程服務(wù)器用戶(hù)名", "127.0.0.1", "遠(yuǎn)程服務(wù)器密碼", 'cat /proc/stat | grep "cpu "') child.expect(pexpect.EOF) child1 = ssh_command("遠(yuǎn)程服務(wù)器用戶(hù)名", "127.0.0.1", "遠(yuǎn)程服務(wù)器密碼", 'cat /proc/stat | grep "cpu "') child1.expect(pexpect.EOF) cpus = child.before.strip().split() cpus1 = child1.before.strip().split() print '************************cpu使用情況****************************' print "*******************時(shí)間:",time.strftime("%Y-%m-%d %H:%M:%S", time.localtime()),"******************" T1=int(cpus[1])+int(cpus[2])+int(cpus[3])+int(cpus[4])+int(cpus[5])+int(cpus[6])+int(cpus[8])+int(cpus[9]) T2=int(cpus1[1]) + int(cpus1[2]) + int(cpus1[3]) + int(cpus1[4] )+ int(cpus1[5] )+int( cpus1[6] )+ int(cpus1[8] )+ int(cpus1[9]) Tol=T2-T1 Idle=int(cpus1[4]) - int(cpus[4]) print '總的cpu時(shí)間1:',T1 print '總的cpu時(shí)間2:', T2 print '時(shí)間間隔內(nèi)的所有時(shí)間片:', Tol print '計(jì)算空閑時(shí)間idle:', Idle print "計(jì)算cpu使用率:",100*(Tol-Idle)/Tol,"%" """ 第一種執(zhí)行 """ def alltask(): try: threads = [] t1 = threading.Thread(target=mem_info) threads.append(t1) t2 = threading.Thread(target=vm_stat_info) threads.append(t2) t3 = threading.Thread(target=cpu_info) threads.append(t3) t4 = threading.Thread(target=load_stat) threads.append(t4) t5 = threading.Thread(target=ionetwork) threads.append(t5) t6 = threading.Thread(target=disk_stat) threads.append(t6) t7 = threading.Thread(target=getComStr) threads.append(t7) t8 = threading.Thread(target=cpu) threads.append(t8) for n in range(len(threads)): threads[n].start() except Exception, e: print str(e) """ 第二種執(zhí)行 """ if __name__ == '__main__': try: threads = [] t1 = threading.Thread(target=mem_info) threads.append(t1) t2 = threading.Thread(target=vm_stat_info) threads.append(t2) t3 = threading.Thread(target=cpu_info) threads.append(t3) t4 = threading.Thread(target=load_stat) threads.append(t4) t5 = threading.Thread(target=ionetwork) threads.append(t5) t6 = threading.Thread(target=disk_stat) threads.append(t6) t7 = threading.Thread(target=getComStr) threads.append(t7) t8 = threading.Thread(target=cpu) threads.append(t8) for n in range(len(threads)): threads[n].start() except Exception, e: print str(e)
監(jiān)控結(jié)果如下:
看完了這篇文章,相信你對(duì)“怎么使用Python實(shí)現(xiàn)自動(dòng)化監(jiān)控遠(yuǎn)程服務(wù)器”有了一定的了解,如果想了解更多相關(guān)知識(shí),歡迎關(guān)注億速云行業(yè)資訊頻道,感謝各位的閱讀!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。