其主要目的是：基于 Python 編程語(yǔ)言來(lái)監(jiān)控服務(wù)器的 CPU、內(nèi)存、/目錄、/appslog、/bigdata目錄使用率以及網(wǎng)卡接收和發(fā)送情況。

該腳本部署場(chǎng)景分為：服務(wù)端和客戶端。

服務(wù)端：一臺(tái)固定 IP 地址的服務(wù)器

客戶端：N 臺(tái)指定固定 IP 地址的服務(wù)器

服務(wù)端腳本：

- - coding:utf-8 - -

import io

import os

import sys

import logging

from logging import handlers

import MySQLdb

import smtplib

from email.mime.text import MIMEText

from email.header import Header

from email.utils import formataddr

import requests, json

import datetime

import time

import shutil,re

import uuid

import socket

import SocketServer

if sys.getdefaultencoding() != 'utf-8':

reload(sys)

sys.setdefaultencoding('utf-8')

class Logger(object):

level_relations = {

'debug': logging.DEBUG,

'info': logging.INFO,

'warning': logging.WARNING,

'error': logging.ERROR,

'crit': logging.CRITICAL

} # 日志級(jí)別關(guān)系映射

def init (self,logname, level='info', when='D', backCount=10, fmt='%(asctime)s - %(pathname)s[line:%(lineno)d] - %(levelname)s: %(message)s'):

CURRENT_DIR = os.path.dirname(file)

LOG_FILE = os.path.abspath(os.path.join(CURRENT_DIR, logname))

self.logger = logging.getLogger(LOG_FILE)

format_str = logging.Formatter(fmt) # 設(shè)置日志格式

self.logger.setLevel(self.level_relations.get(level)) # 設(shè)置日志級(jí)別

sh = logging.StreamHandler() # 往屏幕上輸出

sh.setFormatter(format_str) # 設(shè)置屏幕上顯示的格式

th = handlers.TimedRotatingFileHandler(

filename=LOG_FILE, when=when, backupCount=backCount, encoding='utf-8') # 往文件里寫(xiě)入#指定間隔時(shí)間自動(dòng)生成文件的處理器

#實(shí)例化TimedRotatingFileHandler

#interval是時(shí)間間隔，backupCount是備份文件的個(gè)數(shù)，如果超過(guò)這個(gè)個(gè)數(shù)，就會(huì)自動(dòng)刪除，when是間隔的時(shí)間單位，單位有以下幾種：

S 秒

M 分

H 小時(shí)、

D 天、

W 每星期（interval==0時(shí)代表星期一）

midnight 每天凌晨

th.setFormatter(format_str) # 設(shè)置文件里寫(xiě)入的格式

#self.logger.addHandler(sh) # 把對(duì)象加到logger里

if not self.logger.handlers:

self.logger.addHandler(th)

class Analysis(object):

def buildMsg(self,msg):

print('構(gòu)造預(yù)警信息'+str(msg))

icount = 0

if(float(msg[4]) > 90):

icount+=1

CPU ="> CPU預(yù)警：使用率高于90%，使用"+str(msg[4])+"% \\n"

else:

CPU=""

if(float(msg[5]) > 90):

icount+=1

mem ="> 內(nèi)存預(yù)警：使用率高于90%，使用"+str(msg[5])+"% \\n"

else:

mem=""

if(float(msg[6]) > 85):

icount+=1

disk_root ="> 磁盤(pán)根目錄預(yù)警：使用率高于85%，使用"+str(msg[6])+"% \\n"

else:

disk_root=""

if(float(msg[7]) > 85):

icount+=1

disk_appslog ="> 業(yè)務(wù)磁盤(pán)預(yù)警：使用率高于85%，使用"+str(msg[7])+"% \\n"

else:

disk_appslog=""

if(float(msg[8]) > 3000):

icount+=1

networkRecv ="> 網(wǎng)卡10秒內(nèi)接收數(shù)據(jù)預(yù)警：接收數(shù)據(jù)大于4000M，接收"+str(msg[8])+"M \\n"

else:

networkRecv=""

if(float(msg[9]) > 3000):

icount+=1

networkSend ="> 網(wǎng)卡10秒內(nèi)發(fā)送數(shù)據(jù)預(yù)警：發(fā)送數(shù)據(jù)大于4000M，發(fā)送"+str(msg[9])+"M \\n"

else:

networkSend=""

s= alarmName+"\\n"+msg[2]+":" +msg[3]+"\\n" +CPU+mem+disk_root+disk_appslog+networkRecv+networkSend

#print(s)

log.logger.info('預(yù)警信息：'+s)

#發(fā)送預(yù)警
   if(icount>0):
       #發(fā)送預(yù)警郵件、企業(yè)微信
       if mailconf ==1:
           self.send_mail(s,msg[3])
       if wxconf ==1:
           self.send_WX(s)

def send_mail(self,content,ip):

smtpserver = 'smtp.163.com'

mail_user="[email protected]"

mail_pass="passwordxxx"

mail_res=["[email protected]","[email protected]","[email protected]","[email protected]","[email protected]","[email protected]","[email protected]"]

sub = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())

msg = MIMEText( sub + "\\n"+content, _subtype='plain',_charset='utf-8')

msg['Subject'] = Header(alarmName+':'+ip, 'utf-8' )

#msg['From'] = Header("系統(tǒng)預(yù)警", 'utf-8')

msg['From'] = formataddr(pair=('設(shè)備預(yù)警', mail_user))

msg['To'] = ', '.join(mail_res)

smtp = smtplib.SMTP()

smtp.connect(smtpserver)

smtp.starttls()

smtp.login(mail_user, mail_pass)

smtp.sendmail(mail_user, mail_res, msg.as_string())

smtp.quit()

def send_WX(self,msg):

headers = {"Content-Type": "text/plain"}

#s="服務(wù)器預(yù)警：{},驗(yàn)證碼{}".format({str(printCode)},{str(verifyCode)})

data = {

"msgtype": "text",

"text": {

"content": msg,

}

}

r = requests.post(

url='企業(yè)微信機(jī)器人地址（需要根據(jù)實(shí)際機(jī)器人地址配置）',

headers=headers, json=data)

print(r.text)

def Write_to_Mysql_alarm(self,valuelist):

#log = Logger('all.log',level='debug')

#業(yè)務(wù)監(jiān)控：id,project,tpye,exceptiontype,details(xx,大數(shù)據(jù)，無(wú)es進(jìn)程/es集群不健康，)

try:

db = MySQLdb.connect("xxx", "xxx", "xxx", "xxx", charset='utf8' )

log.logger.info("數(shù)據(jù)庫(kù)連接成功")

except:

log.logger.info("數(shù)據(jù)庫(kù)連接失敗")

創(chuàng)建游標(biāo)

cursor = db.cursor()

uid = uuid.uuid1()

result=0

sql =''

try:

sql = 'insert into test_serverresourcealarm values (%s, %s, %s, %s,%s, %s, %s, %s, %s, %s, %s, %s, %s,%s)'

#val = (str(uid),valuelist[1], valuelist[2], valuelist[3], valuelist[4],valuelist[5], valuelist[6],'',valuelist[7], valuelist[8],valuelist[9],valuelist[10],'','','')

val = (str(uid),valuelist[2], valuelist[3], valuelist[4], valuelist[5],valuelist[6], valuelist[7],'',valuelist[8], valuelist[9],valuelist[10],'','','')

cursor.execute(sql,val)

db.commit()

log.logger.error('設(shè)備預(yù)警信息已入庫(kù)！')

#發(fā)送企業(yè)微信預(yù)警信息

self.buildMsg(valuelist)

except:

into = sys.exc_info()

#log.logger.error('插入數(shù)據(jù)失敗！')

log.logger.error('設(shè)備預(yù)警信息入庫(kù)失敗！'+str(into))

result=0

#str = self.obj_to_string(sys.exc_info(), self)

print('error',into)

# 關(guān)閉游標(biāo)
   db.close()
   return result

def Write_to_Mysql_temp(self,valuelist):

打開(kāi)數(shù)據(jù)庫(kù)連接

#db = MySQLdb.connect("xxx", "xxx", "xxx", "xxx", charset='utf8' )

try:

db = MySQLdb.connect("xxx", "xxx", "xxx", "xxx", charset='utf8' )

log.logger.info("數(shù)據(jù)庫(kù)連接成功")

except:

log.logger.info("數(shù)據(jù)庫(kù)連接失敗")

使用cursor()方法獲取操作游標(biāo)

cursor = db.cursor()

uid = uuid.uuid1()

result=0

try:

sql = 'insert into test_serverresourcetemp values (%s, %s, %s, %s,%s, %s, %s, %s, %s, %s, %s, %s, %s,%s)'

val = (str(uid),valuelist[2], valuelist[3], valuelist[4], valuelist[5],valuelist[6], valuelist[7],'',valuelist[8], valuelist[9],valuelist[10],'','','')

cursor.execute(sql,val)

db.commit()

result=1

log.logger.info("臨時(shí)表sql執(zhí)行狀態(tài)："+str(result))

except:

into = sys.exc_info()

result = 0

print(into)

log.logger.info('臨時(shí)表sql執(zhí)行失敗： '+str(into))

關(guān)閉數(shù)據(jù)庫(kù)連接

db.close()
   return result

class MyServer(SocketServer.BaseRequestHandler):

def handle(self):

conn = self.request

log.logger.info('... connected from {}'.format(self.client_address))

#print('1多線程監(jiān)控')

Flag = True

while Flag:

data = conn.recv(1024)

#print(data)

if len(data)>10:

log.logger.info('接收到的客戶端數(shù)據(jù)：'+data)

conn.sendall('1')

sub = data.strip('\\n')

str = sub.split('|')

#print(str)

a = Analysis()

#報(bào)警信息入庫(kù)，#將監(jiān)控?cái)?shù)據(jù)寫(xiě)入臨時(shí)表中test_serverresourcetemp_lty

result = a.Write_to_Mysql_temp(str)

if(float(str[4])>90 or float(str[5])>90 or float(str[6])>85 or float(str[7])>85 or float(str[8])>3000 or float(str[9])>3000):

result1 = a.Write_to_Mysql_alarm(str)

#result = 1

if result == 0:

log.logger.info('預(yù)警信息入庫(kù)失敗！')

else:

log.logger.info('預(yù)警信息入庫(kù)完成！')

#發(fā)送預(yù)警郵件、企業(yè)微信

#a.buildMsg(str)

if data =='exit':
           log.logger.info('... connecte end ...')
           Flag = False

if name == " main ":

#每分鐘執(zhí)行一次

log = Logger('socketservice.logs')

log.logger.info('----start----')

alarmName ='服務(wù)器資源預(yù)警'

#是否開(kāi)啟郵件報(bào)警，1為開(kāi)啟，0為關(guān)閉

mailconf =1

#是否開(kāi)啟企業(yè)微信報(bào)警，1為開(kāi)啟，0為關(guān)閉

wxconf =0

server = SocketServer.ThreadingTCPServer(('IP',port),MyServer)

server.serve_forever()

原文鏈接：https://blog.csdn.net/eagle89/article/details/128579002