@@ -127,19 +127,19 @@ def build_collector(self, sensor) -> SensorCollector :
127
127
attrs = {'sensor' : sensor , 'period' : period , 'nsamples' : 1 }
128
128
request = QueryPolicy (** attrs )
129
129
collector = SensorCollector (sensor , period , self .logger , request )
130
- #collector.cache = True
131
- #else:
132
- #ts = calendar.timegm(time.gmtime()) - 15
133
- #ts = int(round(time.time() * 1000))
134
- #ts=int(timer()*1000)
135
-
136
- #ts=int(time()*1000)
137
- #ts1 = ts-1000
138
- #self.logger.trace("ts:{0}, ts1:{1}".format(str(ts),str(ts1)))
139
- #qstart = str(int(int(str(ts1)) / 1000))
140
- #attrs = {'sensor': sensor, 'period': period, 'start': qstart}
141
- #request = QueryPolicy(**attrs)
142
- #collector = SensorCollector(sensor, period, self.logger, request)
130
+ # collector.cache = True
131
+ # else:
132
+ # ts = calendar.timegm(time.gmtime()) - 15
133
+ # ts = int(round(time.time() * 1000))
134
+ # ts=int(timer()*1000)
135
+
136
+ # ts=int(time()*1000)
137
+ # ts1 = ts-1000
138
+ # self.logger.trace("ts:{0}, ts1:{1}".format(str(ts),str(ts1)))
139
+ # qstart = str(int(int(str(ts1)) / 1000))
140
+ # attrs = {'sensor': sensor, 'period': period, 'start': qstart}
141
+ # request = QueryPolicy(**attrs)
142
+ # collector = SensorCollector(sensor, period, self.logger, request)
143
143
144
144
self .logger .debug (f'request instance { str (request .__dict__ )} ' )
145
145
self .logger .debug (f'Created Collector instance { str (collector .__dict__ )} ' )
@@ -165,47 +165,41 @@ def GET(self, **params):
165
165
if 'update' in cherrypy .request .script_name :
166
166
#cherrypy.response.headers['Content-Type'] = 'application/json'
167
167
resp = self .md .update ()
168
- #resp = json.dumps(resp)
169
168
170
169
# /metrics_cpu
171
170
elif 'metrics_cpu' in cherrypy .request .script_name :
172
171
resp = self .metrics (['CPU' ])
173
172
cherrypy .response .headers ['Content-Type' ] = 'text/plain'
174
173
resString = '\n ' .join (resp ) + '\n '
175
174
return resString
176
- #return bytes(resString, 'utf-8')
177
175
178
176
# /metrics_load
179
177
elif 'metrics_load' in cherrypy .request .script_name :
180
178
resp = self .metrics (['Load' ])
181
179
cherrypy .response .headers ['Content-Type' ] = 'text/plain'
182
180
resString = '\n ' .join (resp ) + '\n '
183
181
return resString
184
- #return bytes(resString, 'utf-8')
185
182
186
183
# /metrics_memory
187
184
elif 'metrics_memory' in cherrypy .request .script_name :
188
185
resp = self .metrics (['Memory' ])
189
186
cherrypy .response .headers ['Content-Type' ] = 'text/plain'
190
187
resString = '\n ' .join (resp ) + '\n '
191
188
return resString
192
- #return bytes(resString, 'utf-8')
193
189
194
190
# /metrics_network
195
191
elif 'metrics_network' in cherrypy .request .script_name :
196
192
resp = self .metrics (['Network' ])
197
193
cherrypy .response .headers ['Content-Type' ] = 'text/plain'
198
194
resString = '\n ' .join (resp ) + '\n '
199
195
return resString
200
- #return bytes(resString, 'utf-8')
201
196
202
197
# /metrics_netstat
203
198
elif 'metrics_netstat' in cherrypy .request .script_name :
204
199
resp = self .metrics (['Netstat' ])
205
200
cherrypy .response .headers ['Content-Type' ] = 'text/plain'
206
201
resString = '\n ' .join (resp ) + '\n '
207
202
return resString
208
- #return bytes(resString, 'utf-8')
209
203
210
204
# /metrics_diskfree
211
205
elif 'metrics_diskfree' in cherrypy .request .script_name :
@@ -221,23 +215,20 @@ def GET(self, **params):
221
215
cherrypy .response .headers ['Content-Type' ] = 'text/plain'
222
216
resString = '\n ' .join (resp ) + '\n '
223
217
return resString
224
- #return bytes(resString, 'utf-8')
225
218
226
219
# /metrics_gpfs_pool
227
220
elif 'metrics_gpfs_pool' in cherrypy .request .script_name :
228
221
resp = self .metrics (['GPFSPool' ])
229
222
cherrypy .response .headers ['Content-Type' ] = 'text/plain'
230
223
resString = '\n ' .join (resp ) + '\n '
231
224
return resString
232
- #return bytes(resString, 'utf-8')
233
225
234
226
# /metrics
235
227
elif 'metrics' in cherrypy .request .script_name :
236
228
resp = self .metrics ()
237
229
cherrypy .response .headers ['Content-Type' ] = 'text/plain'
238
230
resString = '\n ' .join (resp ) + '\n '
239
231
return resString
240
- #return bytes(resString, 'utf-8')
241
232
242
233
elif 'aggregators' in cherrypy .request .script_name :
243
234
resp = ["noop" , "sum" , "avg" , "max" , "min" , "rate" ]
@@ -271,7 +262,7 @@ class SingleTimeSeriesResponse():
271
262
272
263
def __init__ (self , metricname , timestamp , value , tags ):
273
264
self .metric = metricname
274
- self .timestamp = timestamp * 1000
265
+ self .timestamp = timestamp * 1000
275
266
self .value = value if value is not None else 0 # TODO check if we should return None or null
276
267
self .tags = tags
277
268
@@ -287,11 +278,10 @@ def str_expfmt(self) -> str:
287
278
fmtstr = '{name}{{{labels}}} {value} {timestamp}'
288
279
else :
289
280
fmtstr = '{name} {value} {timestamp}'
290
- mstring = fmtstr .format (
291
- name = self .metric ,
292
- labels = labels ,
293
- value = repr (float (self .value )),
294
- timestamp = int (self .timestamp )
295
- )
281
+ mstring = fmtstr .format (name = self .metric ,
282
+ labels = labels ,
283
+ value = repr (float (self .value )),
284
+ timestamp = int (self .timestamp )
285
+ )
296
286
myset .append (mstring )
297
287
return myset
0 commit comments