diff options
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/launch.py | 360 |
1 files changed, 220 insertions, 140 deletions
diff --git a/examples/launch.py b/examples/launch.py index c13d05f..8f6697a 100644 --- a/examples/launch.py +++ b/examples/launch.py @@ -18,16 +18,16 @@ # This script is responsible for deploying virtual environments import argparse import logging -import os import re +import os from snaps import file_utils from snaps.openstack.create_flavor import FlavorSettings, OpenStackFlavor -from snaps.openstack.create_image import ImageSettings +from snaps.openstack.create_image import ImageSettings, OpenStackImage from snaps.openstack.create_instance import VmInstanceSettings +from snaps.openstack.create_keypairs import KeypairSettings from snaps.openstack.create_network import PortSettings, NetworkSettings from snaps.openstack.create_router import RouterSettings -from snaps.openstack.create_keypairs import KeypairSettings from snaps.openstack.os_credentials import OSCreds, ProxySettings from snaps.openstack.utils import deploy_utils from snaps.provisioning import ansible_utils @@ -41,7 +41,8 @@ ARG_NOT_SET = "argument not set" def __get_os_credentials(os_conn_config): """ - Returns an object containing all of the information required to access OpenStack APIs + Returns an object containing all of the information required to access + OpenStack APIs :param os_conn_config: The configuration holding the credentials :return: an OSCreds instance """ @@ -67,16 +68,17 @@ def __parse_ports_config(config): """ out = list() for port_config in config: - out.append(PortSettings(config=port_config.get('port'))) + out.append(PortSettings(**port_config.get('port'))) return out def __create_flavors(os_conn_config, flavors_config, cleanup=False): """ - Returns a dictionary of flavors where the key is the image name and the value is the image object + Returns a dictionary of flavors where the key is the image name and the + value is the image object :param os_conn_config: The OpenStack connection credentials :param flavors_config: The list of image configurations - :param cleanup: Denotes whether or not this is being called for cleanup or not + :param cleanup: Denotes whether or not this is being called for cleanup :return: dictionary """ flavors = {} @@ -86,8 +88,9 @@ def __create_flavors(os_conn_config, flavors_config, cleanup=False): for flavor_config_dict in flavors_config: flavor_config = flavor_config_dict.get('flavor') if flavor_config and flavor_config.get('name'): - flavor_creator = OpenStackFlavor(__get_os_credentials(os_conn_config), - FlavorSettings(flavor_config)) + flavor_creator = OpenStackFlavor( + __get_os_credentials(os_conn_config), + FlavorSettings(**flavor_config)) flavor_creator.create(cleanup=cleanup) flavors[flavor_config['name']] = flavor_creator except Exception as e: @@ -101,10 +104,11 @@ def __create_flavors(os_conn_config, flavors_config, cleanup=False): def __create_images(os_conn_config, images_config, cleanup=False): """ - Returns a dictionary of images where the key is the image name and the value is the image object + Returns a dictionary of images where the key is the image name and the + value is the image object :param os_conn_config: The OpenStack connection credentials :param images_config: The list of image configurations - :param cleanup: Denotes whether or not this is being called for cleanup or not + :param cleanup: Denotes whether or not this is being called for cleanup :return: dictionary """ images = {} @@ -114,8 +118,9 @@ def __create_images(os_conn_config, images_config, cleanup=False): for image_config_dict in images_config: image_config = image_config_dict.get('image') if image_config and image_config.get('name'): - images[image_config['name']] = deploy_utils.create_image(__get_os_credentials(os_conn_config), - ImageSettings(image_config), cleanup) + images[image_config['name']] = deploy_utils.create_image( + __get_os_credentials(os_conn_config), + ImageSettings(**image_config), cleanup) except Exception as e: for key, image_creator in images.items(): image_creator.clean() @@ -127,10 +132,11 @@ def __create_images(os_conn_config, images_config, cleanup=False): def __create_networks(os_conn_config, network_confs, cleanup=False): """ - Returns a dictionary of networks where the key is the network name and the value is the network object + Returns a dictionary of networks where the key is the network name and the + value is the network object :param os_conn_config: The OpenStack connection credentials :param network_confs: The list of network configurations - :param cleanup: Denotes whether or not this is being called for cleanup or not + :param cleanup: Denotes whether or not this is being called for cleanup :return: dictionary """ network_dict = {} @@ -141,7 +147,8 @@ def __create_networks(os_conn_config, network_confs, cleanup=False): net_name = network_conf['network']['name'] os_creds = __get_os_credentials(os_conn_config) network_dict[net_name] = deploy_utils.create_network( - os_creds, NetworkSettings(config=network_conf['network']), cleanup) + os_creds, NetworkSettings(**network_conf['network']), + cleanup) except Exception as e: for key, net_creator in network_dict.items(): net_creator.clean() @@ -154,10 +161,11 @@ def __create_networks(os_conn_config, network_confs, cleanup=False): def __create_routers(os_conn_config, router_confs, cleanup=False): """ - Returns a dictionary of networks where the key is the network name and the value is the network object + Returns a dictionary of networks where the key is the network name and the + value is the network object :param os_conn_config: The OpenStack connection credentials :param router_confs: The list of router configurations - :param cleanup: Denotes whether or not this is being called for cleanup or not + :param cleanup: Denotes whether or not this is being called for cleanup :return: dictionary """ router_dict = {} @@ -168,7 +176,7 @@ def __create_routers(os_conn_config, router_confs, cleanup=False): for router_conf in router_confs: router_name = router_conf['router']['name'] router_dict[router_name] = deploy_utils.create_router( - os_creds, RouterSettings(config=router_conf['router']), cleanup) + os_creds, RouterSettings(**router_conf['router']), cleanup) except Exception as e: for key, router_creator in router_dict.items(): router_creator.clean() @@ -181,10 +189,11 @@ def __create_routers(os_conn_config, router_confs, cleanup=False): def __create_keypairs(os_conn_config, keypair_confs, cleanup=False): """ - Returns a dictionary of keypairs where the key is the keypair name and the value is the keypair object + Returns a dictionary of keypairs where the key is the keypair name and the + value is the keypair object :param os_conn_config: The OpenStack connection credentials :param keypair_confs: The list of keypair configurations - :param cleanup: Denotes whether or not this is being called for cleanup or not + :param cleanup: Denotes whether or not this is being called for cleanup :return: dictionary """ keypairs_dict = {} @@ -192,8 +201,9 @@ def __create_keypairs(os_conn_config, keypair_confs, cleanup=False): try: for keypair_dict in keypair_confs: keypair_config = keypair_dict['keypair'] - kp_settings = KeypairSettings(keypair_config) - keypairs_dict[keypair_config['name']] = deploy_utils.create_keypair( + kp_settings = KeypairSettings(**keypair_config) + keypairs_dict[ + keypair_config['name']] = deploy_utils.create_keypair( __get_os_credentials(os_conn_config), kp_settings, cleanup) except Exception as e: for key, keypair_creator in keypairs_dict.items(): @@ -205,14 +215,18 @@ def __create_keypairs(os_conn_config, keypair_confs, cleanup=False): return keypairs_dict -def __create_instances(os_conn_config, instances_config, image_dict, keypairs_dict, cleanup=False): +def __create_instances(os_conn_config, instances_config, image_dict, + keypairs_dict, cleanup=False): """ - Returns a dictionary of instances where the key is the instance name and the value is the VM object + Returns a dictionary of instances where the key is the instance name and + the value is the VM object :param os_conn_config: The OpenStack connection credentials :param instances_config: The list of VM instance configurations - :param image_dict: A dictionary of images that will probably be used to instantiate the VM instance - :param keypairs_dict: A dictionary of keypairs that will probably be used to instantiate the VM instance - :param cleanup: Denotes whether or not this is being called for cleanup or not + :param image_dict: A dictionary of images that will probably be used to + instantiate the VM instance + :param keypairs_dict: A dictionary of keypairs that will probably be used + to instantiate the VM instance + :param cleanup: Denotes whether or not this is being called for cleanup :return: dictionary """ os_creds = __get_os_credentials(os_conn_config) @@ -227,19 +241,27 @@ def __create_instances(os_conn_config, instances_config, image_dict, keypairs_di if image_dict: image_creator = image_dict.get(conf.get('imageName')) if image_creator: - instance_settings = VmInstanceSettings(config=instance_config['instance']) + instance_settings = VmInstanceSettings( + **instance_config['instance']) kp_name = conf.get('keypair_name') - vm_dict[conf['name']] = deploy_utils.create_vm_instance( - os_creds, instance_settings, image_creator.image_settings, - keypair_creator=keypairs_dict[kp_name], cleanup=cleanup) + vm_dict[conf[ + 'name']] = deploy_utils.create_vm_instance( + os_creds, instance_settings, + image_creator.image_settings, + keypair_creator=keypairs_dict[kp_name], + cleanup=cleanup) else: - raise Exception('Image creator instance not found. Cannot instantiate') + raise Exception('Image creator instance not found.' + ' Cannot instantiate') else: - raise Exception('Image dictionary is None. Cannot instantiate') + raise Exception('Image dictionary is None. Cannot ' + 'instantiate') else: - raise Exception('Instance configuration is None. Cannot instantiate') + raise Exception('Instance configuration is None. Cannot ' + 'instantiate') except Exception as e: - logger.error('Unexpected error creating instances. Attempting to cleanup environment - ' + str(e)) + logger.error('Unexpected error creating instances. Attempting to ' + 'cleanup environment - %s', e) for key, inst_creator in vm_dict.items(): inst_creator.clean() raise e @@ -249,16 +271,21 @@ def __create_instances(os_conn_config, instances_config, image_dict, keypairs_di return vm_dict -def __apply_ansible_playbooks(ansible_configs, os_conn_config, vm_dict, image_dict, flavor_dict, env_file): +def __apply_ansible_playbooks(ansible_configs, os_conn_config, vm_dict, + image_dict, flavor_dict, env_file): """ Applies ansible playbooks to running VMs with floating IPs :param ansible_configs: a list of Ansible configurations - :param os_conn_config: the OpenStack connection configuration used to create an OSCreds instance - :param vm_dict: the dictionary of newly instantiated VMs where the name is the key - :param image_dict: the dictionary of newly instantiated images where the name is the key - :param flavor_dict: the dictionary of newly instantiated flavors where the name is the key - :param env_file: the path of the environment for setting the CWD so playbook location is relative to the deployment - file + :param os_conn_config: the OpenStack connection configuration used to + create an OSCreds instance + :param vm_dict: the dictionary of newly instantiated VMs where the name is + the key + :param image_dict: the dictionary of newly instantiated images where the + name is the key + :param flavor_dict: the dictionary of newly instantiated flavors where the + name is the key + :param env_file: the path of the environment for setting the CWD so + playbook location is relative to the deployment file :return: t/f - true if successful """ logger.info("Applying Ansible Playbooks") @@ -266,10 +293,12 @@ def __apply_ansible_playbooks(ansible_configs, os_conn_config, vm_dict, image_di # Ensure all hosts are accepting SSH session requests for vm_inst in list(vm_dict.values()): if not vm_inst.vm_ssh_active(block=True): - logger.warning("Timeout waiting for instance to respond to SSH requests") + logger.warning( + "Timeout waiting for instance to respond to SSH requests") return False - # Set CWD so the deployment file's playbook location can leverage relative paths + # Set CWD so the deployment file's playbook location can leverage + # relative paths orig_cwd = os.getcwd() env_dir = os.path.dirname(env_file) os.chdir(env_dir) @@ -277,7 +306,8 @@ def __apply_ansible_playbooks(ansible_configs, os_conn_config, vm_dict, image_di # Apply playbooks for ansible_config in ansible_configs: os_creds = __get_os_credentials(os_conn_config) - __apply_ansible_playbook(ansible_config, os_creds, vm_dict, image_dict, flavor_dict) + __apply_ansible_playbook(ansible_config, os_creds, vm_dict, + image_dict, flavor_dict) # Return to original directory os.chdir(orig_cwd) @@ -285,25 +315,36 @@ def __apply_ansible_playbooks(ansible_configs, os_conn_config, vm_dict, image_di return True -def __apply_ansible_playbook(ansible_config, os_creds, vm_dict, image_dict, flavor_dict): +def __apply_ansible_playbook(ansible_config, os_creds, vm_dict, image_dict, + flavor_dict): """ Applies an Ansible configuration setting :param ansible_config: the configuration settings :param os_creds: the OpenStack credentials object - :param vm_dict: the dictionary of newly instantiated VMs where the name is the key - :param image_dict: the dictionary of newly instantiated images where the name is the key - :param flavor_dict: the dictionary of newly instantiated flavors where the name is the key + :param vm_dict: the dictionary of newly instantiated VMs where the name is + the key + :param image_dict: the dictionary of newly instantiated images where the + name is the key + :param flavor_dict: the dictionary of newly instantiated flavors where the + name is the key """ if ansible_config: - remote_user, floating_ips, private_key_filepath, proxy_settings = __get_connection_info(ansible_config, vm_dict) + (remote_user, floating_ips, private_key_filepath, + proxy_settings) = __get_connection_info( + ansible_config, vm_dict) if floating_ips: retval = ansible_utils.apply_playbook( - ansible_config['playbook_location'], floating_ips, remote_user, private_key_filepath, - variables=__get_variables(ansible_config.get('variables'), os_creds, vm_dict, image_dict, flavor_dict), + ansible_config['playbook_location'], floating_ips, remote_user, + private_key_filepath, + variables=__get_variables(ansible_config.get('variables'), + os_creds, vm_dict, image_dict, + flavor_dict), proxy_setting=proxy_settings) if retval != 0: # Not a fatal type of event - logger.warning('Unable to apply playbook found at location - ' + ansible_config('playbook_location')) + logger.warning( + 'Unable to apply playbook found at location - ' + + ansible_config('playbook_location')) def __get_connection_info(ansible_config, vm_dict): @@ -312,16 +353,19 @@ def __get_connection_info(ansible_config, vm_dict): (remote_user, [floating_ips], private_key_filepath, proxy_settings) :param ansible_config: the configuration settings :param vm_dict: the dictionary of VMs where the VM name is the key - :return: tuple where the first element is the user and the second is a list of floating IPs and the third is the - private key file location and the fourth is an instance of the snaps.ProxySettings class - (note: in order to work, each of the hosts need to have the same sudo_user and private key file location values) + :return: tuple where the first element is the user and the second is a list + of floating IPs and the third is the + private key file location and the fourth is an instance of the + snaps.ProxySettings class + (note: in order to work, each of the hosts need to have the same sudo_user + and private key file location values) """ if ansible_config.get('hosts'): hosts = ansible_config['hosts'] if len(hosts) > 0: floating_ips = list() remote_user = None - private_key_filepath = None + pk_file = None proxy_settings = None for host in hosts: vm = vm_dict.get(host) @@ -333,48 +377,63 @@ def __get_connection_info(ansible_config, vm_dict): if fip: floating_ips.append(fip.ip) else: - raise Exception('Could not find floating IP for VM - ' + vm.name) + raise Exception( + 'Could not find floating IP for VM - ' + + vm.name) - private_key_filepath = vm.keypair_settings.private_filepath + pk_file = vm.keypair_settings.private_filepath proxy_settings = vm.get_os_creds().proxy_settings else: logger.error('Could not locate VM with name - ' + host) - return remote_user, floating_ips, private_key_filepath, proxy_settings + return remote_user, floating_ips, pk_file, proxy_settings return None def __get_variables(var_config, os_creds, vm_dict, image_dict, flavor_dict): """ - Returns a dictionary of substitution variables to be used for Ansible templates + Returns a dictionary of substitution variables to be used for Ansible + templates :param var_config: the variable configuration settings :param os_creds: the OpenStack credentials object - :param vm_dict: the dictionary of newly instantiated VMs where the name is the key - :param image_dict: the dictionary of newly instantiated images where the name is the key - :param flavor_dict: the dictionary of newly instantiated flavors where the name is the key + :param vm_dict: the dictionary of newly instantiated VMs where the name is + the key + :param image_dict: the dictionary of newly instantiated images where the + name is the key + :param flavor_dict: the dictionary of newly instantiated flavors where the + name is the key :return: dictionary or None """ if var_config and vm_dict and len(vm_dict) > 0: variables = dict() for key, value in var_config.items(): - value = __get_variable_value(value, os_creds, vm_dict, image_dict, flavor_dict) + value = __get_variable_value(value, os_creds, vm_dict, image_dict, + flavor_dict) if key and value: variables[key] = value - logger.info("Set Jinga2 variable with key [" + key + "] the value [" + value + ']') + logger.info( + "Set Jinga2 variable with key [%s] the value [%s]", + key, value) else: - logger.warning('Key [' + str(key) + '] or Value [' + str(value) + '] must not be None') + logger.warning('Key [%s] or Value [%s] must not be None', + str(key), str(value)) return variables return None -def __get_variable_value(var_config_values, os_creds, vm_dict, image_dict, flavor_dict): +def __get_variable_value(var_config_values, os_creds, vm_dict, image_dict, + flavor_dict): """ - Returns the associated variable value for use by Ansible for substitution purposes + Returns the associated variable value for use by Ansible for substitution + purposes :param var_config_values: the configuration dictionary :param os_creds: the OpenStack credentials object - :param vm_dict: the dictionary of newly instantiated VMs where the name is the key - :param image_dict: the dictionary of newly instantiated images where the name is the key - :param flavor_dict: the dictionary of newly instantiated flavors where the name is the key + :param vm_dict: the dictionary of newly instantiated VMs where the name is + the key + :param image_dict: the dictionary of newly instantiated images where the + name is the key + :param flavor_dict: the dictionary of newly instantiated flavors where the + name is the key :return: """ if var_config_values['type'] == 'string': @@ -405,7 +464,8 @@ def __get_vm_attr_variable_value(var_config_values, vm_dict): """ Returns the associated value contained on a VM instance :param var_config_values: the configuration dictionary - :param vm_dict: the dictionary containing all VMs where the key is the VM's name + :param vm_dict: the dictionary containing all VMs where the key is the VM's + name :return: the value """ vm = vm_dict.get(var_config_values['vm_name']) @@ -446,7 +506,8 @@ def __get_vm_port_variable_value(var_config_values, vm_dict): """ Returns the associated OS credentials value :param var_config_values: the configuration dictionary - :param vm_dict: the dictionary containing all VMs where the key is the VM's name + :param vm_dict: the dictionary containing all VMs where the key is the VM's + name :return: the value """ port_name = var_config_values.get('port_name') @@ -467,7 +528,8 @@ def __get_image_variable_value(var_config_values, image_dict): """ Returns the associated image value :param var_config_values: the configuration dictionary - :param image_dict: the dictionary containing all images where the key is the name + :param image_dict: the dictionary containing all images where the key is + the name :return: the value """ logger.info("Retrieving image values") @@ -476,9 +538,11 @@ def __get_image_variable_value(var_config_values, image_dict): if var_config_values.get('image_name'): image_creator = image_dict.get(var_config_values['image_name']) if image_creator: - if var_config_values.get('value') and var_config_values['value'] == 'id': + if var_config_values.get('value') and \ + var_config_values['value'] == 'id': return image_creator.get_image().id - if var_config_values.get('value') and var_config_values['value'] == 'user': + if var_config_values.get('value') and \ + var_config_values['value'] == 'user': return image_creator.image_settings.image_user logger.info("Returning none") @@ -489,7 +553,8 @@ def __get_flavor_variable_value(var_config_values, flavor_dict): """ Returns the associated flavor value :param var_config_values: the configuration dictionary - :param flavor_dict: the dictionary containing all flavor creators where the key is the name + :param flavor_dict: the dictionary containing all flavor creators where the + key is the name :return: the value or None """ logger.info("Retrieving flavor values") @@ -498,7 +563,8 @@ def __get_flavor_variable_value(var_config_values, flavor_dict): if var_config_values.get('flavor_name'): flavor_creator = flavor_dict.get(var_config_values['flavor_name']) if flavor_creator: - if var_config_values.get('value') and var_config_values['value'] == 'id': + if var_config_values.get('value') and \ + var_config_values['value'] == 'id': return flavor_creator.get_flavor().id logger.info("Returning none") @@ -507,8 +573,9 @@ def __get_flavor_variable_value(var_config_values, flavor_dict): def main(arguments): """ - Will need to set environment variable ANSIBLE_HOST_KEY_CHECKING=False or ... - Create a file located in /etc/ansible/ansible/cfg or ~/.ansible.cfg containing the following content: + Will need to set environment variable ANSIBLE_HOST_KEY_CHECKING=False or + Create a file located in /etc/ansible/ansible/cfg or ~/.ansible.cfg + containing the following content: [defaults] host_key_checking = False @@ -530,51 +597,62 @@ def main(arguments): os_config = config.get('openstack') os_conn_config = None - flavor_dict = {} - image_dict = {} - network_dict = {} - router_dict = {} - keypairs_dict = {} - vm_dict = {} + creators = list() + vm_dict = dict() + images_dict = dict() + flavors_dict = dict() if os_config: try: os_conn_config = os_config.get('connection') # Create flavors - flavor_dict = __create_flavors(os_conn_config, os_config.get('flavors'), - arguments.clean is not ARG_NOT_SET) + flavors_dict = __create_flavors( + os_conn_config, os_config.get('flavors'), + arguments.clean is not ARG_NOT_SET) + creators.append(flavors_dict) # Create images - image_dict = __create_images(os_conn_config, os_config.get('images'), - arguments.clean is not ARG_NOT_SET) + images_dict = __create_images( + os_conn_config, os_config.get('images'), + arguments.clean is not ARG_NOT_SET) + creators.append(images_dict) # Create network - network_dict = __create_networks(os_conn_config, os_config.get('networks'), - arguments.clean is not ARG_NOT_SET) + creators.append(__create_networks( + os_conn_config, os_config.get('networks'), + arguments.clean is not ARG_NOT_SET)) - # Create network - router_dict = __create_routers(os_conn_config, os_config.get('routers'), - arguments.clean is not ARG_NOT_SET) + # Create routers + creators.append(__create_routers( + os_conn_config, os_config.get('routers'), + arguments.clean is not ARG_NOT_SET)) # Create keypairs - keypairs_dict = __create_keypairs(os_conn_config, os_config.get('keypairs'), - arguments.clean is not ARG_NOT_SET) + keypairs_dict = __create_keypairs( + os_conn_config, os_config.get('keypairs'), + arguments.clean is not ARG_NOT_SET) + creators.append(keypairs_dict) # Create instance - vm_dict = __create_instances(os_conn_config, os_config.get('instances'), image_dict, keypairs_dict, - arguments.clean is not ARG_NOT_SET) - logger.info('Completed creating/retrieving all configured instances') + vm_dict = __create_instances( + os_conn_config, os_config.get('instances'), + images_dict, keypairs_dict, + arguments.clean is not ARG_NOT_SET) + creators.append(vm_dict) + logger.info( + 'Completed creating/retrieving all configured instances') except Exception as e: - logger.error('Unexpected error deploying environment. Rolling back due to - ' + str(e)) - __cleanup(vm_dict, keypairs_dict, router_dict, network_dict, image_dict, flavor_dict, True) - raise e + logger.error( + 'Unexpected error deploying environment. Rolling back due' + ' to - ' + str(e)) + __cleanup(creators) + raise # Must enter either block if arguments.clean is not ARG_NOT_SET: # Cleanup Environment - __cleanup(vm_dict, keypairs_dict, router_dict, network_dict, image_dict, flavor_dict, - arguments.clean_image is not ARG_NOT_SET) + __cleanup(creators, arguments.clean_image is not ARG_NOT_SET) elif arguments.deploy is not ARG_NOT_SET: logger.info('Configuring NICs where required') for vm in vm_dict.values(): @@ -584,56 +662,58 @@ def main(arguments): # Provision VMs ansible_config = config.get('ansible') if ansible_config and vm_dict: - if not __apply_ansible_playbooks(ansible_config, os_conn_config, vm_dict, image_dict, flavor_dict, + if not __apply_ansible_playbooks(ansible_config, + os_conn_config, vm_dict, + images_dict, flavors_dict, arguments.environment): logger.error("Problem applying ansible playbooks") else: - logger.error('Unable to read configuration file - ' + arguments.environment) + logger.error( + 'Unable to read configuration file - ' + arguments.environment) exit(1) exit(0) -def __cleanup(vm_dict, keypairs_dict, router_dict, network_dict, image_dict, flavor_dict, clean_image=False): - for key, vm_inst in vm_dict.items(): - vm_inst.clean() - for key, kp_inst in keypairs_dict.items(): - kp_inst.clean() - for key, router_inst in router_dict.items(): - try: - router_inst.clean() - except Exception: - logger.warning("Router not found continuing to next component") - for key, net_inst in network_dict.items(): - try: - net_inst.clean() - except Exception: - logger.warning("Network not found continuing to next component") - if clean_image: - for key, image_inst in image_dict.items(): - image_inst.clean() - for key, flavor_inst in flavor_dict.items(): - flavor_inst.clean() +def __cleanup(creators, clean_image=False): + for creator_dict in reversed(creators): + for key, creator in creator_dict.items(): + if (isinstance(creator, OpenStackImage) and clean_image) or \ + not isinstance(creator, OpenStackImage): + try: + creator.clean() + except Exception as e: + logger.warning('Error cleaning component - %s', e) if __name__ == '__main__': - # To ensure any files referenced via a relative path will begin from the diectory in which this file resides + # To ensure any files referenced via a relative path will begin from the + # directory in which this file resides os.chdir(os.path.dirname(os.path.realpath(__file__))) parser = argparse.ArgumentParser() - parser.add_argument('-d', '--deploy', dest='deploy', nargs='?', default=ARG_NOT_SET, - help='When used, environment will be deployed and provisioned') - parser.add_argument('-c', '--clean', dest='clean', nargs='?', default=ARG_NOT_SET, - help='When used, the environment will be removed') - parser.add_argument('-i', '--clean-image', dest='clean_image', nargs='?', default=ARG_NOT_SET, - help='When cleaning, if this is set, the image will be cleaned too') - parser.add_argument('-e', '--env', dest='environment', required=True, - help='The environment configuration YAML file - REQUIRED') - parser.add_argument('-l', '--log-level', dest='log_level', default='INFO', help='Logging Level (INFO|DEBUG)') + parser.add_argument( + '-d', '--deploy', dest='deploy', nargs='?', default=ARG_NOT_SET, + help='When used, environment will be deployed and provisioned') + parser.add_argument( + '-c', '--clean', dest='clean', nargs='?', default=ARG_NOT_SET, + help='When used, the environment will be removed') + parser.add_argument( + '-i', '--clean-image', dest='clean_image', nargs='?', + default=ARG_NOT_SET, + help='When cleaning, if this is set, the image will be cleaned too') + parser.add_argument( + '-e', '--env', dest='environment', required=True, + help='The environment configuration YAML file - REQUIRED') + parser.add_argument( + '-l', '--log-level', dest='log_level', default='INFO', + help='Logging Level (INFO|DEBUG)') args = parser.parse_args() if args.deploy is ARG_NOT_SET and args.clean is ARG_NOT_SET: - print('Must enter either -d for deploy or -c for cleaning up and environment') + print( + 'Must enter either -d for deploy or -c for cleaning up and ' + 'environment') exit(1) if args.deploy is not ARG_NOT_SET and args.clean is not ARG_NOT_SET: print('Cannot enter both options -d/--deploy and -c/--clean') |