用python进行服务器的监控

在linux服务器中，一切皆为文件，就是说，服务器运行的个中信息，其实是可以从某些文件中查询得到的；百度后，你会知道，在Linux系统中，有一个/proc的虚拟文件系统：

进程信息：系统中的任何一个进程，在 proc 的子目录中都有一个同名的进程 ID，可以找到 cmdline、mem、root、stat、statm，以及 status。某些信息只有超级用户可见，例如进程根目录。每一个单独含有现有进程信息的进程有一些可用的专门链接，系统中的任何一个进程都有一个单独的自链接指向进程信息，其用处就是从进程中获取命令行信息。
系统信息：如果需要了解整个系统信息中也可以从/proc/stat 中获得，其中包括 CPU 占用情况、磁盘空间、内存对换、中断等
CPU 信息：利用/proc/CPUinfo 文件可以获得中央处理器的当前准确信息
负载信息：/proc/loadavg 文件包含系统负载信息
系统内存信息：/proc/meminfo 文件包含系统内存的详细信息，其中显示物理内存的数量、可用交换空间的数量，以及空闲内存的数量等

/proc 目录中的主要文件的说明

apm	高级电源管理信息
cmdline	这个文件给出了内核启动的命令行
CPUinfo	中央处理器信息
devices	可以用到的设备（块设备/字符设备）
dma	显示当前使用的 DMA 通道
filesystems	核心配置的文件系统
ioports	当前使用的 I/O 端口
interrupts	这个文件的每一行都有一个保留的中断
kcore	系统物理内存映像
kmsg	核心输出的消息，被送到日志文件
mdstat	这个文件包含了由 md 设备驱动程序控制的 RAID 设备信息
loadavg	系统平均负载均衡
meminfo	存储器使用信息，包括物理内存和交换内存
modules	这个文件给出可加载内核模块的信息
lsmod	程序用这些信息显示有关模块的名称，大小，使用数目方面的信息
net	网络协议状态信息
partitions	系统识别的分区表
pci	pci 设备信息
scsi	scsi 设备信息
self	到查看/proc 程序进程目录的符号连接
stat	这个文件包含的信息有 CPU 利用率，磁盘，内存页，内存对换，全部
swaps	显示的是交换分区的使用情况
uptime	这个文件给出自从上次系统自举以来的秒数，以及其中有多少秒处于空闲
version	这个文件只有一行内容，说明正在运行的内核版本。可以用标准的编程方法进行分析获得所需的系统信息

以上列出来了这么多，是不是看起来眼花缭乱，但是不要慌，其实我们进行服务器监控，只会经常用到其中比较少的以部门。

利用/proc文件系统进行服务器监控

以上我们知道了服务器信息可以从哪里获取，那么下面，我们就是编写脚本，读取我们要获取信息的文件，从中得到服务器的运行数据。下面是我们经常会需要监控的服务器的一些数据：

读取/proc/meminfo获取内存信息

该文件内容如下

每个字段具体什么意思自己百度吧，直接上监控代码：

""" 内存监控

"""

def memory_stat():

    mem = {}

    f = open('/proc/meminfo', 'r')

    lines = f.readlines()

    f.close()

    for line in lines:

        if len(line) < 2:

            continue

        name = line.split(':')[0]

        var = line.split(':')[1].split()[0]

        mem[name] = float(var)

    mem['MemUsed'] = mem['MemTotal'] - mem['MemFree'] - mem['Buffers'] - mem['Cached']

    #记录内存使用率 已使用 总内存和缓存大小

    res = {}

    res['percent'] = int(round(mem['MemUsed'] / mem['MemTotal'] * 100))

    res['used'] = round(mem['MemUsed'] / (1024 * 1024), 2)

    res['MemTotal'] = round(mem['MemTotal'] / (1024 * 1024), 2)

    res['Buffers'] = round(mem['Buffers'] / (1024 * 1024), 2)

    return res

读取/proc/loadavg获取CPU负载信息

该文件内容如下:

下面为python实现的监控CPU负载的代码:

""" CPU负载监控

"""

def load_stat():

    loadavg = {}

    f = open("/proc/loadavg")

    con = f.read().split()

    f.close()

    loadavg['lavg_1']=con[0]

    loadavg['lavg_5']=con[1]

    loadavg['lavg_15']=con[2]

    loadavg['nr']=con[3]

    prosess_list = loadavg['nr'].split('/')

    loadavg['running_prosess']=prosess_list[0]

    loadavg['total_prosess']=prosess_list[1]

    loadavg['last_pid']=con[4]

    return loadavg

利用python的os包获取硬盘信息

""" 磁盘空间监控

"""

def disk_stat():

    import os

    hd={}

    disk = os.statvfs('/')

    hd['available'] = float(disk.f_bsize * disk.f_bavail)

    hd['capacity'] = float(disk.f_bsize * disk.f_blocks)

    hd['used'] = float((disk.f_blocks - disk.f_bfree) * disk.f_frsize)

    res = {}

    res['used'] = round(hd['used'] / (1024 * 1024 * 1024), 2)

    res['capacity'] = round(hd['capacity'] / (1024 * 1024 * 1024), 2)

    res['available'] = res['capacity'] - res['used']

    res['percent'] = int(round(float(res['used']) / res['capacity'] * 100))

    return res

获取服务器的ip

在一个服务器上，可能有多块网卡，在获取网卡信息时，你需要传入网卡的名字，具体有哪些网卡，可以使用ifconfig命令查看

""" 获取当前服务器ip

"""

def get_ip(ifname):

    import socket

    import fcntl

    import struct

    s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

    return socket.inet_ntoa(fcntl.ioctl(s.fileno(), 0x8915, struct.pack('256s', ifname[:15]))[20:24])

读取/proc/net/dev获取网卡流量信息

我们将会从该文件中获得系统的网络接口，以及当系统重启之后通过它们数据发送和接受数据的信息。 /proc/net/dev文件让这些信息可用。如果你检查了这个文件的内容，你就会注意到头一两行包含了头信息等等，这个文件第一列是网络接口名，第二和第三列显示了接收和发送的字节数信息（例如总发送字节数，包数，错误等等）。这里我们所感兴趣的就是他哦难过不同的网络设备提取出总发送数据和接收数据。下面的代码展示了怎么从/proc/net/dev文件中提取出这些信息，文件内容会是这样的：

下面将获取每个网卡的进出流量信息：

#!/usr/bin/env python

from __future__ import print_function

def net_stat():

    net = {}

    f = open("/proc/net/dev")

    lines = f.readlines()

    f.close

    for line in lines[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

    return net

if __name__ == '__main__':

    netdevs = net_stat()

    print(netdevs)

最后在提供一个Apache服务的监控脚本

#!/usr/bin/env Python

import os, sys, time

while True:

    time.sleep(4)

    try:

        ret = os.popen('ps -C apache -o pid,cmd').readlines()

        if len(ret) < 2:

            print "apache 进程异常退出， 4 秒后重新启动"

            time.sleep(3)

            os.system("service apache2 restart")

    except:

        print "Error", sys.exc_info()[1]