root / util / rrd2json.py @ 04733cdb
History | View | Annotate | Download (1.3 kB)
1 |
# -*- coding: utf-8 -*- vim:encoding=utf-8:
|
---|---|
2 |
# vim: tabstop=4:shiftwidth=4:softtabstop=4:expandtab
|
3 |
|
4 |
import json |
5 |
|
6 |
def rrd2json(rrdexport): |
7 |
time = rrdexport[0][0] |
8 |
step = rrdexport[0][2] |
9 |
ds0 = rrdexport[1][0] |
10 |
ds1 = rrdexport[1][0] |
11 |
ds0_l = [] |
12 |
ds1_l = [] |
13 |
for tuplevals in rrdexport[2]: |
14 |
if tuplevals[0] is None: |
15 |
pass
|
16 |
else:
|
17 |
ds0_l.append([time*1000, tuplevals[0]]) |
18 |
if tuplevals[1] is None: |
19 |
pass
|
20 |
else:
|
21 |
ds1_l.append([time*1000, tuplevals[1]]) |
22 |
time = time + step |
23 |
|
24 |
ret_dict = {'ds0': ds0_l, 'ds1':ds1_l} |
25 |
|
26 |
return ret_dict
|
27 |
# return
|
28 |
# sys.stdout.write(" {\n \"Key1\":\"" + rrdexport[1][0] +\
|
29 |
# "\",\n \"Key2\":\"" + "abcd" +\
|
30 |
# "\",\n \"metric_name\":\"" + "cpu_system" + "\",\n")
|
31 |
|
32 |
# firstDP = True
|
33 |
# sys.stdout.write(" \"datapoints\":[\n")
|
34 |
# for tuple in rrdexport[2]:
|
35 |
# if tuple[0] is not None:
|
36 |
# if not firstDP:
|
37 |
# sys.stdout.write(",\n")
|
38 |
# firstDP = False
|
39 |
# sys.stdout.write(" [")
|
40 |
# sys.stdout.write(str(tuple[0]))
|
41 |
# sys.stdout.write(",")
|
42 |
# sys.stdout.write(str(time))
|
43 |
# sys.stdout.write("]")
|
44 |
# time = time + step
|
45 |
# sys.stdout.write("\n ]\n }")
|
46 |
# print rrdexport
|