#!/usr/bin/python2 import csv import optparse import signal import sys import os try: signal.signal(signal.SIGPIPE, signal.SIG_DFL) except AttributeError: pass path = os.path.dirname(os.path.realpath(__file__)) path = os.path.realpath(os.path.join(path, '..', 'lib', 'python')) if path.startswith('/opt'): sys.path.append(path) import confluent.client as client import confluent.sortutil as sortutil def lookupdata(data, key): ret = data.get(key, {}).get('value', '') if ret is None: ret = '' return ret def main(): argparser = optparse.OptionParser( usage='''\n %prog noderange -o xcatnodes.def \n ''') argparser.add_option('-o', '--output', help='xCAT stanza file') argparser.add_option('-m', '--macs', help='xCAT macs.csv to write') (options, args) = argparser.parse_args() try: noderange = args[0] except IndexError: argparser.print_help() sys.exit(1) if not (options.output or options.macs): sys.stderr.write('Output file must be specified by -o or -m\n') sys.exit(1) sess = client.Command() databynode = {} for res in sess.read('/noderange/{0}/attributes/all'.format(noderange)): for node in res.get('databynode', {}): if node not in databynode: databynode[node] = {} databynode[node].update(res['databynode'][node]) if options.output: with open(options.output, 'w') as importfile: for node in sortutil.natural_sort(databynode): xcatattrs = collect_attribute_data(databynode, node) importfile.write('{0}:\n'.format(node)) importfile.write(' objtype=node\n') importfile.write(' arch=x86_64\n') importfile.write(' netboot=xnba\n') importfile.write(' mgt=ipmi\n') for attr in xcatattrs: if xcatattrs[attr] is None: continue importfile.write(' {0}={1}\n'.format(attr, xcatattrs[attr])) importfile.write('\n') if options.macs: with open(options.macs, 'w') as importfile: macsv = csv.writer(importfile) macsv.writerow(['#node', 'mac']) for node in sortutil.natural_sort(databynode): xcatattrs = collect_attribute_data(databynode, node) macsv.writerow([node, xcatattrs['mac']]) def collect_attribute_data(databynode, node): data = databynode[node] xcatattrs = {} xcatattrs['groups'] = ','.join(data.get('groups', [])) xcatattrs['bmc'] = data.get('hardwaremanagement.manager', {}).get( 'value', None) xcatattrs['mpa'] = data.get('enclosure.manager', {}).get( 'value', None) xcatattrs['slotid'] = data.get('enclosure.bay', {}).get( 'value', None) gotmac = False for key in data: if key.startswith('net.') and 'hwaddr' in key: currmac = data[key].get('value', None) if currmac: if gotmac: sys.stderr.write( 'Ignoring {0} and using only {1} for mac, ' 'multiple macs not supported by ' 'confluent2xcat\n'.format(key, gotmac)) continue gotmac = key xcatattrs['mac'] = currmac return xcatattrs if __name__ == '__main__': main()