最近在搞kafka的监控，主要是通过jmx端口来获取item和对应的值。

由于监控项比较多，直接通过api来添加item就方便很多。。

简单写了一个脚本，调用api来批量添加item，写得比较简单(哈哈，异常都懒得去处理了。)，有兴趣的同学可以扩展下。

首先手动获取template的hostid和item的app id。

1
2
select 
hostid,
name 
from 
hosts  
where 
name 
like 
'%spark%'
;
select 
* 
from 
applications 
order 
by 
applicationid 
desc 
limit 5;

使用下面脚本创建对应的item:

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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
import 
os
import 
subprocess
import 
urllib2
import 
sys
import 
json
def 
requestJason(url,values):
    
data 
= 
json.dumps(values)
    
req 
= 
urllib2.Request(url, data, {
'Content-Type'
: 
'application/json-rpc'
})
    
response 
= 
urllib2.urlopen(req, data)
    
data_get 
= 
response.read()
    
output 
= 
json.loads(data_get)
    
print 
output
    
try
:
        
message 
= 
output[
'result'
]
    
except
:
        
message 
= 
output[
'error'
][
'data'
]
        
raise 
Exception(message)
    
print 
json.dumps(message)
    
return 
output
def 
authenticate(url, username, password):
    
values 
= 
{
'jsonrpc'
: 
'2.0'
,
              
'method'
: 
'user.login'
,
              
'params'
: {
                  
'user'
: username,
                  
'password'
: password
              
},
              
'id'
: 
'0'
              
}
    
idvalue 
= 
requestJason(url,values)
    
return 
idvalue[
'result'
]
def 
createitem(itemname,itemkey):
    
url 
= 
'http://xxx/api_jsonrpc.php'
    
username 
= 
'xxx'
    
password 
= 
'xxx'
    
auth 
= 
authenticate(url, username, password)
    
values 
= 
(
           
{
'jsonrpc'
: 
'2.0'
,
            
"method"
: 
"item.create"
,
            
"params"
: {
            
"name"
:itemname,
            
"key_"
:itemkey,
            
"hostid"
: xxxx,
            
"applications"
: xxxx,
            
"type"
:
"7"
,
            
"delay"
:
"60"
,
            
"value_type"
:
"0"
,
                  
},
            
"auth"
: auth,
            
"id"
: 
'3'
    
})
    
print 
values
    
output 
= 
requestJason(url,values)
    
print  
output[
'result'
]
if 
__name__ 
=
= 
'__main__'
:
    
f
=
open
(
'/tmp/kafka.log'
,
'r'
)
    
for 
i 
in 
f.readlines():
        
cmd 
= 
"""
        
java -jar /apps/sh/zabbix_scripts/java/cmdline-jmxclient-0.10.3.jar - 127.0.0.1:9999 '%s' |grep -B 100 Operations|egrep -v 'Attributes|Operations'|awk '{print $1}'|sed 's/://g'
        
""" 
% 
(i.strip())
        
itemname 
= 
i.strip().split(
'='
)[
1
].replace(
',type'
,'
').replace('
"
','
')
        
p 
= 
subprocess.Popen(cmd, stdin 
= 
subprocess.PIPE,stdout 
= 
subprocess.PIPE, stderr 
= 
subprocess.PIPE, shell 
= 
True
)
        
itemname2 
= 
i.strip().replace(
'"'
,'')
        
for 
x 
in 
p.stdout.readlines():
            
if 
'RateUnit' 
in 
x 
or 
'EventType' 
in 
x:
                
pass
            
else
:
                
#print "9093_" + itemname + "_" + x.strip() + " kafka[9999,"+ itemname2 + "," + x.strip() + ']'
                
itemnamex 
= 
"9093_" 
+ 
itemname 
+ 
"_" 
+ 
x.strip()
                
itemkeyx 
= 
"kafka[9999,"
+ 
itemname2 
+ 
"," 
+ 
x.strip() 
+ 
']'
                
print 
itemnamex,itemkeyx
                
createitem(itemnamex,itemkeyx)
                
try
:
                    
createitem(itemnamex,itemkeyx)
                
except 
Exception,e:
                    
print 
str
(e)
    
f.close()