Skip to content

Commit f4b232f

Browse files
committed
improve opentsdb loookup
Signed-off-by: hwassman <[email protected]>
1 parent 52ab44b commit f4b232f

File tree

2 files changed

+8
-7
lines changed

2 files changed

+8
-7
lines changed

source/opentsdb.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -373,10 +373,8 @@ def parse_result_tags(self, identifiersMap):
373373
if identifiersMap:
374374
for identifiers in identifiersMap:
375375
d = defaultdict(dict)
376-
for key in identifiers.keys():
377-
d['tags'][key] = identifiers[key]
378-
if d not in self.results:
379-
self.results.append(d)
376+
d['tags'] = identifiers
377+
self.results.append(d)
380378

381379

382380
class SingleTimeSeriesResponse(object):

source/queryHandler/Topo.py

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@
2525
from typing import Set, List, Dict, DefaultDict
2626

2727
import analytics
28-
from utils import get_runtime_statistics
28+
from utils import get_runtime_statistics, cond_execution_time
2929

3030
# dict.iteritems() deprecated in python 3
3131
iterval = lambda d: (getattr(d, 'itervalues', None) or d.values)()
@@ -258,8 +258,11 @@ def getAllFilterMapsForSensor(self, searchSensor):
258258
based on metadata topology returned from zimon "topo".
259259
'''
260260
filtersMaps = []
261-
if searchSensor in set(self.allFiltersMaps.keys()):
262-
filtersMaps.extend(self.allFiltersMaps[searchSensor])
261+
if searchSensor in set(self.sensorsSpec.keys()):
262+
for entryName in self.__compTree.keys():
263+
values = self.__compTree[entryName]['filtersMap'].get(searchSensor, [])
264+
if len(values) > 0:
265+
filtersMaps.extend(values)
263266
return filtersMaps
264267

265268
def getAllFilterMapsForMetric(self, searchMetric):

0 commit comments

Comments
 (0)