@@ -323,6 +323,7 @@ def invoke_api(self, api):
323
323
""" invoke api_tests endpoints """
324
324
http_call = getattr (requests , api ['method' ])
325
325
try :
326
+ invoke_labels = self .labels
326
327
result = http_call (
327
328
"https://{}:{}{}" .format (self .ip , self .apiPort , api ['path' ]),
328
329
headers = api .get ('headers' , None ),
@@ -333,31 +334,31 @@ def invoke_api(self, api):
333
334
elapsed_time = result .elapsed .microseconds
334
335
size = len (result .text )
335
336
status = result .status_code
337
+
336
338
self .trawler .set_gauge (
337
339
'datapower' ,
338
340
"invoke_api_{}_size" .format (api ['name' ]),
339
341
size ,
340
- pod_name = self .name , labels = self . labels )
342
+ pod_name = self .name , labels = invoke_labels )
341
343
self .trawler .set_gauge (
342
344
'datapower' ,
343
345
"invoke_api_{}_time" .format (api ['name' ]),
344
346
elapsed_time ,
345
- pod_name = self .name , labels = self . labels )
346
- status_labels = self . labels
347
- status_labels [ 'code' ] = status
348
- self .trawler .set_gauge (
347
+ pod_name = self .name , labels = invoke_labels )
348
+
349
+ status_labels = { 'code' : status }
350
+ self .trawler .inc_counter (
349
351
'datapower' ,
350
352
"invoke_api_{}_status_total" .format (api ['name' ]),
351
353
1 ,
352
- pod_name = self .name , labels = status_labels )
354
+ pod_name = self .name , labels = { ** status_labels , ** self . labels } )
353
355
except requests .RequestException :
354
- status_labels = self .labels
355
- status_labels ['code' ] = '000'
356
- self .trawler .set_gauge (
356
+ status_labels = {'code' : '000' }
357
+ self .trawler .inc_counter (
357
358
'datapower' ,
358
359
"invoke_api_{}_status_total" .format (api ['name' ]),
359
360
0 ,
360
- pod_name = self .name , labels = status_labels )
361
+ pod_name = self .name , labels = { ** status_labels , ** self . labels } )
361
362
362
363
if __name__ == "__main__" :
363
364
net = DataPowerNet ()
0 commit comments