X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=nodegroups.py;h=999902f2a5c3dff1122627c6530a57a3c90e5293;hb=2c3be2b58bc07001f1b221135997f6a0d45477a6;hp=9e14e2f0a5f2dc6ffe4df631f69f048555a33aee;hpb=90b2e8e7cb145cb1f6b3780867617084441b6ca9;p=monitor.git diff --git a/nodegroups.py b/nodegroups.py index 9e14e2f..999902f 100755 --- a/nodegroups.py +++ b/nodegroups.py @@ -14,7 +14,7 @@ # * from monitor import database -from monitor.database import FindbadNodeRecord +from monitor.database.info.model import FindbadNodeRecord from monitor import util from monitor.wrapper import plc from monitor import parser as parsermodule @@ -22,7 +22,7 @@ from monitor import parser as parsermodule api = plc.getAuthAPI() from nodequery import verify,query_to_dict,node_select -from nodecommon import * +from monitor.common import * from sets import Set def main(): @@ -59,16 +59,15 @@ def main(): # given to GetNodes nodelist = [] for h in hostlist: - nodelist += api.GetNodes(h) + nodelist.append( plccache.GetNodeByName(h) ) - #nodelist = api.GetNodes(hostlist) group_str = "Given" elif config.site: - site = api.GetSites(config.site) + site = plccache.GetSitesByName([config.site]) if len (site) > 0: site = site[0] - nodelist = api.GetNodes(site['node_ids']) + nodelist = plccache.GetNodesByIds(site['node_ids']) else: nodelist = [] @@ -76,13 +75,13 @@ def main(): elif config.nodeselect: hostlist = node_select(config.nodeselect) - nodelist = api.GetNodes(hostlist) + nodelist = [ plccache.GetNodeByName(h) for h in hostlist ] group_str = "selection" else: ng = api.GetNodeGroups({'name' : config.nodegroup}) - nodelist = api.GetNodes(ng[0]['node_ids']) + nodelist = plccache.GetNodesByIds(ng[0]['node_ids']) group_str = config.nodegroup @@ -91,7 +90,7 @@ def main(): ng_nodes = nodelist # Get all nodes - all_nodes = api.GetNodes({'peer_id': None}) + all_nodes = plccache.l_nodes # remove ngnodes from all node list ng_list = [ x['hostname'] for x in ng_nodes ] @@ -121,7 +120,7 @@ def main(): i = 1 for node in nodelist: print "%-2d" % i, - fbrec = FindbadNodeRecord.query.filter(FindbadNodeRecord.hostname==node['hostname']).order_by(FindbadNodeRecord.date_checked.desc()).first() + fbrec = FindbadNodeRecord.get_latest_by(hostname=node['hostname']) fbdata = fbrec.to_dict() print nodegroup_display(node, fbdata, config) i += 1