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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
import rrdtool
import os
import sys
class RRD:
hdr_item = 0
ds_item = 1
data_item = 2
DS = {'active':0, 'buddies':0, 'instances':0, 'new':0, 'resumed':0, 'uptime':0}
def __init__(self, path, name, date_start, date_end):
self.rrd_name = name
if date_start == None:
self.date_start = str(rrdtool.first(str(os.path.join (path,name))))
else:
self.date_start = str(date_start)
if date_end == None:
self.date_end = str(rrdtool.last(str(os.path.join(path, name))))
else:
self.date_end = str(date_end)
self.user_hash = os.path.split(path)[1]
self.user_path = os.path.join (
self.get_first_part_path(path, 3),
"users",
"user",
self.user_hash[:2],
self.user_hash
)
self.uuid = self.get_uuid_from_file(self.user_path)
print "*******************************************"
print " RRD "
print "start: " + self.date_start
print "end: " + self.date_end
print "PATH: " + path
print "RRD NAME: " + name
print "\n"
try:
self.rrd = rrdtool.fetch (str(os.path.join(path,name)), 'AVERAGE', '-r 60', '-s '+ self.date_start, '-e '+self.date_end)
except:
raise
print " DS "
for item in self.DS.keys():
idx = self.get_ds_index (item)
if idx != -1:
self.DS[item] = idx
print "DS "+ item + ": " + str(self.DS[item])
else:
print "DS "+ item + " not found in header"
print "***********************************************"
def get_ds_index(self, ds):
i=0
for i in range (len (self.rrd[self.ds_item])):
if self.rrd[self.ds_item][i] == ds:
return i
i=+1
return -1
def get_uptime_by_interval (self):
ds_name = "uptime"
res=list()
print "-------Calcule "+ ds_name +"-------"
i=0
found = False
while i < len(self.rrd[self.data_item]):
value = str(self.rrd[self.data_item][i][self.DS[ds_name]])
if value != "None":
uptime = value
end = str (long(self.date_start) + ((i+1) * 60))
if found == False:
found = True
start = str (long (self.date_start) + ((i+1) * 60))
else:
if found:
print start + "->" + end + ": " + uptime
if float(uptime) > 0:
res.append((start, uptime))
found = False
i=i+1
return res
print "---------------------------------------------------"
def get_name(self):
return self.rrd_name.partition(".rrd")[0]
def show_valid_ds(self, ds_name):
print "------------------- DS "+ ds_name +"---------------------"
i=0
while i < len(self.rrd[self.data_item]):
timestamp = str (long (self.date_start) + ((i+1) * 60))
value = str (self.rrd[self.data_item][i][self.DS[ds_name]])
if value != "None":
print timestamp+ ": " + value
i=i+1
print "---------------------------------------------------"
def get_date_last_record(self):
return self.date_end
def set_user_hash(self, u_hash):
self.user_hash = u_hash
def get_first_part_path (self, path, idx):
l=list()
l.append(path)
for i in range (idx):
l.append(os.path.split(l[i])[0])
return l[idx]
def get_uuid_from_file(self,path):
return open (os.path.join(path, "machine_uuid")).next()
def get_user_hash(self):
return self.user_hash
def get_uuid (self):
return self.uuid
|
