在线观看www成人影院-在线观看www日本免费网站-在线观看www视频-在线观看操-欧美18在线-欧美1级

0
  • 聊天消息
  • 系統(tǒng)消息
  • 評論與回復(fù)
登錄后你可以
  • 下載海量資料
  • 學(xué)習(xí)在線課程
  • 觀看技術(shù)視頻
  • 寫文章/發(fā)帖/加入社區(qū)
會員中心
創(chuàng)作中心

完善資料讓更多小伙伴認(rèn)識你,還能領(lǐng)取20積分哦,立即完善>

3天內(nèi)不再提示

監(jiān)控服務(wù)器資源利用率的服務(wù)端腳本

麥辣雞腿堡 ? 來源:CSDN博客 ? 作者:jerry-89 ? 2023-01-22 16:02 ? 次閱讀

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

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

服務(wù)端:一臺固定 IP 地址的服務(wù)器

客戶端:N 臺指定固定 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

} # 日志級別關(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è)置日志級別

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

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

th = handlers.TimedRotatingFileHandler(

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

#實例化TimedRotatingFileHandler

#interval是時間間隔,backupCount是備份文件的個數(shù),如果超過這個個數(shù),就會自動刪除,when是間隔的時間單位,單位有以下幾種:

S 秒

M 分

H 小時、

D 天、

W 每星期(interval==0時代表星期一)

midnight 每天凌晨

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

#self.logger.addHandler(sh) # 把對象加到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 ="> 磁盤根目錄預(yù)警:使用率高于85%,使用"+str(msg[6])+"% \\n"

else:

disk_root=""

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

icount+=1

disk_appslog ="> 業(yè)務(wù)磁盤預(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="xxx@163.com"

mail_pass="passwordxxx"

mail_res=["xxx@163.com","xxx@163.com","xxx@163.com","xxx@163.com","xxx@163.com","xxx@163.com","xxx@163.com"]

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ù)警:{},驗證碼{}".format({str(printCode)},{str(verifyCode)})

data = {

"msgtype": "text",

"text": {

"content": msg,

}

}

r = requests.post(

url='企業(yè)微信機(jī)器人地址(需要根據(jù)實際機(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ù),無es進(jìn)程/es集群不健康,)

try:

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

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

except:

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

創(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ù)警信息已入庫!')

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

self.buildMsg(valuelist)

except:

into = sys.exc_info()

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

log.logger.error('設(shè)備預(yù)警信息入庫失敗!'+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):

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

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

try:

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

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

except:

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

使用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("臨時表sql執(zhí)行狀態(tài):"+str(result))

except:

into = sys.exc_info()

result = 0

print(into)

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

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

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()

#報警信息入庫,#將監(jiān)控數(shù)據(jù)寫入臨時表中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ù)警信息入庫失敗!')

else:

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

#發(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ù)警'

#是否開啟郵件報警,1為開啟,0為關(guān)閉

mailconf =1

#是否開啟企業(yè)微信報警,1為開啟,0為關(guān)閉

wxconf =0

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

server.serve_forever()

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

聲明:本文內(nèi)容及配圖由入駐作者撰寫或者入駐合作網(wǎng)站授權(quán)轉(zhuǎn)載。文章觀點僅代表作者本人,不代表電子發(fā)燒友網(wǎng)立場。文章及其配圖僅供工程師學(xué)習(xí)之用,如有內(nèi)容侵權(quán)或者其他違規(guī)問題,請聯(lián)系本站處理。 舉報投訴
  • 監(jiān)控
    +關(guān)注

    關(guān)注

    6

    文章

    2273

    瀏覽量

    55683
  • 服務(wù)器
    +關(guān)注

    關(guān)注

    12

    文章

    9556

    瀏覽量

    86839
收藏 人收藏

    評論

    相關(guān)推薦

    TCP服務(wù)端測試工具

    本帖最后由 小子個 于 2024-3-20 22:58 編輯 該TCP服務(wù)端工具可以理解為 “TCP服務(wù)端” 或者 “服務(wù)器” ,目的是幫助大家在沒有服務(wù)器的情況下,完成客戶
    發(fā)表于 06-29 09:22

    服務(wù)端視角看高并發(fā)難題

    `所謂服務(wù)器大流量高并發(fā)指的是:在同時或極短時間內(nèi),有大量的請求到達(dá)服務(wù)端,每個請求都需要服務(wù)端耗費資源進(jìn)行處理,并做出相應(yīng)的反饋。 從服務(wù)端
    發(fā)表于 11-02 15:11

    監(jiān)控系統(tǒng)客戶服務(wù)端設(shè)計

    項目開發(fā)報告1 項目簡介1.1 概述1.2 開發(fā)環(huán)境1.3 其他支持1.4 應(yīng)用界面1.4.1 服務(wù)器端1.4.2 客戶1.5 程序使用2 項目開發(fā)2.1 搭建基于實驗平臺數(shù)據(jù)庫2.1.1 數(shù)據(jù)庫
    發(fā)表于 12-21 07:02

    openEuler 資源利用率提升之道 01:概論

    存在共峰資源不足的問題,該問題會導(dǎo)致部分業(yè)務(wù)服務(wù)質(zhì)量(QoS)受損。如何在提升資源利用率之后,保障業(yè)務(wù) QoS 不受損是技術(shù)上的關(guān)鍵挑戰(zhàn)。此外,云上業(yè)務(wù)的多樣性和復(fù)雜性進(jìn)一步加大了保障
    發(fā)表于 07-06 09:54

    ARM服務(wù)器準(zhǔn)備如何解決服務(wù)端渲染的問題

    針對云手機(jī)、視頻流云游戲行業(yè),ARM服務(wù)器準(zhǔn)備如何解決服務(wù)端渲染的問題?目前的狀況了解,PCIE顯卡對安卓游戲的支持還不夠成熟
    發(fā)表于 09-13 14:58

    服務(wù)器端腳本與動態(tài)網(wǎng)頁設(shè)計,下載

    服務(wù)器端腳本與動態(tài)網(wǎng)頁設(shè)計 1. 了解服務(wù)器端腳本和動態(tài)網(wǎng)頁的有關(guān)概念 ; 2. 了解ASP、PHP的基本語法和基本功能 ; 3. 熟練掌握J(rèn)SP的基本語法和基本
    發(fā)表于 04-28 16:44 ?0次下載

    專家談如何提高服務(wù)器利用率

    專家談如何提高服務(wù)器利用率  如今,數(shù)據(jù)中心節(jié)能已成為熱點話題,為減少功耗,各大廠商紛紛推出相應(yīng)產(chǎn)品和解決方案。近日,Microsoft的utility
    發(fā)表于 01-27 11:46 ?772次閱讀

    如何監(jiān)控服務(wù)器性能?

    (CPU) 和內(nèi)存 每當(dāng)服務(wù)器性能下降時,通常會懷疑服務(wù)器CPU利用率和內(nèi)存資源。如果您的服務(wù)器的CPU使
    的頭像 發(fā)表于 07-19 16:01 ?6414次閱讀

    監(jiān)控服務(wù)器資源利用率的客戶腳本

    客戶腳本腳本: - - coding:utf-8 - - import io import os import sys import time import datetime
    的頭像 發(fā)表于 01-22 16:04 ?877次閱讀

    利用Python寫了一個監(jiān)控服務(wù)器資源利用率腳本

    研究了一個腳本,其主要目的是:基于 Python 編程語言來監(jiān)控服務(wù)器的 CPU、內(nèi)存、/目錄、/appslog、/bigdata目錄使用率以及網(wǎng)卡接收和發(fā)送情況。
    的頭像 發(fā)表于 01-29 15:08 ?896次閱讀

    在遠(yuǎn)程服務(wù)器上搭建一個OpenVPN服務(wù)端

    應(yīng)公司要求需要在一臺遠(yuǎn)程服務(wù)器上搭建一個OpenVPN服務(wù)端,在公司本地服務(wù)器上搭建一個OpenVPN客戶,實現(xiàn)公司內(nèi)網(wǎng)可以訪問遠(yuǎn)程服務(wù)器
    的頭像 發(fā)表于 05-26 15:03 ?9054次閱讀
    在遠(yuǎn)程<b class='flag-5'>服務(wù)器</b>上搭建一個OpenVPN<b class='flag-5'>服務(wù)端</b>

    恒訊科技全面解析:如何有效降低服務(wù)器CPU利用率

    降低服務(wù)器CPU利用率是一個涉及監(jiān)控、診斷和優(yōu)化的全面過程。以下是一些有效的方法: 1、監(jiān)控CPU使用率: 使用工具如top, htop,
    的頭像 發(fā)表于 05-10 17:24 ?937次閱讀

    服務(wù)端測試和客戶測試區(qū)別在哪

    服務(wù)端測試和客戶測試是軟件開發(fā)過程中的兩個重要環(huán)節(jié),它們分別針對服務(wù)器端和客戶的軟件進(jìn)行測試。本文將詳細(xì)介紹服務(wù)端測試和客戶
    的頭像 發(fā)表于 05-30 15:27 ?3975次閱讀

    服務(wù)端測試是web測試嗎為什么

    服務(wù)端測試和Web測試是兩個不同的概念,但它們在軟件開發(fā)和測試過程中是相互關(guān)聯(lián)的。本文將詳細(xì)解釋這兩個概念以及它們之間的關(guān)系。 服務(wù)端測試 服務(wù)端測試主要關(guān)注服務(wù)器端的軟件組件,這些組
    的頭像 發(fā)表于 05-30 15:30 ?918次閱讀

    服務(wù)端測試包括什么類型

    服務(wù)端測試是確保軟件系統(tǒng)在服務(wù)器端正常運行和滿足性能要求的重要環(huán)節(jié)。本文將詳細(xì)介紹服務(wù)端測試的類型、方法和最佳實踐。 1. 服務(wù)端測試的定義 服務(wù)端
    的頭像 發(fā)表于 05-30 16:03 ?1222次閱讀
    主站蜘蛛池模板: 午夜影视网站 | 卡2卡三卡四卡精品公司 | 日本在线视频精品 | 欲香欲色| 狠狠插综合网 | 免费色片网站 | 男女一进一出无遮挡黄 | 九九国产在线观看 | 天天鲁天天爽天天视频 | 嘿嘿嘿视频在线观看 | 国产小福利 | 激情综合丝袜美女一区二区 | 性夜影院爽黄a爽免费视频 性瘾高h姚蕊全文免费阅读 | 国产单男 | 狠狠干狠狠艹 | 四虎影业 | 午夜黄大色黄大片美女图片 | 免费高清一级欧美片在线观看 | tom影院亚洲国产 | 久久久夜夜夜 | 国产在线a不卡免费视频 | 老师下面好湿好紧好滑好想要 | 欧美色视频日本片高清在线观看 | 自拍偷自拍亚洲精品被多人伦好爽 | 久久艹综合| 1024手机最新手机在线 | 天天看天天爽天天摸天天添 | 日本一区二区三区不卡在线看 | 久久久久久久影院 | 女性一级全黄生活片在线播放 | 成人三级电影在线观看 | 国产青青草 | 1000部又爽又黄的做黄禁片 | 一级特黄色毛片免费看 | 色偷偷97| 天天干天天色综合 | 成年女人毛片免费观看97 | 亚洲一区二区三区高清 | 一级特黄性生活大片免费观看 | 欧美色插| 欧美成人精品欧美一级乱黄 |