下面我們一起來(lái)看一個(gè)關(guān)于Zabbix與RRDtool繪圖之創(chuàng)建每臺(tái)主機(jī)每張圖的rrd文件文章，希望這個(gè)例子可以給你有幫助。
RRDtool對(duì)于圖形展示有多優(yōu)秀，想必懂的人都知道。
兵馬未動(dòng)糧草先行。搞IT的得手冊(cè)先行RRDtool的官方手冊(cè)地址 還有ailms整理的“RRDtool簡(jiǎn)體中文教程 v1.01” 該教材通俗易懂，先膜拜下!基本看了alims的 那個(gè)教程就對(duì)RRDtool清楚了。
我創(chuàng)建每臺(tái)主機(jī)每張rrd文件用的是多線程，遍歷每張圖的時(shí)間大概12秒的樣子，千張圖的rrd文件創(chuàng)建大概2分鐘的樣子，主要受硬件的限制，如果
有更快的硬盤和更多的線程應(yīng)該會(huì)快不少。rrd文件分類參考了cacti的風(fēng)格，創(chuàng)建的rrd文件按主機(jī)ID分文件夾存放(hostid)，每張圖的名稱
由圖形ID和.rrd后綴組成(graphid.rrd)。
創(chuàng)建每個(gè)rrd文件的py模塊如下，寫的有點(diǎn)笨，有多少個(gè)不同的item組成的圖形就得定義不同的創(chuàng)建函數(shù)，我找了一個(gè)下午都沒(méi)有找到更好的傳參方法，先
就用這個(gè)笨方法。記住有幾種DS就需要寫對(duì)應(yīng)的Item函數(shù)，下面我只列出Item03，我是不會(huì)告訴你們我總共堆了24個(gè)一直到Item24
代碼如下復(fù)制代碼
#!/usr/bin/env python
#coding=utf-8
import rrdtool
def Item01(rrdname, startStamp, DS):
rrdtool.create(rrdname, '--step', '60', '--start', startStamp, DS[0],
'RRA:AVERAGE:0.5:1:3000',
'RRA:AVERAGE:0.5:5:4200',
'RRA:AVERAGE:0.5:24:3800',
'RRA:AVERAGE:0.5:240:4400',
'RRA:MAX:0.5:1:3000',
'RRA:MAX:0.5:5:4200',
'RRA:MAX:0.5:24:3800',
'RRA:MAX:0.5:240:4400',
'RRA:MIN:0.5:1:3000',
'RRA:MIN:0.5:5:4200',
'RRA:MIN:0.5:24:3800',
'RRA:MIN:0.5:240:4400')
def Item02(rrdname, startStamp, DS):
rrdtool.create(rrdname, '--step', '60', '--start', startStamp, DS[0],
DS[1],
'RRA:AVERAGE:0.5:1:3000',
'RRA:AVERAGE:0.5:5:4200',
'RRA:AVERAGE:0.5:24:3800',
'RRA:AVERAGE:0.5:240:4400',
'RRA:MAX:0.5:1:3000',
'RRA:MAX:0.5:5:4200',
'RRA:MAX:0.5:24:3800',
'RRA:MAX:0.5:240:4400',
'RRA:MIN:0.5:1:3000',
'RRA:MIN:0.5:5:4200',
'RRA:MIN:0.5:24:3800',
'RRA:MIN:0.5:240:4400')
def Item03(rrdname, startStamp, DS):
rrdtool.create(rrdname, '--step', '60', '--start', startStamp, DS[0],
DS[1], DS[2],
'RRA:AVERAGE:0.5:1:3000',
'RRA:AVERAGE:0.5:5:4200',
'RRA:AVERAGE:0.5:24:3800',
'RRA:AVERAGE:0.5:240:4400',
'RRA:MAX:0.5:1:3000',
'RRA:MAX:0.5:5:4200',
'RRA:MAX:0.5:24:3800',
'RRA:MAX:0.5:240:4400',
'RRA:MIN:0.5:1:3000',
'RRA:MIN:0.5:5:4200',
'RRA:MIN:0.5:24:3800',
'RRA:MIN:0.5:240:4400')
基本創(chuàng)建rrd文件的模塊寫好了，然后組織數(shù)據(jù)、調(diào)用函數(shù)傳遞相應(yīng)的參數(shù)就可以了，下面是我寫的一個(gè)多線程程序，同時(shí)啟用16個(gè)線程工作(CPU線程數(shù)的2倍)?？筛木€程數(shù)適應(yīng)不同的硬件環(huán)境。
代碼如下復(fù)制代碼
#!/usr/bin/env python
#coding=utf-8
from zabbixget import Zabbix
from time import ctime
import threading
import createsub
import os
import time, datetime
def rrd_create(grinfo):
#如果主機(jī)存放rrd圖形目錄不存在,則創(chuàng)建
bashdir = "/opt/rrd/"
path = bashdir + grinfo[0]['hostid'] + "/"
if not os.path.exists(path):
os.makedirs(path)
rrdname = str(path + grinfo[0]['graphid'] + '.rrd')
timeDaysAgo = (datetime.datetime.now() - datetime.timedelta(days = 730))
startStamp = str(int(time.mktime(timeDaysAgo.timetuple())))
DS = []
for sub in grinfo:
DStmp = str('DS:' + sub['itemid'] + ':GAUGE:120:0:U')
DS.append(DStmp)
if len(DS) == 1: createsub.Item01(rrdname, startStamp, DS)
elif len(DS) == 2: createsub.Item02(rrdname, startStamp, DS)
elif len(DS) == 3: createsub.Item03(rrdname, startStamp, DS)
elif len(DS) == 4: createsub.Item04(rrdname, startStamp, DS)
elif len(DS) == 5: createsub.Item05(rrdname, startStamp, DS)
elif len(DS) == 6: createsub.Item06(rrdname, startStamp, DS)
elif len(DS) == 7: createsub.Item07(rrdname, startStamp, DS)
elif len(DS) == 8: createsub.Item08(rrdname, startStamp, DS)
elif len(DS) == 9: createsub.Item09(rrdname, startStamp, DS)
elif len(DS) == 10: createsub.Item10(rrdname, startStamp, DS)
elif len(DS) == 11: createsub.Item11(rrdname, startStamp, DS)
elif len(DS) == 12: createsub.Item12(rrdname, startStamp, DS)
elif len(DS) == 13: createsub.Item13(rrdname, startStamp, DS)
elif len(DS) == 14: createsub.Item14(rrdname, startStamp, DS)
elif len(DS) == 15: createsub.Item15(rrdname, startStamp, DS)
elif len(DS) == 16: createsub.Item16(rrdname, startStamp, DS)
elif len(DS) == 17: createsub.Item17(rrdname, startStamp, DS)
elif len(DS) == 18: createsub.Item18(rrdname, startStamp, DS)
elif len(DS) == 19: createsub.Item19(rrdname, startStamp, DS)
elif len(DS) == 20: createsub.Item20(rrdname, startStamp, DS)
elif len(DS) == 21: createsub.Item21(rrdname, startStamp, DS)
elif len(DS) == 22: createsub.Item22(rrdname, startStamp, DS)
elif len(DS) == 23: createsub.Item23(rrdname, startStamp, DS)
elif len(DS) == 24: createsub.Item24(rrdname, startStamp, DS)
def rrd_update(rrdfile, data):
pass
def hosts_get():
global zb
zb = Zabbix()
hostsName = zb.hostsid_get()
return hostsName
#遍歷每臺(tái)主機(jī)每張圖的每個(gè)項(xiàng)目的最新10的值,后來(lái)考慮到api的壓力改成每張圖的最新值(減少了一個(gè)for循環(huán)變量items)
def items_get(host):
bashdir = "/opt/rrd/"
graphsName = zb.hostgraph_get(host.keys())
for graph in graphsName:
grapitem = zb.graphitems_get(graph['graphid'])
rrdfile = bashdir + host.values()[0] + "/" + str(graph['graphid']) + '.rrd'
if os.path.isfile(rrdfile):
data = []
for item in grapitem:
tmp = {'itemid':item['itemid'],'lastvalue':item['lastvalue']}
data.append(tmp)
rrd_update(rrdfile, data)
print data
else:
grinfo = []
for item in grapitem:
tmp = {'hostid': host.values()[0], 'graphid': graph['graphid'], 'itemid': item['itemid']}
grinfo.append(tmp)
rrd_create(grinfo)
def main():
threads = []
keys = hosts_get()
numkey = len(keys)
loop = 0
for i in range(0, numkey, 16):
nkeys = range(loop*16, (loop+1)*16, 1)
for i in nkeys:
if i >= numkey:
break
else:
t = threading.Thread(target=items_get, args=(keys[i],))
threads.append(t)
for i in nkeys:
if i >= numkey:
break
else:
threads[i].start()
for i in nkeys:
if i >= numkey:
break
threads[i].join()
loop = loop + 1
if __name__ == "__main__":
main()
上面還有更新數(shù)據(jù)的函數(shù)沒(méi)有寫完，用pass站位。過(guò)多的解釋就不用了，對(duì)著相應(yīng)的注釋大家都應(yīng)該看的懂。