diff --git a/contrib/inventory/rackhd.py b/contrib/inventory/rackhd.py new file mode 100755 index 00000000000..f27fd5905eb --- /dev/null +++ b/contrib/inventory/rackhd.py @@ -0,0 +1,73 @@ +#!/usr/bin/python +import json +import requests +import os +import argparse +import types + +MONORAIL_URL = 'http://localhost:8080' + +class OnRackInventory(object): + def __init__(self, nodeids): + self._inventory = {} + for nodeid in nodeids: + self._load_inventory_data(nodeid) + output = '{\n' + for nodeid,info in self._inventory.iteritems(): + output += self._format_output(nodeid, info) + output += ',\n' + output = output[:-2] + output += '}\n' + print output + + def _load_inventory_data(self, nodeid): + info = {} + info['ohai'] = MONORAIL_URL + '/api/common/nodes/{0}/catalogs/ohai'.format(nodeid ) + info['lookup'] = MONORAIL_URL + '/api/common/lookups/?q={0}'.format(nodeid) + + results = {} + for key,url in info.iteritems(): + r = requests.get( url, verify=False) + results[key] = r.text + + self._inventory[nodeid] = results + + def _format_output(self, nodeid, info): + output = '' + try: + node_info = json.loads(info['lookup']) + ipaddress = '' + if len(node_info) > 0: + ipaddress = node_info[0]["ipAddress"] + output += ' "' + nodeid + '" : {\n' + output += ' "hosts": [ "' + ipaddress + '" ],\n' + output += ' "vars" : {\n' + for key,result in info.iteritems(): + output += ' "' + key + '": ' + json.dumps(json.loads(result), sort_keys=True, indent=2) + ',\n' + output += ' "ansible_ssh_user": "renasar"\n' + output += ' }\n' + output += ' }\n' + except KeyError: + pass + return output + +try: + #check if monorail url(ie:10.1.1.45:8080) is specified in the environment + MONORAIL_URL = 'http://' + str(os.environ['MONORAIL']) +except: + #use default values + pass + +# Use the nodeid specified in the environment to limit the data returned +# or return data for all available nodes +nodeids = [] +try: + nodeids += os.environ['nodeid'].split(',') +except KeyError: + url = MONORAIL_URL + '/api/common/nodes' + r = requests.get( url, verify=False) + data = json.loads(r.text) + for entry in data: + if entry['type'] == 'compute': + nodeids.append(entry['id']) +OnRackInventory(nodeids)