devbox
天景科技苑
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

Python 开发简易巡检工具_python windows远程登录巡检

作者：天景科技苑 | 2024-07-01 04:33:45

赞

踩

python windows远程登录巡检

利用SSH或者Zabbix监控，配合Django开发框架，改造出属于自己的监控平台，实现包括主机图形，自动发现，计划任务，批量cmd执行，服务监控，日志监控等功能，由于公司机器混乱，基本上市面上的所有设备都能找到，监控这些不同型号不同系统的主机需要分别对待，我们就借助各种开源项目来做一个简单的巡检工具，方便工作需要。

由于公司及其都是老式的性能不高，所以全程我都没敢加多线程，生怕把服务器拒绝服务了。

安装Zabbix客户端

首先客户端还是需要安装zabbix-agent这个监控工具，该工具可以监控所有的平台，windows linux mac unix 等，利用该工具完成一整套自动化平台一点问题都没有，连ansible都不需要了。

  1. [root@localhost ~]# wget http://repo.zabbix.com/zabbix/4.4/rhel/7/x86_64/zabbix-agent-4.4.3-1.el7.x86_64.rpm
  2. [root@localhost ~]# rpm -ivh zabbix-agent-4.2.0-0.1alpha1.el7.x86_64.rpm

该配置文件，并启动服务完事。

  1. [root@localhost ~]# vim /etc/zabbix/zabbix_agentd.conf
  2.  
  3. PidFile=/var/run/zabbix/zabbix_agentd.pid
  4. LogFile=/var/log/zabbix/zabbix_agentd.log
  5. LogFileSize=0
  6. Server=192.168.1.2
  7. ServerActive=192.168.1.2
  8. Hostname=centos1
  9. Timeout=1
  10. Include=/etc/zabbix/zabbix_agentd.d/*.conf
  11. EnableRemoteCommands=1
  12.  
  13. [root@localhost ~]# systemctl restart zabbix-agent
  14. [root@localhost ~]# systemctl enable zabbix-agent

服务端下载

Download Zabbix agents

下载好之后将里面的 zabbix-get.exe 拖入项目中，直接调用就好。

基本的数据采集命令：

  1. zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.hostname
  2. localhost.localdomain  // 此处才是主机名称
  3.  
  4. zabbix_get.exe -s 192.168.1.20 -p 10050 -k agent.hostname
  5. centos1   // 此处是我们zabbix中自定义的键值对
  6.  
  7. zabbix_get.exe -s 192.168.1.20 -p 10050 -k agent.ping
  8. 1
  9.  
  10. zabbix_get.exe -s 192.168.1.20 -p 10050 -k agent.version
  11. 4.4.3      // zabbix 的version
  12.  
  13. zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.boottime
  14. 1578564779    // 系统启动的时间戳
  15.  
  16. zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.cpu.num
  17. 1              // 处理器个数
  18.  
  19. zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.localtime
  20. 1578569019      // 当前系统时间戳
  21.  
  22. zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.sw.arch
  23. x86_64         // 返回系统架构
  24.  
  25. zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.sw.os
  26. Linux version 3.10.0-1062.el7.x86_64 (mockbuild@kbuilder.bsys.centos.org) (gcc version 4.8.5 20150623 (Red Hat 4.8.5-36) (GCC) ) #1 SMP Wed Aug 7 18:08:02 UTC 2019   // 返回系统详细架构
  27.  
  28. zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.sw.packages[ssh]  // 已安装软件列表
  29. [rpm] libssh2-1.8.0-3.el7.x86_64, openssh-7.4p1-21.el7.x86_64, openssh-clients-7.4p1-21.el7.x86_64, openssh-server-7.4p1-21.el7.x86_64
  30.  
  31. zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.uname
  32. Linux localhost.localdomain 3.10.0-1062.el7.x86_64 #1 SMP Wed Aug 7 18:08:02 UTC 2019 x86_64
  33.  
  34. zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.uptime
  35. 4438   // 系统运行时长(秒)多少秒使用s/uptime来获取
  36.  
  37. zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.users.num
  38. 0    // 登陆用户数
  39.  
  40. zabbix_get.exe -s 192.168.1.20 -p 10050 -k kernel.maxfiles
  41. 96437  // 系统支持最大的open files整数
  42.  
  43. zabbix_get.exe -s 192.168.1.20 -p 10050 -k kernel.maxproc
  44. 65536  // 系统支持最大进程数
  45.  
  46. zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.hw.macaddr
  47. [ens32] 00:50:56:22:6f:d3   // mac 地址列表
  48.  
  49. >zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.sw.os
  50. Linux version 3.10.0-1062.el7.x86_64 (mockbuild@kbuilder.bsys.centos.org) (gcc version 4.8.5 20150623 (Red Hat 4.8.5-36) (GCC) ) #1 SMP Wed Aug 7 18:08:02 UTC 2019   // 操作系统信息

允许远程执行命令：

  1. [root@localhost ~]# vim /etc/zabbix/zabbix_agentd.conf
  2. EnableRemoteCommands=1
  3. [root@localhost ~]# systemctl restart zabbix-agent
  4.  
  5. D:\zabbix> zabbix_get.exe -s 192.168.1.20 -p 10050 -k "system.run[df -h]"
  6. Filesystem               Size  Used Avail Use% Mounted on
  7. devtmpfs                 480M     0  480M   0% /dev
  8. tmpfs                    491M     0  491M   0% /dev/shm
  9. tmpfs                    491M  7.4M  484M   2% /run
  10. tmpfs                    491M     0  491M   0% /sys/fs/cgroup
  11. /dev/mapper/centos-root   27G  1.7G   26G   7% /
  12. /dev/sda1               1014M  136M  879M  14% /boot
  13. tmpfs                     99M     0   99M   0% /run/user/0

监控CPU

  1. system.cpu.util[<cpu>,<type>,<mode>]
  2.  
  3. -CPU:  CPU数量(默认是所有CPU)
  4. -Type: 可用值,idle,nice,user,system,iowait,interrupt,sottrq,steal
  5. -Mode  可用值,avg1(一分钟负载),avg5,avg15
  6.  
  7. [root@localhost ~]# zabbix_get -s 192.168.1.25 -k system.cpu.util[,,avg1]
  8. 0.016692
  9.  
  10. zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.cpu.num
  11. 1   // cpu 个数
  12.  
  13. zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.cpu.util
  14. 0.016461  // cpu 利用率百分比
  15.  
  16. zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.hw.cpu  // cpu 详细信息
  17. processor 0: GenuineIntel Intel(R) Celeron(R) CPU        E3500  @ 2.70GHz working at 2700MHz

监控内存

  1. proc.mem[<name>,<user>,<mode>,<cmdline>,<memtype>]
  2.  
  3. -name    进程名(默认所有进程)
  4. -user    用户名(默认所有用户)
  5. -mode    可选值,avg,max,min,sum
  6. -cmdline 命令过滤
  7.  
  8. [root@localhost ~]# zabbix_get -s 192.168.1.25 -k proc.mem[httpd,,,]
  9. 1376378880
  10. [root@localhost ~]# zabbix_get -s 192.168.1.25 -k proc.mem[]
  11. 6479925248
  12.  
  13. zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.swap.in
  14. 0      // Swap in (f内存到磁盘) .数字
  15.  
  16. zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.swap.out
  17. 0  //Swap out (f内存到磁盘) .数字
  18. zabbix_get.exe -s 192.168.1.20 -p 10050 -k system.swap.size
  19. 2147479552  // 交换分区大小字节或者百分比
  20.  
  21.  
  22. mode - total (默认), active, anon, buffers, cached, exec, file, free, inactive, pinned, shared, wired, used, pused, available
  23. zabbix_get.exe -s 192.168.1.20 -p 10050 -k vm.memory.size[free]
  24. 598949888   // 监控内存变化

监控网卡

  1. net.if.in [if,<mode>]       #网卡入口流量
  2. net.if.out [if,<mode>]      #网卡出口流量
  3. net.if.total [if,<mode>]    #网卡进/出流量总和
  4.  
  5. -if    网卡名称
  6. -mode  可用值(如下)
  7.  
  8.        bytes    字节数
  9.        packets  包数量
  10.        errors   错误数量
  11.        droppend 丢包数量
  12.  
  13. [root@localhost ~]# zabbix_get -s 192.168.1.25 -k net.if.in[ens32,bytes]
  14. 165983
  15. [root@localhost ~]# zabbix_get -s 192.168.1.25 -k net.if.in[ens32,packets]
  16. 2166
  17. [root@localhost ~]# zabbix_get -s 192.168.1.25 -k net.if.out[ens32,packets]
  18. 2067
  19. [root@localhost ~]# zabbix_get.exe -s 192.168.1.20 -p 10050 -k net.if.discovery
  20. [{"{#IFNAME}":"ens32"},{"{#IFNAME}":"lo"}]  // 列出系统网卡信息
  21. zabbix_get.exe -s 192.168.1.20 -p 10050 -k net.if.total[ens32]
  22. 20785083           // 列出网卡总流量
  23.  
  24. zabbix_get.exe -s 192.168.1.20 -p 10050 -k net.tcp.listen[10050]
  25. 1             // 检测指定端口是否开启
  26.  
  27. zabbix_get.exe -s 192.168.1.20 -p 10050 -k net.tcp.port[,80]
  28. 0             // 检测本机web服务是否开启
  29.  
  30. zabbix_get.exe -s 192.168.1.20 -p 10050 -k net.tcp.service[ssh,,22]
  31. 1            // 检测是定服务是否在运行

监控IO/读写

  1. vfs.dev.read [<device>,<type>,<mode>]    #磁盘读取
  2. vfs.dev.write [<device>,<type>,<mode>]   #磁盘写入
  3.  
  4. -device   磁盘设备(默认all)
  5. -type     sectors,operations,bytes,sps,ops,hps
  6. -mode     默认有(avg1,avg5,avg15)
  7.  
  8. [root@localhost ~]# zabbix_get -s 192.168.1.25 -k vfs.dev.read[/dev/sda,,avg1]
  9. 0.000000
  10. [root@localhost ~]# zabbix_get -s 192.168.1.25 -k vfs.dev.read[all]
  11. 195.200000
  12. [root@localhost ~]# zabbix_get -s 192.168.1.25 -k vfs.dev.read[all,,avg1]
  13. 195.200000
  14. [root@localhost ~]# zabbix_get -s 192.168.1.25 -k vfs.dev.read[all,,avg5]
  15. 177.758242
  16. [root@localhost ~]# zabbix_get -s 192.168.1.25 -k vfs.dev.write[all,,avg5]
  17. 465.284483
  18. [root@localhost ~]# zabbix_get -s 192.168.1.25 -k vfs.dev.write[all,,avg1]
  19. 877.200000
  20. [root@localhost ~]# zabbix_get -s 192.168.1.25 -k vfs.dev.write[/dev/sda,,]
  21. 374.800000

文件操作：

  1. zabbix_get.exe -s 192.168.1.20 -p 10050 -k vfs.file.exists[/etc/passwd]
  2. 1   // 检测指定文件是否存在
  3.  
  4. zabbix_get.exe -s 192.168.1.20 -p 10050 -k vfs.file.md5sum[/etc/passwd]
  5. 52f5db4f5688b79b9c07ef5a42ea29af  // md5验证
  6.  
  7. zabbix_get.exe -s 192.168.1.20 -p 10050 -k vfs.file.size[/etc/passwd]
  8. 870   // 文件大小字节数
  9.  
  10. zabbix_get.exe -s 192.168.1.20 -p 10050 -k vfs.file.time[/etc/passwd]
  11. 1578566854  // 文件日期时间戳
  12.  
  13. zabbix_get.exe -s 192.168.1.20 -p 10050 -k vfs.fs.discovery  // 列出文件系统所有目录结构
  14. [{"{#FSNAME}":"/","{#FSTYPE}":"rootfs"},{"{#FSNAME}":"/sys","{#FSTYPE}":"sysfs"},{"{#FSNAME}":"/proc","{#FSTYPE}":"proc"},{"{#FSNAME}":"/dev","{#FSTYPE}":"devtmpfs"},{"{#FSNAME}":"/sys/kernel/security","{#FSTYPE}":"securityfs"},{"{#FSNAME}":"/dev/shm"}]
  15.  
  16. mode - total (默认), free, used, pfree (空闲百分比), pused (使用百分比)
  17. zabbix_get.exe -s 192.168.1.20 -p 10050 -k vfs.fs.inode[/dev,free]
  18. 122355 // 检测/dev/空闲空间
  19.  
  20. zabbix_get.exe -s 192.168.1.20 -p 10050 -k vfs.fs.size[/dev,free]
  21. 502525952  // 磁盘空间，返回本地文件系统的使用量字节

磁盘利用率

  1. 监控磁盘使用情况需要vfs.fs.size[fs,<mode>]键值
  2.  
  3. fs：文件系统
  4. mode：模式
  5. total默认全部，free空闲，used使用，pfree空闲百分比，pused使用百分比
  6.  
  7. 名称：c盘总量
  8. 键值：vfs.fs.size[c:,total]
  9.  
  10.  
  11. 名称：c盘剩余量 键值vfs.fs.size[c:,free]
  12. 名称：c盘使用量 键值vfs.fs.size[c:,used]
  13.  
  14. 名称：c盘剩余百分比 键值：vfs.fs.size[c:,pfree]
  15. 名称：c盘使用百分比 键值：vfs.fs.size[c:,pused]

先来完成一个Ping操作

  1. import os,sqlite3,datetime,time,signal,sys
  2. import subprocess
  3.  
  4. def Ping(address,port,timeout):
  5.     command = "get.exe -s {} -p {} -k agent.ping".format(address,port).split(" ")
  6.     start = datetime.datetime.now()
  7.     process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)
  8.     while process.poll() is None:
  9.         time.sleep(1)
  10.         now = datetime.datetime.now()
  11.         if (now - start).seconds > timeout:
  12.             return 0
  13.     return 1
  14.  
  15. for i in range(10,22):
  16.     a = Ping("192.168.1.{}".format(i),"10050",1)
  17.     print(a)

封装connect方法 connect.py

  1. import os,subprocess,sys,math
  2. import time
  3. import datetime
  4.  
  5. # 检查主机状态
  6. def GetPing(addr,port,timeout):
  7.     try:
  8.         command = "engine.exe -s {} -p {} -k agent.ping".format(addr, port).split(" ")
  9.         start = datetime.datetime.now()
  10.         process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)
  11.         while process.poll() is None:
  12.             time.sleep(1)
  13.             now = datetime.datetime.now()
  14.             if (now - start).seconds > timeout:
  15.                 return 0
  16.         return 1
  17.     except Exception:
  18.         return 0
  19.  
  20. # 获取目标主机名 仅用于Windows
  21. def GetHostName(addr,port,timeout):
  22.     try:
  23.         Command = "engine.exe -s {} -p {} -k system.hostname".format(addr,port)
  24.         start = datetime.datetime.now()
  25.         process = subprocess.Popen(Command, shell=True,stdout=subprocess.PIPE,stderr=subprocess.PIPE)
  26.         HostName = str(process.stdout.readlines()[0].split()[0],"utf-8")
  27.  
  28.         while process.poll() is None:
  29.             time.sleep(1)
  30.             now = datetime.datetime.now()
  31.             if (now - start).seconds > timeout:
  32.                 return 0
  33.         return HostName
  34.     except Exception:
  35.         return 0
  36.  
  37. # 得到系统型号，例如windows linux等
  38. def GetSysUname(addr,port,timeout):
  39.     try:
  40.         Command = "engine.exe -s {} -p {} -k system.uname".format(addr,port)
  41.         start = datetime.datetime.now()
  42.         process = subprocess.Popen(Command, shell=True,stdout=subprocess.PIPE,stderr=subprocess.PIPE)
  43.         Uname = str(process.stdout.readlines()[0].split()[0],"utf-8")
  44.  
  45.         while process.poll() is None:
  46.             time.sleep(1)
  47.             now = datetime.datetime.now()
  48.             if (now - start).seconds > timeout:
  49.                 return 0
  50.         return Uname
  51.     except Exception:
  52.         return 0
  53.  
  54. # 列出系统平台  x86 or x64
  55. def GetSysArch(addr,port,timeout):
  56.     try:
  57.         command = "engine.exe -s {} -p {} -k system.sw.arch".format(addr, port).split(" ")
  58.         start = datetime.datetime.now()
  59.         process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)
  60.         while process.poll() is None:
  61.             time.sleep(1)
  62.             now = datetime.datetime.now()
  63.             if (now - start).seconds > timeout:
  64.                 return 0
  65.         arch = process.stdout.readlines()[0].split()[0]
  66.         return str(arch,"utf-8")
  67.     except Exception:
  68.         return 0
  69.  
  70. # 获取CPU核心数
  71. def GetCPUCoreNumber(addr,port,timeout):
  72.     try:
  73.         Command = "engine.exe -s {} -p {} -k system.cpu.num[online]".format(addr,port)
  74.         start = datetime.datetime.now()
  75.         process = subprocess.Popen(Command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  76.         CpuCoreNum = process.stdout.readlines()[0].split()[0]
  77.         #print()
  78.         return str(CpuCoreNum,"utf-8")
  79.     except Exception:
  80.         return 0
  81.  
  82. # 获取CPU的利用率 10%
  83. def GetCPUCoreInfo(addr,port,timeout):
  84.     try:
  85.         Command = "engine.exe -s {} -p {} -k system.cpu.util".format(addr, port)
  86.         start = datetime.datetime.now()
  87.         process = subprocess.Popen(Command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  88.         CPU = math.ceil(float(process.stdout.readlines()[0].split()[0]))
  89.         while process.poll() is None:
  90.             time.sleep(1)
  91.             now = datetime.datetime.now()
  92.             if (now - start).seconds > timeout:
  93.                 return 0
  94.         return CPU
  95.     except Exception:
  96.         return 0
  97.  
  98. # 获取CPU 的负载值 avg1 avg5 avg15
  99. def GetCPULoadAvg(addr,port,avg,timeout):
  100.     try:
  101.         Command = "engine.exe -s {} -p {} -k system.cpu.load[,{}]".format(addr, port,avg)
  102.         start = datetime.datetime.now()
  103.         process = subprocess.Popen(Command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  104.         CPU = float(process.stdout.readlines()[0].split()[0])
  105.         while process.poll() is None:
  106.             time.sleep(1)
  107.             now = datetime.datetime.now()
  108.             if (now - start).seconds > timeout:
  109.                 return 0
  110.         return CPU
  111.     except Exception:
  112.         return 0
  113.  
  114. # 获取内存数据 返回总内存/剩余内存
  115. def GetMemInfo(addr,port,timeout):
  116.     try:
  117.         Total = subprocess.Popen("engine.exe -s {} -p {} -k vm.memory.size[total]".format(addr, port)
  118.                                  , shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  119.         Free = subprocess.Popen("engine.exe -s {} -p {} -k vm.memory.size[free]".format(addr, port)
  120.                                 , shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  121.         Total = math.ceil(int(Total.stdout.readlines()[0].split()[0])/1024/1024)
  122.         Free = math.ceil(int(Free.stdout.readlines()[0].split()[0])/1024/1024)
  123.         return Total,Free
  124.     except Exception:
  125.         return 0
  126.  
  127. # 获取全部磁盘容量
  128. def GetDiskInfo(self):
  129.     try:
  130.         Free = subprocess.Popen("engine.exe -s {} -p {} -k vfs.fs.size[/,pfree]".format(self.addr, self.port)
  131.                                  , shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  132.         Free = float(Free.stdout.readlines()[0].split()[0])
  133.         return Free
  134.     except Exception:
  135.         return 0
  136.  
  137. # 获取特定进程是否运行
  138. def GetProcessStatus(addr,port,procname):
  139.     command = "engine.exe -s {} -p {} -k proc.num[\"{}\"]".format(addr,port,procname)
  140.     process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)
  141.     ref = process.stdout.readlines()[0]
  142.     if ref == b"1\r\n":
  143.         return 1
  144.     return 0
  145.  
  146. # 获取端口开放状态
  147. def GetNetworkPort(addr,port,check_port):
  148.     command = "engine.exe -s {} -p {} -k net.tcp.listen[{}]".format(addr,port,check_port)
  149.     process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)
  150.     ref = process.stdout.readlines()[0]
  151.     if ref == b"1\r\n":
  152.         return 1
  153.     return 0

调用命令，获取系统基本信息。

  1. import connect
  2.  
  3. def SysInfo():
  4.     lis = [["127.0.0.1","MCP服务器"],["192.168.1.1","CTI"]]
  5.  
  6.     print("IP地址 \t\t 主机作用 \t\t 主机类型 \t\t 主机架构 \t\t 核心数 \t\t CPU利用率 \t\t CPU Avg1 \t Avg5 \t Avg15 \t 内存利用率 \t Ping")
  7.  
  8.     host_addr = lis[0][0]
  9.     host_type = lis[0][1]
  10.  
  11.     host_address = host_addr
  12.     host_user_type = host_type
  13.  
  14.     host_ping = connect.GetPing(host_address,"10050",2)
  15.     host_type = connect.GetSysUname(host_address,"10050",2)
  16.     host_arch = connect.GetSysArch(host_address,"10050",2)
  17.     host_cpu_number = connect.GetCPUCoreNumber(host_address,"10050",2)
  18.     host_cpu_core = connect.GetCPUCoreInfo(host_address,"10050",2)
  19.     host_cpu_load1 = connect.GetCPULoadAvg(host_address,"10050","avg1",2)
  20.     host_cpu_load5 = connect.GetCPULoadAvg(host_address,"10050","avg5",2)
  21.     host_cpu_load15 = connect.GetCPULoadAvg(host_address,"10050","avg15",2)
  22.     host_memory = connect.GetMemInfo(host_address,"10050",2)
  23.  
  24.     print("{} \t {} \t\t {} \t\t {} \t\t\t {} \t\t\t {}% \t\t {} \t\t {} \t {} \t {} \t {}".
  25.           format(host_address,host_user_type,host_type,host_arch,host_cpu_number,
  26.                  host_cpu_core,host_cpu_load1,host_cpu_load5,host_cpu_load15,host_memory,host_ping))
  27.  
  28. if __name__ == '__main__':
  29.     SysInfo()

批量ping检测

  1. import subprocess, datetime, time
  2. import threading,os,sys
  3.  
  4. lock = threading.RLock()
  5.  
  6. def GetPing(command, timeout):
  7.     cmd = command.split(" ")
  8.     start = datetime.datetime.now()
  9.     process = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  10.     while process.poll() is None:
  11.         time.sleep(0.2)
  12.         now = datetime.datetime.now()
  13.         if (now - start).seconds> timeout:
  14.             return "异常"
  15.     try:
  16.         ref = process.stdout.readlines()[0]
  17.         if ref == b"1\r\n":
  18.             return "正常"
  19.         else:
  20.             return "异常"
  21.     except Exception:
  22.         return "异常"
  23.  
  24. def MyThread(ptr):
  25.     each = eval(ptr)
  26.     command = "engine.exe -s {} -p 10050 -k agent.ping".format(each[0])
  27.     ref = GetPing(command,1)
  28.     lock.acquire()
  29.     if(ref == "异常"):
  30.         print("{0:15}\t\t {1:15}\t {2:10}\t\t {3:10}\t {4:4} <--".format(each[0], each[1], each[2], each[3], ref))
  31.     else:
  32.         print("{0:15}\t\t {1:15}\t {2:10}\t\t {3:10}\t {4:4}".format(each[0], each[1], each[2], each[3], ref))
  33.     lock.release()
  34.  
  35. if __name__ == "__main__":
  36. # Base.db 内容: ["127.0.0.1","ANA2048567","1M-2F","MCP服务器"]
  37.     fp = open("base.db","r",encoding="utf-8")
  38.     count=len(open("base.db","r",encoding="utf-8").readlines())
  39.  
  40.     print("-" * 100)
  41.     print("{0:13}\t\t {1:15}\t {2:10}\t\t {3:8}\t {4:4}".format("IP地址","SN号码","机房位置","作用","Ping"))
  42.     print("-" * 100)
  43.     for i in range(count):
  44.         ptr = fp.readline()
  45.         thread = threading.Thread(target=MyThread, args=(ptr,))
  46.         thread.start()

批量进程检测

  1. import subprocess, datetime, time
  2. import threading,os,sys
  3.  
  4. # 获取特定进程是否运行
  5. def GetProcessStatus(addr,port,timeout,procname):
  6.     command = "engine.exe -s {} -p {} -k proc.num[\"{}\"]".format(addr,port,procname)
  7.     start = datetime.datetime.now()
  8.     process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  9.     while process.poll() is None:
  10.         time.sleep(0.2)
  11.         now = datetime.datetime.now()
  12.         if (now - start).seconds> timeout:
  13.             return 0
  14.     try:
  15.         ref = process.stdout.readlines()[0]
  16.         if ref != b"0\r\n":
  17.             return int(ref)
  18.         else:
  19.             return 0
  20.     except Exception:
  21.         return 0
  22.  
  23. if __name__ == "__main__":
  24.     process_cache = []
  25.     proc_fp = open("process.db","r",encoding="utf-8")
  26.     count = len(open("process.db","r",encoding="utf-8").readlines())
  27.  
  28.     for each in range(1,count+1):
  29.         proc = eval(proc_fp.readline())
  30.         proc_len = len(proc)
  31.         print("-" * 70)
  32.         print("---> 巡检地址: {}".format(proc[0]))
  33.         print("-" * 70)
  34.         for process in range(1,proc_len):
  35.             ref = GetProcessStatus(proc[0],10050,3,proc[process])
  36.             if(ref != 0):
  37.                 print("进程: {0:18} \t  进程数: {1:5} \t 状态: {2}".format(proc[process],ref,"√"))
  38.             else:
  39.                 print("进程: {0:18} \t  进程数: {1:5} \t 状态: {2}".format(proc[process],ref,"×"))
  40.         print()

批量CPU负载检测等

  1. import subprocess, datetime, time,math
  2. import threading,os,sys
  3.  
  4. lock = threading.RLock()
  5.  
  6. # 获取CPU的利用率 %
  7. def GetCPUCoreInfo(addr,port,timeout):
  8.     try:
  9.         Command = "engine.exe -s {} -p {} -k system.cpu.util".format(addr, port)
  10.         start = datetime.datetime.now()
  11.         process = subprocess.Popen(Command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  12.         CPU = math.ceil(float(process.stdout.readlines()[0].split()[0]))
  13.         while process.poll() is None:
  14.             time.sleep(0.3)
  15.             now = datetime.datetime.now()
  16.             if (now - start).seconds > timeout:
  17.                 return str("0%")
  18.         return str(CPU) + "%"
  19.     except Exception:
  20.         return str("0%")
  21.  
  22. # 获取CPU 的负载值 avg1 avg5 avg15
  23. def GetCPULoadAvg(addr,port,avg,timeout):
  24.     try:
  25.         Command = "engine.exe -s {} -p {} -k system.cpu.load[,{}]".format(addr, port,avg)
  26.         start = datetime.datetime.now()
  27.         process = subprocess.Popen(Command, shell=True, stdout=subprocess.PIPE,stderr=subprocess.PIPE)
  28.         CPU = float(process.stdout.readlines()[0].split()[0])
  29.         while process.poll() is None:
  30.             time.sleep(0.3)
  31.             now = datetime.datetime.now()
  32.             if (now - start).seconds > timeout:
  33.                 return 0
  34.         return CPU
  35.     except Exception:
  36.         return 0
  37.  
  38. # 获取内存数据 返回 %
  39. def GetMemInfo(addr,port,timeout):
  40.     try:
  41.         Total = subprocess.Popen("engine.exe -s {} -p {} -k vm.memory.size[total]".format(addr, port)
  42.                                  , shell=True, stdout=subprocess.PIPE,stderr=subprocess.PIPE)
  43.         start = datetime.datetime.now()
  44.         while Total.poll() is None:
  45.             time.sleep(0.3)
  46.             now = datetime.datetime.now()
  47.             if (now - start).seconds > timeout:
  48.                 return 0
  49.         Free = subprocess.Popen("engine.exe -s {} -p {} -k vm.memory.size[free]".format(addr, port)
  50.                                 , shell=True, stdout=subprocess.PIPE,stderr=subprocess.PIPE)
  51.         start = datetime.datetime.now()
  52.         while Free.poll() is None:
  53.             time.sleep(0.3)
  54.             now = datetime.datetime.now()
  55.             if (now - start).seconds > timeout:
  56.                 return str(0)+"%"
  57.         Total = math.ceil(int(Total.stdout.readlines()[0].split()[0])/1024/1024)
  58.         Free = math.ceil(int(Free.stdout.readlines()[0].split()[0])/1024/1024)
  59.         percentage = 100 - int(Free/int(Total/100))
  60.         return str(percentage)+"%"
  61.     except Exception:
  62.         return str(0)+"%"
  63.  
  64. def MyThread(ptr):
  65.     address = eval(ptr)
  66.     cpu_info = GetCPUCoreInfo(address[0], 10050, 1)
  67.     mem_info = GetMemInfo(address[0], 10050, 1)
  68.     cpu_load1 = GetCPULoadAvg(address[0], 10050, "avg1", 1)
  69.     cpu_load5 = GetCPULoadAvg(address[0], 10050, "avg5", 1)
  70.     cpu_load15 = GetCPULoadAvg(address[0], 10050, "avg15", 1)
  71.     lock.acquire()
  72.     print("{0:10} \t {1:10} \t {2:10} \t {3:10} \t {4:10} \t {5:10} \t".
  73.           format(address[0], cpu_info, mem_info,cpu_load1, cpu_load5,cpu_load15))
  74.     lock.release()
  75.  
  76. if __name__ == "__main__":
  77.     fp = open("base.db","r",encoding="utf-8")
  78.     count = len(open("base.db","r",encoding="utf-8").readlines())
  79.     print("-" * 100)
  80.     print("IP地址 \t\t CPU利用率 \t 内存利用率 \t 1分钟负载 \t 5分钟负载 \t 15分钟负载 \t")
  81.     print("-" * 100)
  82.  
  83.     for i in range(count):
  84.         ptr = fp.readline()
  85.         thread = threading.Thread(target=MyThread, args=(ptr,))
  86.         thread.start()

封装一个Zabbix调用类

  1. import subprocess,datetime,time,math
  2.  
  3. class Engine():
  4.     def __init__(self,address,port):
  5.         self.address = address
  6.         self.port = port
  7.  
  8.     def GetValue(self,key):
  9.         try:
  10.             command = "get.exe -s {0} -p {1} -k {2}".format(self.address,self.port,key).split(" ")
  11.             start = datetime.datetime.now()
  12.             process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)
  13.             while process.poll() is None:
  14.                 time.sleep(1)
  15.                 now = datetime.datetime.now()
  16.                 if (now - start).seconds > 2:
  17.                     return 0
  18.             return str(process.stdout.readlines()[0].split()[0],"utf-8")
  19.         except Exception:
  20.             return 0
  21.  
  22.     # 获取主机组基本信息
  23.     def GetSystem(self):
  24.         ref_dict = { "Address" : 0 ,"HostName" : 0,"Uname":0, "Ping":0 }
  25.         ref_dict["Address"] = self.address
  26.         ref_dict["HostName"] = self.GetValue("system.hostname")
  27.         ref_dict["Uname"] = self.GetValue("system.uname")
  28.         ref_dict["Ping"] = self.GetValue("agent.ping")
  29.         return ref_dict
  30.  
  31.     # 获取CPU利用率
  32.     def GetCPU(self):
  33.         ref_dict = { "Address": 0 ,"Core": 0,"Active":0 , "Avg1": 0 ,"Avg5":0 , "Avg15":0 }
  34.         ref_dict["Address"] = self.address
  35.         ref_dict["Core"] = self.GetValue("system.cpu.num")
  36.         ref_dict["Active"] = math.ceil(float(self.GetValue("system.cpu.util")))
  37.         ref_dict["Avg1"] = self.GetValue("system.cpu.load[,avg1]")
  38.         ref_dict["Avg5"] = self.GetValue("system.cpu.load[,avg5]")
  39.         ref_dict["Avg15"] = self.GetValue("system.cpu.load[,avg15]")
  40.         return ref_dict
  41.  
  42.     # 获取内存利用率
  43.     def GetMemory(self):
  44.         ref_dict = { "Address":0,"Total":0,"Free":0,"Percentage":0 }
  45.         ref_dict["Address"] = self.address
  46.         ref_dict["Total"] = self.GetValue("vm.memory.size[total]")
  47.         ref_dict["Free"] = self.GetValue("vm.memory.size[free]")
  48.         # 计算百分比: percentage = 100 - int(Free/int(Total/100))
  49.         ref_dict["Percentage"] = str( 100 - int( int(ref_dict.get("Free")) / (int(ref_dict.get("Total"))/100)) ) + "%"
  50.         return ref_dict
  51.  
  52.     # 获取磁盘数据
  53.     def GetDisk(self):
  54.         ref_list = []
  55.         disk_ = eval( self.GetValue("vfs.fs.discovery") )
  56.         for x in range(len(disk_)):
  57.             dict_ = { "Address":0, "Name":0,"Type":0,"Free":0}
  58.             dict_["Address"] = self.address
  59.             dict_["Name"] = disk_[x].get("{#FSNAME}")
  60.             dict_["Type"] = disk_[x].get("{#FSTYPE}")
  61.             if dict_["Type"] != "UNKNOWN":
  62.                 pfree = self.GetValue("vfs.fs.size[\"{0}\",pfree]".format(dict_["Name"]))
  63.                 dict_["Free"] = str(math.ceil(float(pfree)))
  64.             else:
  65.                 dict_["Free"] = 0
  66.             ref_list.append(dict_)
  67.         return ref_list
  68.  
  69. if __name__ == "__main__":
  70.     ptr_windows = Engine("132.35.93.2","10050")
  71.     ret = ptr_windows.GetDisk()
  72.     print(ret)

简单的监控脚本编写 (无脑写法)

首先是连接脚本 win32_connect.py

  1. import subprocess, datetime, time
  2. import threading, os, sys,math
  3.  
  4. # 获取Ping返回状态
  5. def GetPing(command, timeout):
  6.     cmd = command.split(" ")
  7.     start = datetime.datetime.now()
  8.     process = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  9.     while process.poll() is None:
  10.         time.sleep(0.2)
  11.         now = datetime.datetime.now()
  12.         if (now - start).seconds > timeout:
  13.             return "异常"
  14.     try:
  15.         ref = process.stdout.readlines()[0]
  16.         if ref == b"1\r\n":
  17.             return "正常"
  18.         else:
  19.             return "异常"
  20.     except Exception:
  21.         return "异常"
  22.  
  23. # 获取特定进程是否运行
  24. def GetProcessStatus(addr,port,timeout,procname):
  25.     command = "engine.exe -s {} -p {} -k proc.num[\"{}\"]".format(addr,port,procname)
  26.     start = datetime.datetime.now()
  27.     process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  28.     while process.poll() is None:
  29.         time.sleep(0.2)
  30.         now = datetime.datetime.now()
  31.         if (now - start).seconds> timeout:
  32.             return 0
  33.     try:
  34.         ref = process.stdout.readlines()[0]
  35.         if ref != b"0\r\n":
  36.             return int(ref)
  37.         else:
  38.             return 0
  39.     except Exception:
  40.         return 0
  41.  
  42. # 获取CPU的利用率 %
  43. def GetCPUCoreInfo(addr,port,timeout):
  44.     try:
  45.         Command = "engine.exe -s {} -p {} -k system.cpu.util".format(addr, port)
  46.         start = datetime.datetime.now()
  47.         process = subprocess.Popen(Command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  48.         CPU = math.ceil(float(process.stdout.readlines()[0].split()[0]))
  49.         while process.poll() is None:
  50.             time.sleep(0.3)
  51.             now = datetime.datetime.now()
  52.             if (now - start).seconds > timeout:
  53.                 return str("0%")
  54.         return str(CPU) + "%"
  55.     except Exception:
  56.         return str("0%")
  57.  
  58. # 获取CPU 的负载值 avg1 avg5 avg15
  59. def GetCPULoadAvg(addr,port,avg,timeout):
  60.     try:
  61.         Command = "engine.exe -s {} -p {} -k system.cpu.load[,{}]".format(addr, port,avg)
  62.         start = datetime.datetime.now()
  63.         process = subprocess.Popen(Command, shell=True, stdout=subprocess.PIPE,stderr=subprocess.PIPE)
  64.         CPU = float(process.stdout.readlines()[0].split()[0])
  65.         while process.poll() is None:
  66.             time.sleep(0.3)
  67.             now = datetime.datetime.now()
  68.             if (now - start).seconds > timeout:
  69.                 return 0
  70.         return CPU
  71.     except Exception:
  72.         return 0
  73.  
  74. # 获取内存数据 返回 %
  75. def GetMemInfo(addr,port,timeout):
  76.     try:
  77.         Total = subprocess.Popen("engine.exe -s {} -p {} -k vm.memory.size[total]".format(addr, port)
  78.                                  , shell=True, stdout=subprocess.PIPE,stderr=subprocess.PIPE)
  79.         start = datetime.datetime.now()
  80.         while Total.poll() is None:
  81.             time.sleep(0.3)
  82.             now = datetime.datetime.now()
  83.             if (now - start).seconds > timeout:
  84.                 return 0
  85.         Free = subprocess.Popen("engine.exe -s {} -p {} -k vm.memory.size[free]".format(addr, port)
  86.                                 , shell=True, stdout=subprocess.PIPE,stderr=subprocess.PIPE)
  87.         start = datetime.datetime.now()
  88.         while Free.poll() is None:
  89.             time.sleep(0.3)
  90.             now = datetime.datetime.now()
  91.             if (now - start).seconds > timeout:
  92.                 return str(0)+"%"
  93.         Total = math.ceil(int(Total.stdout.readlines()[0].split()[0])/1024/1024)
  94.         Free = math.ceil(int(Free.stdout.readlines()[0].split()[0])/1024/1024)
  95.         percentage = 100 - int(Free/int(Total/100))
  96.         return str(percentage)+"%"
  97.     except Exception:
  98.         return str(0)+"%"
  99.  
  100. # 获取磁盘容量、pfree_disk 已用 、 ptotal_disk 可用
  101. def GetDisk(addr,port,timeout,diskname):
  102.     command = "engine.exe -s {} -p {} -k vfs.fs.size[\"{}\",pfree]".format(addr,port,diskname)
  103.     start = datetime.datetime.now()
  104.     process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  105.     try:
  106.         while process.poll() is None:
  107.             time.sleep(0.2)
  108.             now = datetime.datetime.now()
  109.             if (now - start).seconds> timeout:
  110.                 return 0
  111.             try:
  112.                 pfree_disk = math.ceil(float(process.stdout.readlines()[0]))
  113.                 ptotal_disk = math.ceil(100 - pfree_disk)
  114.                 return pfree_disk,ptotal_disk
  115.             except Exception:
  116.                 return 0,0
  117.     except Exception:
  118.         return 0,0
  119.  
  120. # 检测端口开启状态
  121. def GetListenPort(addr,port,timeout,check_port):
  122.     Command = "engine.exe -s {} -p {} -k net.tcp.listen[{}]".format(addr, port,check_port)
  123.     start = datetime.datetime.now()
  124.     try:
  125.         process = subprocess.Popen(Command, shell=True, stdout=subprocess.PIPE,stderr=subprocess.PIPE)
  126.         while process.poll() is None:
  127.             time.sleep(0.2)
  128.             now = datetime.datetime.now()
  129.             if (now - start).seconds> timeout:
  130.                 return 0
  131.             status = int(process.stdout.readlines()[0])
  132.             return status
  133.     except Exception:
  134.         return 0
  135.     return 0
  136.  
  137. # 检测Web服务器状态 使用LocalAddr的地址对check_addr的check_port端口进行检测
  138. def CheckWebServerStatus(Local_Addr,port,timeout,check_addr,check_port):
  139.     test_ping = "engine.exe -s {} -p 10050 -k agent.ping".format(Local_Addr)
  140.     ref = GetPing(test_ping, 1)
  141.     if ref != "异常":
  142.         Command = "engine.exe -s {} -p {} -k net.tcp.port[\"{}\",{}]".format(Local_Addr, port,check_addr,check_port)
  143.         start = datetime.datetime.now()
  144.         try:
  145.             process = subprocess.Popen(Command, shell=True, stdout=subprocess.PIPE,stderr=subprocess.PIPE)
  146.             while process.poll() is None:
  147.                 time.sleep(0.2)
  148.                 now = datetime.datetime.now()
  149.                 if (now - start).seconds> timeout:
  150.                     return 0
  151.                 status = int(process.stdout.readlines()[0])
  152.                 return status
  153.         except Exception:
  154.             return 0
  155.         return 0
  156.     return 0

接着是win32_core.py

  1. import win32_connect
  2.  
  3. def MyPing():
  4.     fp = open("win32_base.db", "r", encoding="utf-8")
  5.     count = len(open("win32_base.db", "r", encoding="utf-8").readlines())
  6.     print("-" * 100)
  7.     print("{0:20} \t {1:10} \t {2:13} \t {3:5} \t {4:9} \t {5:40}".format("IP地址","机器系统","设备SN","机房位置","存活状态","主机作用"))
  8.     print("-" * 100)
  9.     for each in range(count):
  10.         item = fp.readline().replace("\n","")
  11.         eval_list = eval(item)
  12.         command = "engine.exe -s {} -p 10050 -k agent.ping".format(eval_list[0])
  13.         ref = win32_connect.GetPing(command, 1)
  14.         print("{0:20} \t {1:15} \t {2:13} \t {3:10} \t {4:5} \t {5:40}".
  15.               format(eval_list[0],eval_list[1],eval_list[2],eval_list[3],ref,eval_list[4]))
  16.     fp.close()
  17.  
  18. # 统计系统启动进程
  19. def MyProcessCheck():
  20.     process_cache = []
  21.     proc_fp = open("win32_process.db", "r", encoding="utf-8")
  22.     count = len(open("win32_process.db", "r", encoding="utf-8").readlines())
  23.  
  24.     for each in range(1, count + 1):
  25.         proc = eval(proc_fp.readline())
  26.         proc_len = len(proc)
  27.         print("-" * 70)
  28.         print("---> 巡检地址: {}".format(proc[0]))
  29.         print("-" * 70)
  30.         for process in range(1, proc_len):
  31.             ref = win32_connect.GetProcessStatus(proc[0], 10050, 3, proc[process])
  32.             if (ref != 0):
  33.                 print("进程: {0:18} \t  进程数: {1:5} \t 状态: {2}".format(proc[process], ref, "√"))
  34.             else:
  35.                 print("进程: {0:18} \t  进程数: {1:5} \t 状态: {2}".format(proc[process], ref, "×"))
  36.         print()
  37.     proc_fp.close()
  38.  
  39. # 统计系统负载情况
  40. def GetLoadAvg():
  41.     fp = open("win32_base.db", "r", encoding="utf-8")
  42.     count = len(open("win32_base.db", "r", encoding="utf-8").readlines())
  43.     print("-" * 120)
  44.     print("IP地址 \t\t\t 系统类型 \t\t CPU利用率 \t 内存利用率 \t 1分钟负载 \t 5分钟负载 \t 15分钟负载 \t 主机位置 \t\t 主机作用")
  45.     print("-" * 120)
  46.     for item in range(count):
  47.         ptr = eval(fp.readline())
  48.         command = "engine.exe -s {} -p 10050 -k agent.ping".format(ptr[0])
  49.         flag = win32_connect.GetPing(command, 1)
  50.         if flag == "正常":
  51.             cpu_info = win32_connect.GetCPUCoreInfo(ptr[0], 10050, 1)
  52.             mem_info = win32_connect.GetMemInfo(ptr[0], 10050, 1)
  53.             cpu_load1 = win32_connect.GetCPULoadAvg(ptr[0], 10050, "avg1", 1)
  54.             cpu_load5 = win32_connect.GetCPULoadAvg(ptr[0], 10050, "avg5", 1)
  55.             cpu_load15 = win32_connect.GetCPULoadAvg(ptr[0], 10050, "avg15", 1)
  56.             print("{0:10} \t {1:15} \t {2:4} \t {3:4} \t {4:7} \t {5:7} \t {6:7} \t\t {7:10} \t {8:30}".
  57.                   format(ptr[0],ptr[1],cpu_info,mem_info,cpu_load1,cpu_load5,cpu_load15,ptr[3],ptr[4]))
  58.         else:
  59.             print("{0:10} \t {1:15} \t {2:4} \t {3:4} \t {4:7} \t {5:7} \t {6:7} \t\t {7:10} \t {7:30}".
  60.                   format(ptr[0],ptr[1],"-1","-1","-1","-1","-1",ptr[3],ptr[4]))
  61.     fp.close()
  62.  
  63. # 统计磁盘
  64. def GetFDisk():
  65.     fp = open("win32_disk.db", "r", encoding="utf-8")
  66.     count = len(open("win32_disk.db", "r", encoding="utf-8").readlines())
  67.     for each in range(1,count+1):
  68.         item = fp.readline().replace("\n", "")
  69.         eval_list = eval(item)
  70.         print()
  71.         print("-" * 80)
  72.         print("检测主机: {}".format(eval_list[0]))
  73.         print("-" * 80)
  74.         for x in range(1,(len(eval_list)-1)+1):
  75.             command = "engine.exe -s {} -p 10050 -k agent.ping".format(eval_list[0])
  76.             ref = win32_connect.GetPing(command, 1)
  77.             if ref == "正常":
  78.                 pfree,ptotal = win32_connect.GetDisk(eval_list[0], 10050, 1, eval_list[x])
  79.                 print("---> 磁盘分区: {0:10} \t 剩余空间: {1:5} \t 已用空间: {2:5}".format(eval_list[x],str(pfree)+"%",str(ptotal)+"%"))
  80.     fp.close()
  81.  
  82. # 统计Web服务器是否运行中
  83. def CheckWebServer():
  84.     fp = open("WebServer.db", "r", encoding="utf-8")
  85.     count = len(open("WebServer.db", "r", encoding="utf-8").readlines())
  86.  
  87.     for each in range(count):
  88.         fp_list = eval(fp.readline().replace("\n",""))
  89.         ref = win32_connect.CheckWebServerStatus("132.35.93.2", 10050, 1, fp_list[0], fp_list[1])
  90.         if ref == 1:
  91.             print("[成功] -> Web主机: {0:20} \t 检测端口: {1:5} \t 业务名称: {2:20}".format(fp_list[0],fp_list[1],fp_list[2]))
  92.         else:
  93.             print("*失败* -> Web主机: {0:20} \t 检测端口: {1:5} \t 业务名称: {2:20}".format(fp_list[0],fp_list[1],fp_list[2]))
  94.     fp.close()

最后的win32_engine.py

  1. import os,subprocess,sys,math
  2. import time
  3. import datetime
  4.  
  5. # 检查主机状态
  6. def GetPing(addr,port,timeout):
  7.     try:
  8.         command = "engine.exe -s {} -p {} -k agent.ping".format(addr, port).split(" ")
  9.         start = datetime.datetime.now()
  10.         process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)
  11.         while process.poll() is None:
  12.             time.sleep(1)
  13.             now = datetime.datetime.now()
  14.             if (now - start).seconds > timeout:
  15.                 return 0
  16.         return 1
  17.     except Exception:
  18.         return 0
  19.  
  20. # 获取目标主机名 仅用于Windows
  21. def GetHostName(addr,port,timeout):
  22.     try:
  23.         Command = "engine.exe -s {} -p {} -k system.hostname".format(addr,port)
  24.         start = datetime.datetime.now()
  25.         process = subprocess.Popen(Command, shell=True,stdout=subprocess.PIPE,stderr=subprocess.PIPE)
  26.         HostName = str(process.stdout.readlines()[0].split()[0],"utf-8")
  27.  
  28.         while process.poll() is None:
  29.             time.sleep(1)
  30.             now = datetime.datetime.now()
  31.             if (now - start).seconds > timeout:
  32.                 return 0
  33.         return HostName
  34.     except Exception:
  35.         return 0
  36.  
  37. # 得到系统型号，例如windows linux等
  38. def GetSysUname(addr,port,timeout):
  39.     try:
  40.         Command = "engine.exe -s {} -p {} -k system.uname".format(addr,port)
  41.         start = datetime.datetime.now()
  42.         process = subprocess.Popen(Command, shell=True,stdout=subprocess.PIPE,stderr=subprocess.PIPE)
  43.         Uname = str(process.stdout.readlines()[0].split()[0],"utf-8")
  44.  
  45.         while process.poll() is None:
  46.             time.sleep(1)
  47.             now = datetime.datetime.now()
  48.             if (now - start).seconds > timeout:
  49.                 return 0
  50.         return Uname
  51.     except Exception:
  52.         return 0
  53.  
  54. # 列出系统平台  x86 or x64
  55. def GetSysArch(addr,port,timeout):
  56.     try:
  57.         command = "engine.exe -s {} -p {} -k system.sw.arch".format(addr, port).split(" ")
  58.         start = datetime.datetime.now()
  59.         process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)
  60.         while process.poll() is None:
  61.             time.sleep(1)
  62.             now = datetime.datetime.now()
  63.             if (now - start).seconds > timeout:
  64.                 return 0
  65.         arch = process.stdout.readlines()[0].split()[0]
  66.         return str(arch,"utf-8")
  67.     except Exception:
  68.         return 0
  69.  
  70. # 获取CPU核心数
  71. def GetCPUCoreNumber(addr,port,timeout):
  72.     try:
  73.         Command = "engine.exe -s {} -p {} -k system.cpu.num[online]".format(addr,port)
  74.         start = datetime.datetime.now()
  75.         process = subprocess.Popen(Command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  76.         CpuCoreNum = process.stdout.readlines()[0].split()[0]
  77.         #print()
  78.         return str(CpuCoreNum,"utf-8")
  79.     except Exception:
  80.         return 0
  81.  
  82. # 获取CPU的利用率 10%
  83. def GetCPUCoreInfo(addr,port,timeout):
  84.     try:
  85.         Command = "engine.exe -s {} -p {} -k system.cpu.util".format(addr, port)
  86.         start = datetime.datetime.now()
  87.         process = subprocess.Popen(Command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  88.         CPU = math.ceil(float(process.stdout.readlines()[0].split()[0]))
  89.         while process.poll() is None:
  90.             time.sleep(1)
  91.             now = datetime.datetime.now()
  92.             if (now - start).seconds > timeout:
  93.                 return 0
  94.         return CPU
  95.     except Exception:
  96.         return 0
  97.  
  98. # 获取CPU 的负载值 avg1 avg5 avg15
  99. def GetCPULoadAvg(addr,port,avg,timeout):
  100.     try:
  101.         Command = "engine.exe -s {} -p {} -k system.cpu.load[,{}]".format(addr, port,avg)
  102.         start = datetime.datetime.now()
  103.         process = subprocess.Popen(Command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  104.         CPU = float(process.stdout.readlines()[0].split()[0])
  105.         while process.poll() is None:
  106.             time.sleep(1)
  107.             now = datetime.datetime.now()
  108.             if (now - start).seconds > timeout:
  109.                 return 0
  110.         return CPU
  111.     except Exception:
  112.         return 0
  113.  
  114. # 获取内存数据 返回总内存/剩余内存
  115. def GetMemInfo(addr,port,timeout):
  116.     try:
  117.         Total = subprocess.Popen("engine.exe -s {} -p {} -k vm.memory.size[total]".format(addr, port)
  118.                                  , shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  119.         Free = subprocess.Popen("engine.exe -s {} -p {} -k vm.memory.size[free]".format(addr, port)
  120.                                 , shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  121.         Total = math.ceil(int(Total.stdout.readlines()[0].split()[0])/1024/1024)
  122.         Free = math.ceil(int(Free.stdout.readlines()[0].split()[0])/1024/1024)
  123.         return Total,Free
  124.     except Exception:
  125.         return 0
  126.  
  127. # 获取全部磁盘容量
  128. def GetDiskInfo(self):
  129.     try:
  130.         Free = subprocess.Popen("engine.exe -s {} -p {} -k vfs.fs.size[/,pfree]".format(self.addr, self.port)
  131.                                  , shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  132.         Free = float(Free.stdout.readlines()[0].split()[0])
  133.         return Free
  134.     except Exception:
  135.         return 0
  136.  
  137.  
  138.  
  139. # 获取特定进程是否运行
  140. def GetProcessStatus(addr,port,procname):
  141.     command = "engine.exe -s {} -p {} -k proc.num[\"{}\"]".format(addr,port,procname)
  142.     process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)
  143.     ref = process.stdout.readlines()[0]
  144.     if ref == b"1\r\n":
  145.         return 1
  146.     return 0
  147.  
  148. # 获取端口开放状态
  149. def GetNetworkPort(addr,port,check_port):
  150.     command = "engine.exe -s {} -p {} -k net.tcp.listen[{}]".format(addr,port,check_port)
  151.     process = subprocess.Popen(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, shell=True)
  152.     ref = process.stdout.readlines()[0]
  153.     if ref == b"1\r\n":
  154.         return 1
  155.     return 0

监控unix系列，Unix_core.py

  1. import paramiko
  2.  
  3. ssh = paramiko.SSHClient()
  4. ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
  5.  
  6. # 执行命令CMD
  7. def BatchCMD(address,username,password,port,command):
  8.     try:
  9.         ssh.connect(hostname=address,username=username,password=password,port=port,timeout=2)
  10.         stdin , stdout , stderr = ssh.exec_command(command)
  11.         result = stdout.read()
  12.         if len(result) != 0:
  13.             return result
  14.         else:
  15.             return -1
  16.     except Exception:
  17.         return -1
  18.  
  19. # 通过获取主机Ping状态
  20. def GetPing():
  21.     fp = open("unix_base.db", "r", encoding="utf-8")
  22.     count = len(open("unix_base.db", "r", encoding="utf-8").readlines())
  23.     print("-" * 100)
  24.     print("{0:20} \t {1:10} \t {2:13} \t {3:5} \t {4:9} \t {5:40}".format("IP地址","机器系统","设备SN","机房位置","存活状态","主机作用"))
  25.     print("-" * 100)
  26.     for each in range(count):
  27.         ref = eval(fp.readline())
  28.         ret = BatchCMD(ref[0],ref[5],ref[6],22,"pwd | echo $?")
  29.         if(int(ret)==0):
  30.             print("{0:20} \t {1:10} \t {2:11} \t {3:5} \t {4:9} \t {5:40}".
  31.                   format(ref[0],ref[1],ref[2],ref[3],"正常",ref[4]))
  32.         else:
  33.             print("{0:20} \t {1:10} \t {2:13} \t {3:5} \t {4:9} \t {5:40}".
  34.                   format(ref[0],ref[1],ref[2],ref[3],"异常",ref[4]))
  35.     fp.close()
  36.  
  37. # ps aux | grep "usbCfgDev" | grep -v "grep" | awk {'print $2'}
  38. def GetProcessStatus():
  39.     fp = open("unix_process.db", "r", encoding="utf-8")
  40.     count = len(open("unix_process.db", "r", encoding="utf-8").readlines())
  41.     for each in range(count):
  42.         proc = eval(fp.readline())
  43.         proc_len = len(proc)
  44.         print("-" * 70)
  45.         print("---> 巡检地址: {0:10} \t 登录用户: {1:7} \t 登录密码: {2:10}".format(proc[0],proc[1],proc[2]))
  46.         print("-" * 70)
  47.         for process in range(3, proc_len):
  48.             command = "ps aux | grep \'{}\' | grep -v \'grep\' | awk '{}' | head -1".format(proc[process],"{print $2}")
  49.             try:
  50.                 ref = BatchCMD(proc[0],proc[1],proc[2],22,command)
  51.                 if(int(ref)!=-1):
  52.                     print("进程: {0:18}  \t PID: {1:10} \t 状态: {2}".format(proc[process], int(ref),"√"))
  53.                 else:
  54.                     print("进程: {0:18} \t  PID:{1:10} \t 状态: {2}".format(proc[process], 0,"×"))
  55.             except Exception:
  56.                 print("进程: {0:18} \t  PID:{1:10} \t 状态: {2}".format(proc[process], 0,"×"))
  57.         print()
  58.     fp.close()
  59.  
  60.  
  61. def GetDiskStatus():
  62.     fp = open("unix_disk.db", "r", encoding="utf-8")
  63.     count = len(open("unix_disk.db", "r", encoding="utf-8").readlines())
  64.     for each in range(count):
  65.         proc = eval(fp.readline())
  66.         proc_len = len(proc)
  67.         print("-" * 100)
  68.         print("---> 巡检地址: {0:10} \t 登录系统: {1:7} \t 登录账号: {2:10} 登录密码: {3:10}".
  69.               format(proc[0],proc[1],proc[2],proc[3]))
  70.         print("-" * 100)
  71.         try:
  72.             ref = BatchCMD(proc[0], proc[2], proc[3], 22, "df | grep -v 'Filesystem'")
  73.             st = str(ref).replace("\\n", "\n")
  74.             print(st.replace("b'", "").replace("'", ""))
  75.         except Exception:
  76.             pass
  77.         print()
  78.     fp.close()
  79.  
  80. # 运行命令
  81. def RunCmd(command,system):
  82.     fp = open("unix_disk.db", "r", encoding="utf-8")
  83.     count = len(open("unix_disk.db", "r", encoding="utf-8").readlines())
  84.     for each in range(count):
  85.         proc = eval(fp.readline())
  86.         proc_len = len(proc)
  87.  
  88.         if proc[1] == system:
  89.             print("-" * 100)
  90.             print("---> 巡检地址: {0:10} \t 登录系统: {1:7} \t 登录账号: {2:10} 登录密码: {3:10}".
  91.                   format(proc[0],proc[1],proc[2],proc[3]))
  92.             print("-" * 100)
  93.             try:
  94.                 ref = BatchCMD(proc[0], proc[2], proc[3], 22, command)
  95.                 st = str(ref).replace("\\n", "\n")
  96.                 print(st.replace("b'", "").replace("'", ""))
  97.             except Exception:
  98.                 pass
  99.     fp.close()

配置文件

  1. unix_base.db
  2. ["127.0.0.1","Suse","CN11111","C-F-04","国漫 CTI3.6","root","1111111"]
  3.  
  4. unix_disk.db
  5. ["127.0.0.1","Suse","root","123123"]
  6.  
  7. unix_process.db
  8. ["127.0.0.1","root","123123","oracle","mysqld"]
  9.  
  10. webserver.db
  11. ["127.0.0.1",8005,"跨省投诉-在线客服跨省协办"]
  12.  
  13. win32_base.db
  14. ["127.0.0.1","Windows XP","0000000","0-0-0","本地跳板机"]
  15.  
  16. win32_disk.db
  17. ["127.0.0.1","c:","d:"]
  18.  
  19. win32_port.db
  20. ["127.0.0.1","80","3421","8080"]
  21.  
  22. win32_process.db
  23. ["127.0.0.1","ilmt_tray.exe","awhost32.exe"]

比较好的改进写法

上方代码中每个表都有一份账号密码，很麻烦，第二次重写我通过一个UUID序号，来定位用户名密码等登录信息，然后在一个配置文件中包含了所有配置项，程序中对不同的项目进行解析，来实现一个配置文件配置所有的配置项，只有基础base结构存储账号密码，每个base结构对应一个UUID号，当添加进程等表时，自动根据UUID号码，来解析账号密码，这样通过序号关联，只需写一份密码即可，通过UUID相关联。

使用Django开发图形化界面

收集目标主机数据的类:

  1. import os,subprocess,sys,math
  2.  
  3. class GetSysInfo(object):
  4.     def __init__(self,addr,port):
  5.         self.addr = addr
  6.         self.port = port
  7.     def GetHostName(self):
  8.         try:
  9.             Command = "get.exe -s {} -p {} -k system.hostname".format(self.addr,self.port)
  10.             proc = subprocess.Popen(Command, shell=True,stdout=subprocess.PIPE,stderr=subprocess.PIPE)
  11.             HostName = str(proc.stdout.readlines()[0].split()[0])
  12.             return HostName
  13.         except Exception:
  14.             return 0
  15.     def GetCPUInfo(self):
  16.         try:
  17.             Command = "get.exe -s {} -p {} -k system.cpu.util".format(self.addr, self.port)
  18.             proc = subprocess.Popen(Command, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  19.             CPU = math.ceil(float(proc.stdout.readlines()[0].split()[0]))
  20.             return CPU
  21.         except Exception:
  22.             return 0
  23.     def GetMemInfo(self):
  24.         try:
  25.             Total = subprocess.Popen("get.exe -s {} -p {} -k vm.memory.size[total]".format(self.addr, self.port)
  26.                                      , shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  27.             Free = subprocess.Popen("get.exe -s {} -p {} -k vm.memory.size[free]".format(self.addr, self.port)
  28.                                     , shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  29.             Total = math.ceil(int(Total.stdout.readlines()[0].split()[0])/1024/1024)
  30.             Free = math.ceil(int(Free.stdout.readlines()[0].split()[0])/1024/1024)
  31.             return Total,Free
  32.         except Exception:
  33.             return 0
  34.  
  35.     def GetDiskInfo(self):
  36.         try:
  37.             Free = subprocess.Popen("get.exe -s {} -p {} -k vfs.fs.size[/,pfree]".format(self.addr, self.port)
  38.                                      , shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  39.             Free = float(Free.stdout.readlines()[0].split()[0])
  40.             return Free
  41.         except Exception:
  42.             return 0
  43.     def GetNetInfo(self):
  44.         try:
  45.             InModule = subprocess.Popen("get.exe -s {} -p {} -k net.if.in[ens32,bytes]".format(self.addr, self.port)
  46.                                         , shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  47.             InModule = int(InModule.stdout.readlines()[0].split()[0])
  48.             OutModule = subprocess.Popen("get.exe -s {} -p {} -k net.if.out[ens32,bytes]".format(self.addr, self.port)
  49.                                          , shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)
  50.             OutModule = int(OutModule.stdout.readlines()[0].split()[0])
  51.             return InModule,OutModule
  52.         except Exception:
  53.             return 0
  54.  
  55.  
  56. a = GetSysInfo("192.168.1.20","10050")
  57. b = a.GetNetInfo()
  58. print(b)

admin.py

Python

models.py

  1. from django.db import models
  2.  
  3. class HostInfo(models.Model):
  4.     id = models.AutoField(primary_key = True)
  5.     HostAddr = models.CharField(max_length=64,verbose_name="主机地址")
  6.     HostName = models.CharField(max_length=64,verbose_name="主机名称")
  7.     HostCPU = models.CharField(max_length=64,verbose_name="CPU利用率")
  8.     HostMem = models.CharField(max_length=64,verbose_name="内存数据")
  9.     HostDisk = models.CharField(max_length=64,verbose_name="磁盘空闲")
  10.     HostNet = models.CharField(max_length=64,verbose_name="网卡流量")

先来判断是否有指定的IP地址，有的话后端直接爬取数据并填充到数据库中，要求是只需要输入IP地址即可取出所有的数据，并自动填充，有几台自动填充几台。

  1. if __name__ == "__main__":
  2.     conn = sqlite3.connect("C:/Users/LyShark/PycharmProjects/MyProject/db.sqlite3")
  3.     cursor = conn.cursor()
  4.     cursor.execute('select * from MyWeb_hostinfo;')
  5.     data = cursor.fetchall()
  6.  
  7.     for item in range(0,len(data)):
  8.         addr = data[item][1]
  9.         info = GetSysInfo(addr,"10050")
  10.         print(info.GetNetInfo())

fabric的使用技巧 fabric工具也是自动化运维利器,其默认依赖于paramiko的二次封装.

  1. # 简单实现命令执行
  2. from fabric import Connection
  3. conn = Connection(host="192.168.1.10",user="root",port="22",connect_kwargs={"password":"123"})
  4. try:
  5.     with conn.cd("/var/www/html/"):
  6.         ret = conn.run("ls -lh",hide=True)
  7.         print("主机:" + conn.host + "端口:" + conn.port + "完成")
  8. except Exception:
  9.     print("主机:" + conn.host + "端口:" + conn.port + "失败")
  10.  
  11. # 读取数据到本地
  12. from fabric import Connection
  13. conn = Connection(host="192.168.1.20",user="root",port="22",connect_kwargs={"password":"123"})
  14.  
  15. uname = conn.run('uname -s', hide=True)
  16. if 'Linux' in uname.stdout:
  17.     command = "df -h / | tail -n1 | awk '{print $5}'"
  18.     print(conn.run(command,hide=True).stdout.strip())
  19.  
  20. # 文件上传与下载
  21. from fabric import Connection
  22. conn = Connection(host="192.168.1.20",user="root",port="22",connect_kwargs={"password":"123"})
  23. conn.put("D://zabbix_get.exe","/tmp/zabbix.exe")  # 文件上传
  24. conn.get("/tmp/zabbix.exe","./zab.exe")           # 下载文件
声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/天景科技苑/article/detail/775067
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号