由于需要知道公司资产中的相关服务器是否在zabbix的监控中，有些是不需要监控的，有些是资产更新之后zabbix没有监控的，要是一个个的去对比，比较麻烦，闲来无事，写了一个脚本，对比资产中的机器是否需要zabbix监控，然后发邮件给相关的负责人，及时的更新zabbix监控主机。主要原理是用MySQLdb模块查出zabbix中的主机和资产数据库中的主机列表，然后用列表的集合比较set来找出两个列表中不同的值，然后查看确定是在那个列表中，以不同的信息标识发邮件给负责人。

1. #!/bin/env python
2. # -*- coding: utf-8 -*-
3. import os,sys,MySQLdb,smtplib,datetime,time
4. from email.mime.text import MIMEText
5. def send_mail(content):
6. #############
7. #要发给谁，这里发给1个人
8. mailto_list=["xxxxx@139.com"]
9. #####################
10. #设置服务器，用户名、口令以及邮箱的后缀
11. mail_host="mail.xxx.cn"
12. mail_user="zabbix"
13. mail_pass="xxx"
14. mail_postfix="xxxx.cn"
15. ######################
16. '''''
17. to_list:发给谁
18. sub:主题
19. content:内容
20. send_mail("aaa@126.com","sub","content")
21. '''
22. me=mail_user+"<"+mail_user+"@"+mail_postfix+">"
23. msg = MIMEText(content,_charset='utf8')
24. msg['Subject'] = u"zabbix主机检查-%s" % datetime.date.today()
25. msg['From'] = me
26. msg['To'] = ";".join(mailto_list)
27. try:
28. s = smtplib.SMTP()
29. s.connect(mail_host)
30. s.login(mail_user,mail_pass)
31. s.sendmail(me, mailto_list, msg.as_string())
32. s.close()
33. except Exception, e:
34. sys.exit()
35. def conn_mysql(ip,user,passwd,sql):
36. try:
37. conn = MySQLdb.connect(host = ip,user = user,passwd = passwd,connect_timeout=20)
38. cursor = conn.cursor()
39. cursor.execute(sql)
40. alldata = cursor.fetchall()
41. cursor.close()
42. conn.close()
43. return alldata
44. except:
45. return 0
46. def center_host():#查出资产中需要监控的IP
47. ip = '192.168.1.11'
48. user = 'root'
49. passwd = 'xxxxx'
50. sql="SELECT ip FROM zichan.hosts WHERE STATUS=0"
51. center_hostlist = conn_mysql(ip,user,passwd,sql)
52. center = []
53. for center_host in center_hostlist:
54. center.append(center_host[0])
55. center.sort()
56. return center
57. def zabbix_host():#查出zabbix数据库中正在监控的IP
58. ip = '192.168.1.2'
59. user = 'root'
60. passwd = '1q2w3e4r'
61. sql="SELECT HOST FROM zabbix.hosts WHERE STATUS=0"
62. zabbix_hostlist = conn_mysql(ip,user,passwd,sql)
63. zabbix = []
64. for zabbix_host in zabbix_hostlist:
65. zabbix.append(zabbix_host[0])
66. zabbix.sort()
67. return zabbix
68. def main():
69. center_hostlist = center_host()
70. zabbix_hostlist = zabbix_host()
71. #center_hostlist = ['192.168.1.21']
72. #zabbix_hostlist = ['192.168.1.43']
73. difference = list(set(center_hostlist) ^ set(zabbix_hostlist))
74. content = "\n"
75. if len(difference) != 0:
76. for host in difference:
77. if host in center_hostlist:
78. content = content + "%s_not_In_zabbix" % host + "\n"
79. elif host in zabbix_hostlist:
80. content = content + "%s_not_Out_zabbix" % host + "\n"
81. else:
82. sys.exit()
83. send_mail(content)
84. if __name__ == "__main__":
85. main()