[原创] zabbix4.4 利用 API 实现 web 监控批量添加（完美版）

发表于 更新于 分类于 阅读次数：

2020/07/08 更新：

修复一个 BUG：
1. 因 web 监控名称不能大于 64 个字符。weblist.txt 一行文字，如果大于 64，文字说明会自动切割。

最近添加一些 web 监控，大伙都知道添加 web 监控需要先添加 web 页后，还得为每个 web 页配置触发器。如果监控数量多的话，用人工添加的方式。肯定是太费时了。所以上网找了一些资料，总结下来大概有三种方式
1. 用 zabbix 的 API 实现。
2. 直接往 zabbix 的数据库里写 web 监控项。
3. 利用 zabbix 的自动发现来实现。

权衡比较了一下，发现用 api 来实现算是比较方便的。（实际是我对 python 和 shell 很熟，实现起来比较方便）。参考了一下，这篇文章。发现有些地方还是不完善。所以自己用手修改了一下。
对比原作者的 python 脚本，新增功能如下：
1. 能自定义监控网站说明。
2. 原脚本只有添加告警触发器，而没有恢复告警触发器。
3. 读取.txt 文件，批量添加。

python 正式代码如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
#!/usr/bin/env python3
# Author:         思想就是武器 https://zealot.top
# Mail:           18976787@qq.com
from pyzabbix import ZabbixAPI
import sys
from re import compile,IGNORECASE
ZABBIX_SERVER = ""
USER = ""
PASSWORD = ""
HOSTNAME = ""
def login(ZABBIX_SERVER,USER,PASSWORD):
  zapi = ZabbixAPI(ZABBIX_SERVER)
  zapi.login(USER,PASSWORD)
  return zapi
def gethostid(auth,HOSTNAME):
  request = ZabbixAPI.do_request(auth, 'host.get', params={ "filter": {"host":HOSTNAME}})
  if request['result']:
    return request['result'][0]['hostid']
  else:
    print ("找不到该主机")
    sys.exit(1)
def getapplicationid(auth,hostid):
  try:
    request = ZabbixAPI.do_request(auth, 'application.create', params={"name": "web监控","hostid": hostid})
  except Exception as e:
    print(e)
  request = ZabbixAPI.do_request(auth, 'application.get', params={"hostids": hostid})
  for num in range(0,len (request['result'])):
    if request['result'][num]['name'] == "web监控":
      return request['result'][num]['applicationid']
def create_web_scenario(auth,URL,URL1,hostid,applicationid):
  request = ZabbixAPI.do_request(auth, 'httptest.get', params={ "filter": {"name": URL}})
  if request['result']:
    print('该web监控已经添加过了' )
  else:
    try:
      ZabbixAPI.do_request(auth, 'httptest.create',params={"name": URL,"hostid": hostid,"applicationid": applicationid, "delay": '60s',"retries": '3', "steps": [ { 'name': URL1, 'url': URL1, 'no': '1', 'status_codes': r'200'} ] } )
    except Exception as e:
      print(e)
def create_trigger(auth,HOSTNAME,URL,URL1):
  expression="{"+"{0}:web.test.fail[{1}].last()".format(HOSTNAME,URL)+"}"+"<>0"
  recovery_expression="{"+"{0}:web.test.fail[{1}].last()".format(HOSTNAME,URL)+"}"+"=0"
  try:
    ZabbixAPI.do_request(auth, 'trigger.create', params={"description": "{0}-WEB无法访问".format(URL),"expression": expression,"priority":"5","recovery_mode": "1","recovery_expression": recovery_expression})
  except Exception as e:
    print(e)


with open('weblist.txt','r') as f:
  for x in f.readlines():
    URL=x
    URL1=URL.split('：',1)[1]
    if len(URL) > 64 :
      URL=URL.split('：',1)[0]
    auth = login(ZABBIX_SERVER,USER,PASSWORD)
    hostid = gethostid(auth,HOSTNAME)
    applicationid=getapplicationid(auth,hostid)
    create_web_scenario(auth,URL,URL1,hostid,applicationid)
    create_trigger(auth,HOSTNAME,URL,URL1)

使用方法：
1. 自行补齐，ZABBIX_SERVER，USER,PASSWORD,HOSTNAME 这 4 个变量。
2. 在脚本目录下，新键 weblist.txt 文件。每行 examples 如下

1
百度：http://www.baidu.com

3. 更多 API 参数，可以参考 zabbix 官网说明