「Zabbixで１つのディスカバリリールに広いIPレンジのネットワークディスカバリを設定するとディスカバリに時間がかかる。」こんな問題に遭遇した方も何人かいらっしゃるかと思います。
これはZabbixのネットワークディスカバリが１ディスカバリルールは１ディスカバリプロセスで処理する仕様になっているからです。
その為、ディスカバリプロセスを増やしてもディスカバリ時間は短縮されません。
※：ディスカバリルールが複数ある場合は、ディスカバリプロセスの数を増加させるのは有効です。
上記について下記の改善要望を登録しましたが、今だ投票数0で改善される見通しが立っていません。
ZBXNEXT-2732 Load balancing of the discovery process
現在の仕様「１ディスカバリルールは１ディスカバリプロセスで処理」でディスカバリ時間を短縮するには、広範囲のIPレンジを細かく分割して登録すれば良いのですが、いちいち細かく計算するのは面倒ですし時間がかかります。
それならZabbixAPIの「drule.create」を使ってIP範囲を分割して登録するスクリプトを作成すれば良いのではないかと考え、IP範囲を分割するロジックを考えたらできてしまいました。
先程のZBXNEXT-2732にも添付してあるのですが、スクリプトはPythonで下記になります。
splite_drule.py
# -*- coding: utf-8 -*-
import sys, json, urllib2
headers = {"Content-Type":"application/json-rpc"}
# login
def login(usr, pw, url, headers):
auth_post = json.dumps({'jsonrpc':'2.0', 'method':'user.login', 'params':{'user':usr, 'password':pw}, 'auth':None, 'id': 1})
req = urllib2.Request(url, auth_post, headers)
res = urllib2.urlopen(req)
jdata = json.loads(res.read())
if "error" in jdata:
print auth_post
error = jdata["error"]
print error["message"]
print error["code"]
print error["data"]
quit()
return jdata["result"]
# file read
def get_drule(flnm):
f = open(flnm)
jdata = json.load(f)
f.close()
return jdata
# get name
def get_name(jdata):
params = jdata["params"]
return params["name"]
# set params
def set_params(jdata, iprange, name):
params = jdata["params"]
params["iprange"] = iprange
params["name"] = name
return params
# chk iprange
def chk_iprange(iprange, out):
if iprange.find("/")==-1:
print 'Bad IP Range: '+iprange
print ' "/" does not exist in the string'
return False
if iprange.count("/")!=1:
print 'Bad IP Range: '+iprange
print ' "/" there is more than one in a string'
return False
tmp = iprange.split("/")
out[0] = tmp[0]
out[1] = tmp[1]
if not out[1].isdigit():
print 'Bad IP Range: '+iprange
print ' prefix is not numeric'
return False
if int(out[1]) <= 0 or int(out[1]) >= 24:
print 'Bad IP Range: '+iprange
print ' prefix Range : 0 < prefix < 24'
return False
tmp = out[0].split(".")
out[2] = tmp[0]
out[3] = tmp[1]
out[4] = tmp[2]
out[5] = tmp[3]
if not out[2].isdigit():
print 'Bad IP Range: '+iprange
print ' octet 1 is not numeric'
return False
if int(out[2]) < 0 or int(out[2]) > 255:
print 'Bad IP Range: '+iprange
print ' octet 1 Range : 0 <= octet 1 <= 255'
return False
if not out[3].isdigit():
print 'Bad IP Range: '+iprange
print ' octet 2 is not numeric'
return False
if int(out[3]) < 0 or int(out[3]) > 255:
print 'Bad IP Range: '+iprange
print ' octet 2 Range : 0 <= octet 2 <= 255'
return False
if not out[4].isdigit():
print 'Bad IP Range: '+iprange
print ' octet 3 is not numeric'
return False
if int(out[4]) < 0 or int(out[4]) > 255:
print 'Bad IP Range: '+iprange
print ' octet 3 Range : 0 <= octet 3 <= 255'
return False
if not out[5].isdigit():
print 'Bad IP Range: '+iprange
print ' octet 4 is not numeric'
return False
if int(out[5]) < 0 or int(out[5]) > 255:
print 'Bad IP Range: '+iprange
print ' octet 4 Range : 0 <= octet 4 <= 255'
return False
return True
# chk split
def chk_split(prefix, sp):
if not sp.isdigit():
print 'Bad split: ' + sp
print ' split is not numeric'
return False
if int(sp) <= 1 or int(sp) > 24:
print 'Bad split Range: ' + sp
print ' split Range : 1 <= split <= 24'
return False
if int(sp) <= int(prefix):
print 'Bad prefix(' + prefix + ') & split(' + sp + ')'
print ' prefix < split'
return False
return True
# create drule
def create_drule(url, jdata, iprange, sp, name):
tmp = ["","","","","",""]
if not chk_iprange(iprange, tmp):
return False
ip = tmp[0]
prefix = tmp[1]
o1 = tmp[2]
o2 = tmp[3]
o3 = tmp[4]
o4 = tmp[5]
if not chk_split(prefix, sp):
return False
sum = (int(o1) << 24 | int(o2) << 16 | int(o3) << 8 | int(o4) ) & (0xFFFFFFFF - (2 ** (32 - int(sp))))
sum = sum >> (32-int(prefix))
sum = sum << (32-int(prefix))
for i in range(0, 2 << (int(sp) - int(prefix) - 1)):
a = sum | (i<<8) * (2 ** (24 - int(sp)))
# split
o1 = (a & 0xFF000000) >> 24
o2 = (a & 0x00FF0000) >> 16
o3 = (a & 0x0000FF00) >> 8
o4 = 0
tmp = str(o1) + "." + str(o2) + "." + str(o3) + "." + str(o4)
jdata["params"] = set_params(jdata, tmp + "/" + sp, name + str(i+1))
# debug
# print json.dumps(jdata)
req = urllib2.Request(url, json.dumps(jdata), headers)
res = urllib2.urlopen(req)
ret = json.loads(res.read())
if "error" in ret:
print name + str(i+1)
print tmp
error = ret["error"]
print error["message"]
print error["code"]
print error["data"]
return False
return True
# main
if len(sys.argv) != 7:
print "Usage : python splite_drule.py <url> <user> <password> <iprange> <split> <json file>"
quit()
jdata = get_drule(sys.argv[6])
jdata["auth"] = login(sys.argv[2], sys.argv[3], sys.argv[1], headers)
name = get_name(jdata)
ret = create_drule(sys.argv[1], jdata, sys.argv[4], sys.argv[5], name)
if ret:
print "Ok"
else:
print "Ng"
因みにPythonは殆ど書いたことが無く書き方がPythonっぽくないようです。(笑)
使い方は下記の通りで、url、ユーザ、パスワード、IP範囲、分割範囲、drule.createを書いたjsonファイルを指定します。
python splite_drule.py <url> <user> <password> <iprange> <split> <json file>
<url> : http://192.xxx.xx.xxx/zabbix/api_jsonrpc.php
<user> : admin
<password> : zabbix
<iprange> : 192.168.0.0/16
<split> : 19
<json file> : /tmp/drule.json
以下、実行例
この状態で…
以下を実行すると…
]# python splite_drule.py http://xxx.xxx.xxx.xxx/zabbix/api_jsonrpc.php admin zabbix 192.111.1.0/16 19 /usr/local/src/dru
le.json
Ok
こんな感じにIP範囲が分割されて登録されます。
実行エラーはこんな感じで出ます。(2重登録のエラーになります。)
]# python splite_drule.py http://xxx.xxx.xxx.xxx/zabbix/api_jsonrpc.php admin zabbix 192.111.1.0/16 19 /usr/local/src/drule.json
Zabbix agent discovery1
192.111.0.0
Invalid params.
-32602
Discovery rule "Zabbix agent discovery1" already exists.
Ng
上記で使用したdrule.createを書いたjsonファイルは下記になります。
drule.json
{
"jsonrpc": "2.0",
"method": "drule.create",
"params": {
"name": "Zabbix agent discovery",
"iprange": "iprange",
"dchecks": [
{
"type": "12"
}
],
"status" :"1"
},
"auth": "auth",
"id": 1
}
例ではICMP pingを使用していますが、他のチェック(FTP、HTTP、…、Zabbixエージェント)でも可能です。
因みに、drule.jsonを一から手で作ると面倒と言う方は元になるディスカバリルールをWebインタフェースから登録して、ZabbixAPIのdrule.get登録したルールを取得して下さい。
取得した結果から不要なパラメータせばOKです。(ReadOnly項目は除外してください。)
詳しくはZabbixAPIのDiscovery check objectを見て欲しいです。