Fix backcompat with OpenStack inventory

This moves the contents of the current dynamic inventory into a Python
module and adds two new inventories `inventory.py` and
`scaleup_inventory.py` that both use it.

`inventory.py` should work as before, introducing no breaking changes.

It does not work with the scaleup playbooks however, so those should use
the `scaleup_inventory.py` one.

playbooks/openstack/configuration.md

@@ -843,6 +843,9 @@ Adding more nodes to the cluster is a simple process: we need to update the
 node cloud in `inventory/group_vars/all/yml`, then run the appropriate
 scaleup playbook.
 
+**NOTE**: the dynamic inventory used for scaling is different. Make sure you
+use `scaleup_inventory.py` for all the operations below.
+
 
 ### 1. Update The Inventory
 
@@ -868,7 +871,7 @@ for other nodes. For example:
 
 ```
 $ ansible-playbook --user openshift \
-  -i openshift-ansible/playbooks/openstack/inventory.py \
+  -i openshift-ansible/playbooks/openstack/scaleup_inventory.py \
   -i inventory \
   openshift-ansible/playbooks/openstack/openshift-cluster/master-scaleup.yml
 ```

playbooks/openstack/inventory.py

@@ -7,291 +7,18 @@ environment.
 
 """
 
-from __future__ import print_function
-
-import argparse
-import json
-import os
-try:
-    import ConfigParser
-except ImportError:
-    import configparser as ConfigParser
-
-from keystoneauth1.exceptions.catalog import EndpointNotFound
-import shade
-
-
-def base_openshift_inventory(cluster_hosts):
-    '''Set the base openshift inventory.'''
-    inventory = {}
-
-    masters = [server.name for server in cluster_hosts
-               if server.metadata['host-type'] == 'master']
-
-    etcd = [server.name for server in cluster_hosts
-            if server.metadata['host-type'] == 'etcd']
-    if not etcd:
-        etcd = masters
-
-    infra_hosts = [server.name for server in cluster_hosts
-                   if server.metadata['host-type'] == 'node' and
-                   server.metadata['sub-host-type'] == 'infra']
-
-    app = [server.name for server in cluster_hosts
-           if server.metadata['host-type'] == 'node' and
-           server.metadata['sub-host-type'] == 'app']
-
-    cns = [server.name for server in cluster_hosts
-           if server.metadata['host-type'] == 'cns']
-
-    load_balancers = [server.name for server in cluster_hosts
-                      if server.metadata['host-type'] == 'lb']
-
-    # NOTE: everything that should go to the `[nodes]` group:
-    nodes = list(set(masters + etcd + infra_hosts + app + cns))
-
-    # NOTE: all OpenShift nodes, including `[lb]`, `[nfs]`, etc.:
-    osev3 = list(set(nodes + load_balancers))
-
-    inventory['OSEv3'] = {'hosts': osev3, 'vars': {}}
-    inventory['openstack_nodes'] = {'hosts': nodes}
-    inventory['openstack_master_nodes'] = {'hosts': masters}
-    inventory['openstack_etcd_nodes'] = {'hosts': etcd}
-    inventory['openstack_infra_nodes'] = {'hosts': infra_hosts}
-    inventory['openstack_compute_nodes'] = {'hosts': app}
-    inventory['openstack_cns_nodes'] = {'hosts': cns}
-    inventory['lb'] = {'hosts': load_balancers}
-    inventory['localhost'] = {'ansible_connection': 'local'}
-
-    return inventory
-
-
-def get_docker_storage_mountpoints(volumes):
-    '''Check volumes to see if they're being used for docker storage'''
-    docker_storage_mountpoints = {}
-    for volume in volumes:
-        if volume.metadata.get('purpose') == "openshift_docker_storage":
-            for attachment in volume.attachments:
-                if attachment.server_id in docker_storage_mountpoints:
-                    docker_storage_mountpoints[attachment.server_id].append(attachment.device)
-                else:
-                    docker_storage_mountpoints[attachment.server_id] = [attachment.device]
-    return docker_storage_mountpoints
-
-
-def _get_hostvars(server, docker_storage_mountpoints):
-    ssh_ip_address = server.public_v4 or server.private_v4
-    hostvars = {
-        'ansible_host': ssh_ip_address
-    }
-
-    public_v4 = server.public_v4 or server.private_v4
-    if public_v4:
-        hostvars['public_v4'] = server.public_v4
-        hostvars['openshift_public_ip'] = server.public_v4
-    # TODO(shadower): what about multiple networks?
-    if server.private_v4:
-        hostvars['private_v4'] = server.private_v4
-        hostvars['openshift_ip'] = server.private_v4
-
-        # NOTE(shadower): Yes, we set both hostname and IP to the private
-        # IP address for each node. OpenStack doesn't resolve nodes by
-        # name at all, so using a hostname here would require an internal
-        # DNS which would complicate the setup and potentially introduce
-        # performance issues.
-        hostvars['openshift_hostname'] = server.metadata.get(
-            'openshift_hostname', server.private_v4)
-    hostvars['openshift_public_hostname'] = server.name
-
-    if server.metadata['host-type'] == 'cns':
-        hostvars['glusterfs_devices'] = ['/dev/nvme0n1']
-
-    group_name = server.metadata.get('openshift_node_group_name')
-    hostvars['openshift_node_group_name'] = group_name
-
-    # check for attached docker storage volumes
-    if 'os-extended-volumes:volumes_attached' in server:
-        if server.id in docker_storage_mountpoints:
-            hostvars['docker_storage_mountpoints'] = ' '.join(
-                docker_storage_mountpoints[server.id])
-    return hostvars
+import resources
 
 
 def build_inventory():
-    '''Build the dynamic inventory.'''
-    cloud = shade.openstack_cloud()
-
-    # Use an environment variable to optionally skip returning the app nodes.
-    show_compute_nodes = os.environ.get('OPENSTACK_SHOW_COMPUTE_NODES', 'true').lower() == "true"
-
-    # TODO(shadower): filter the servers based on the `OPENSHIFT_CLUSTER`
-    # environment variable.
-    cluster_hosts = [
-        server for server in cloud.list_servers()
-        if 'metadata' in server and 'clusterid' in server.metadata and
-        (show_compute_nodes or server.metadata.get('sub-host-type') != 'app')]
-
-    inventory = base_openshift_inventory(cluster_hosts)
-
-    inventory['_meta'] = {'hostvars': {}}
-
-    # Some clouds don't have Cinder. That's okay:
-    try:
-        volumes = cloud.list_volumes()
-    except EndpointNotFound:
-        volumes = []
-
-    # cinder volumes used for docker storage
-    docker_storage_mountpoints = get_docker_storage_mountpoints(volumes)
-    for server in cluster_hosts:
-        inventory['_meta']['hostvars'][server.name] = _get_hostvars(
-            server,
-            docker_storage_mountpoints)
-
-    stout = _get_stack_outputs(cloud)
-    if stout is not None:
-        try:
-            inventory['localhost'].update({
-                'openshift_openstack_api_lb_provider':
-                stout['api_lb_provider'],
-                'openshift_openstack_api_lb_port_id':
-                stout['api_lb_vip_port_id'],
-                'openshift_openstack_api_lb_sg_id':
-                stout['api_lb_sg_id']})
-        except KeyError:
-            pass  # Not an API load balanced deployment
-
-        try:
-            inventory['OSEv3']['vars'][
-                'openshift_master_cluster_hostname'] = stout['private_api_ip']
-        except KeyError:
-            pass  # Internal LB not specified
-
-        inventory['localhost']['openshift_openstack_private_api_ip'] = \
-            stout.get('private_api_ip')
-        inventory['localhost']['openshift_openstack_public_api_ip'] = \
-            stout.get('public_api_ip')
-        inventory['localhost']['openshift_openstack_public_router_ip'] = \
-            stout.get('public_router_ip')
-
-        try:
-            inventory['OSEv3']['vars'] = _get_kuryr_vars(cloud, stout)
-        except KeyError:
-            pass  # Not a kuryr deployment
+    """Build the Ansible inventory for the current environment."""
+    inventory = resources.build_inventory()
+    inventory['nodes'] = inventory['openstack_nodes']
+    inventory['masters'] = inventory['openstack_master_nodes']
+    inventory['etcd'] = inventory['openstack_etcd_nodes']
+    inventory['glusterfs'] = inventory['openstack_cns_nodes']
     return inventory
 
 
-def _get_stack_outputs(cloud_client):
-    """Returns a dictionary with the stack outputs"""
-    cluster_name = os.getenv('OPENSHIFT_CLUSTER', 'openshift-cluster')
-
-    stack = cloud_client.get_stack(cluster_name)
-    if stack is None or stack['stack_status'] not in (
-            'CREATE_COMPLETE', 'UPDATE_COMPLETE'):
-        return None
-
-    data = {}
-    for output in stack['outputs']:
-        data[output['output_key']] = output['output_value']
-    return data
-
-
-def _get_kuryr_vars(cloud_client, data):
-    """Returns a dictionary of Kuryr variables resulting of heat stacking"""
-    settings = {}
-    settings['kuryr_openstack_pod_subnet_id'] = data['pod_subnet']
-    if 'pod_subnet_pool' in data:
-        settings['kuryr_openstack_pod_subnet_pool_id'] = data[
-            'pod_subnet_pool']
-    if 'sg_allow_from_default' in data:
-        settings['kuryr_openstack_sg_allow_from_default_id'] = data[
-            'sg_allow_from_default']
-    if 'sg_allow_from_namespace' in data:
-        settings['kuryr_openstack_sg_allow_from_namespace_id'] = data[
-            'sg_allow_from_namespace']
-    settings['kuryr_openstack_pod_router_id'] = data['pod_router']
-    settings['kuryr_openstack_worker_nodes_subnet_id'] = data['vm_subnet']
-    settings['kuryr_openstack_service_subnet_id'] = data['service_subnet']
-    settings['kuryr_openstack_pod_sg_id'] = data['pod_access_sg_id']
-    settings['kuryr_openstack_pod_project_id'] = (
-        cloud_client.current_project_id)
-    settings['kuryr_openstack_api_lb_ip'] = data['private_api_ip']
-
-    settings['kuryr_openstack_auth_url'] = cloud_client.auth['auth_url']
-    settings['kuryr_openstack_username'] = cloud_client.auth['username']
-    settings['kuryr_openstack_password'] = cloud_client.auth['password']
-    if 'user_domain_id' in cloud_client.auth:
-        settings['kuryr_openstack_user_domain_name'] = (
-            cloud_client.auth['user_domain_id'])
-    else:
-        settings['kuryr_openstack_user_domain_name'] = (
-            cloud_client.auth['user_domain_name'])
-    # FIXME(apuimedo): consolidate kuryr controller credentials into the same
-    #                  vars the openstack playbook uses.
-    settings['kuryr_openstack_project_id'] = cloud_client.current_project_id
-    if 'project_domain_id' in cloud_client.auth:
-        settings['kuryr_openstack_project_domain_name'] = (
-            cloud_client.auth['project_domain_id'])
-    else:
-        settings['kuryr_openstack_project_domain_name'] = (
-            cloud_client.auth['project_domain_name'])
-    return settings
-
-
-def output_inventory(inventory, output_file):
-    """Outputs inventory into a file in ini format"""
-    config = ConfigParser.ConfigParser(allow_no_value=True)
-
-    host_meta_vars = _get_host_meta_vars_as_dict(inventory)
-
-    for key in sorted(inventory.keys()):
-        if key == 'localhost':
-            config.add_section('localhost')
-            config.set('localhost', 'localhost')
-            config.add_section('localhost:vars')
-            for var, value in inventory['localhost'].items():
-                config.set('localhost:vars', var, value)
-        elif key not in ('localhost', '_meta'):
-            if 'hosts' in inventory[key]:
-                config.add_section(key)
-                for host in inventory[key]['hosts']:
-                    if host in host_meta_vars.keys():
-                        config.set(key, host + " " + host_meta_vars[host])
-                    else:
-                        config.set(key, host)
-            if 'vars' in inventory[key]:
-                config.add_section(key + ":vars")
-                for var, value in inventory[key]['vars'].items():
-                    config.set(key + ":vars", var, value)
-
-    with open(output_file, 'w') as configfile:
-        config.write(configfile)
-
-
-def _get_host_meta_vars_as_dict(inventory):
-    """parse host meta vars from inventory as dict"""
-    host_meta_vars = {}
-    if '_meta' in inventory.keys():
-        if 'hostvars' in inventory['_meta']:
-            for host in inventory['_meta']['hostvars'].keys():
-                host_meta_vars[host] = ' '.join(
-                    '{}={}'.format(key, val) for key, val in inventory['_meta']['hostvars'][host].items())
-    return host_meta_vars
-
-
-def parse_args():
-    """parse arguments to script"""
-    parser = argparse.ArgumentParser(description="Create ansible inventory.")
-    parser.add_argument('--static', type=str, default='',
-                        help='File to store a static inventory in.')
-    parser.add_argument('--list', action="store_true", default=False,
-                        help='List inventory.')
-
-    return parser.parse_args()
-
-
 if __name__ == '__main__':
-    if parse_args().static:
-        output_inventory(build_inventory(), parse_args().static)
-    else:
-        print(json.dumps(build_inventory(), indent=4, sort_keys=True))
+    resources.main(build_inventory)

playbooks/openstack/resources.py

@@ -0,0 +1,297 @@
+#!/usr/bin/env python
+"""
+This library is used by the OpenStack's dynamic inventories.
+
+It produces the inventory in a Python dict structure based on the current
+environment.
+"""
+
+from __future__ import print_function
+
+import argparse
+import json
+import os
+try:
+    import ConfigParser
+except ImportError:
+    import configparser as ConfigParser
+
+from keystoneauth1.exceptions.catalog import EndpointNotFound
+import shade
+
+
+def base_openshift_inventory(cluster_hosts):
+    '''Set the base openshift inventory.'''
+    inventory = {}
+
+    masters = [server.name for server in cluster_hosts
+               if server.metadata['host-type'] == 'master']
+
+    etcd = [server.name for server in cluster_hosts
+            if server.metadata['host-type'] == 'etcd']
+    if not etcd:
+        etcd = masters
+
+    infra_hosts = [server.name for server in cluster_hosts
+                   if server.metadata['host-type'] == 'node' and
+                   server.metadata['sub-host-type'] == 'infra']
+
+    app = [server.name for server in cluster_hosts
+           if server.metadata['host-type'] == 'node' and
+           server.metadata['sub-host-type'] == 'app']
+
+    cns = [server.name for server in cluster_hosts
+           if server.metadata['host-type'] == 'cns']
+
+    load_balancers = [server.name for server in cluster_hosts
+                      if server.metadata['host-type'] == 'lb']
+
+    # NOTE: everything that should go to the `[nodes]` group:
+    nodes = list(set(masters + etcd + infra_hosts + app + cns))
+
+    # NOTE: all OpenShift nodes, including `[lb]`, `[nfs]`, etc.:
+    osev3 = list(set(nodes + load_balancers))
+
+    inventory['OSEv3'] = {'hosts': osev3, 'vars': {}}
+    inventory['openstack_nodes'] = {'hosts': nodes}
+    inventory['openstack_master_nodes'] = {'hosts': masters}
+    inventory['openstack_etcd_nodes'] = {'hosts': etcd}
+    inventory['openstack_infra_nodes'] = {'hosts': infra_hosts}
+    inventory['openstack_compute_nodes'] = {'hosts': app}
+    inventory['openstack_cns_nodes'] = {'hosts': cns}
+    inventory['lb'] = {'hosts': load_balancers}
+    inventory['localhost'] = {'ansible_connection': 'local'}
+
+    return inventory
+
+
+def get_docker_storage_mountpoints(volumes):
+    '''Check volumes to see if they're being used for docker storage'''
+    docker_storage_mountpoints = {}
+    for volume in volumes:
+        if volume.metadata.get('purpose') == "openshift_docker_storage":
+            for attachment in volume.attachments:
+                if attachment.server_id in docker_storage_mountpoints:
+                    docker_storage_mountpoints[attachment.server_id].append(attachment.device)
+                else:
+                    docker_storage_mountpoints[attachment.server_id] = [attachment.device]
+    return docker_storage_mountpoints
+
+
+def _get_hostvars(server, docker_storage_mountpoints):
+    ssh_ip_address = server.public_v4 or server.private_v4
+    hostvars = {
+        'ansible_host': ssh_ip_address
+    }
+
+    public_v4 = server.public_v4 or server.private_v4
+    if public_v4:
+        hostvars['public_v4'] = server.public_v4
+        hostvars['openshift_public_ip'] = server.public_v4
+    # TODO(shadower): what about multiple networks?
+    if server.private_v4:
+        hostvars['private_v4'] = server.private_v4
+        hostvars['openshift_ip'] = server.private_v4
+
+        # NOTE(shadower): Yes, we set both hostname and IP to the private
+        # IP address for each node. OpenStack doesn't resolve nodes by
+        # name at all, so using a hostname here would require an internal
+        # DNS which would complicate the setup and potentially introduce
+        # performance issues.
+        hostvars['openshift_hostname'] = server.metadata.get(
+            'openshift_hostname', server.private_v4)
+    hostvars['openshift_public_hostname'] = server.name
+
+    if server.metadata['host-type'] == 'cns':
+        hostvars['glusterfs_devices'] = ['/dev/nvme0n1']
+
+    group_name = server.metadata.get('openshift_node_group_name')
+    hostvars['openshift_node_group_name'] = group_name
+
+    # check for attached docker storage volumes
+    if 'os-extended-volumes:volumes_attached' in server:
+        if server.id in docker_storage_mountpoints:
+            hostvars['docker_storage_mountpoints'] = ' '.join(
+                docker_storage_mountpoints[server.id])
+    return hostvars
+
+
+def build_inventory():
+    '''Build the dynamic inventory.'''
+    cloud = shade.openstack_cloud()
+
+    # Use an environment variable to optionally skip returning the app nodes.
+    show_compute_nodes = os.environ.get('OPENSTACK_SHOW_COMPUTE_NODES', 'true').lower() == "true"
+
+    # TODO(shadower): filter the servers based on the `OPENSHIFT_CLUSTER`
+    # environment variable.
+    cluster_hosts = [
+        server for server in cloud.list_servers()
+        if 'metadata' in server and 'clusterid' in server.metadata and
+        (show_compute_nodes or server.metadata.get('sub-host-type') != 'app')]
+
+    inventory = base_openshift_inventory(cluster_hosts)
+
+    inventory['_meta'] = {'hostvars': {}}
+
+    # Some clouds don't have Cinder. That's okay:
+    try:
+        volumes = cloud.list_volumes()
+    except EndpointNotFound:
+        volumes = []
+
+    # cinder volumes used for docker storage
+    docker_storage_mountpoints = get_docker_storage_mountpoints(volumes)
+    for server in cluster_hosts:
+        inventory['_meta']['hostvars'][server.name] = _get_hostvars(
+            server,
+            docker_storage_mountpoints)
+
+    stout = _get_stack_outputs(cloud)
+    if stout is not None:
+        try:
+            inventory['localhost'].update({
+                'openshift_openstack_api_lb_provider':
+                stout['api_lb_provider'],
+                'openshift_openstack_api_lb_port_id':
+                stout['api_lb_vip_port_id'],
+                'openshift_openstack_api_lb_sg_id':
+                stout['api_lb_sg_id']})
+        except KeyError:
+            pass  # Not an API load balanced deployment
+
+        try:
+            inventory['OSEv3']['vars'][
+                'openshift_master_cluster_hostname'] = stout['private_api_ip']
+        except KeyError:
+            pass  # Internal LB not specified
+
+        inventory['localhost']['openshift_openstack_private_api_ip'] = \
+            stout.get('private_api_ip')
+        inventory['localhost']['openshift_openstack_public_api_ip'] = \
+            stout.get('public_api_ip')
+        inventory['localhost']['openshift_openstack_public_router_ip'] = \
+            stout.get('public_router_ip')
+
+        try:
+            inventory['OSEv3']['vars'] = _get_kuryr_vars(cloud, stout)
+        except KeyError:
+            pass  # Not a kuryr deployment
+    return inventory
+
+
+def _get_stack_outputs(cloud_client):
+    """Returns a dictionary with the stack outputs"""
+    cluster_name = os.getenv('OPENSHIFT_CLUSTER', 'openshift-cluster')
+
+    stack = cloud_client.get_stack(cluster_name)
+    if stack is None or stack['stack_status'] not in (
+            'CREATE_COMPLETE', 'UPDATE_COMPLETE'):
+        return None
+
+    data = {}
+    for output in stack['outputs']:
+        data[output['output_key']] = output['output_value']
+    return data
+
+
+def _get_kuryr_vars(cloud_client, data):
+    """Returns a dictionary of Kuryr variables resulting of heat stacking"""
+    settings = {}
+    settings['kuryr_openstack_pod_subnet_id'] = data['pod_subnet']
+    if 'pod_subnet_pool' in data:
+        settings['kuryr_openstack_pod_subnet_pool_id'] = data[
+            'pod_subnet_pool']
+    if 'sg_allow_from_default' in data:
+        settings['kuryr_openstack_sg_allow_from_default_id'] = data[
+            'sg_allow_from_default']
+    if 'sg_allow_from_namespace' in data:
+        settings['kuryr_openstack_sg_allow_from_namespace_id'] = data[
+            'sg_allow_from_namespace']
+    settings['kuryr_openstack_pod_router_id'] = data['pod_router']
+    settings['kuryr_openstack_worker_nodes_subnet_id'] = data['vm_subnet']
+    settings['kuryr_openstack_service_subnet_id'] = data['service_subnet']
+    settings['kuryr_openstack_pod_sg_id'] = data['pod_access_sg_id']
+    settings['kuryr_openstack_pod_project_id'] = (
+        cloud_client.current_project_id)
+    settings['kuryr_openstack_api_lb_ip'] = data['private_api_ip']
+
+    settings['kuryr_openstack_auth_url'] = cloud_client.auth['auth_url']
+    settings['kuryr_openstack_username'] = cloud_client.auth['username']
+    settings['kuryr_openstack_password'] = cloud_client.auth['password']
+    if 'user_domain_id' in cloud_client.auth:
+        settings['kuryr_openstack_user_domain_name'] = (
+            cloud_client.auth['user_domain_id'])
+    else:
+        settings['kuryr_openstack_user_domain_name'] = (
+            cloud_client.auth['user_domain_name'])
+    # FIXME(apuimedo): consolidate kuryr controller credentials into the same
+    #                  vars the openstack playbook uses.
+    settings['kuryr_openstack_project_id'] = cloud_client.current_project_id
+    if 'project_domain_id' in cloud_client.auth:
+        settings['kuryr_openstack_project_domain_name'] = (
+            cloud_client.auth['project_domain_id'])
+    else:
+        settings['kuryr_openstack_project_domain_name'] = (
+            cloud_client.auth['project_domain_name'])
+    return settings
+
+
+def output_inventory(inventory, output_file):
+    """Outputs inventory into a file in ini format"""
+    config = ConfigParser.ConfigParser(allow_no_value=True)
+
+    host_meta_vars = _get_host_meta_vars_as_dict(inventory)
+
+    for key in sorted(inventory.keys()):
+        if key == 'localhost':
+            config.add_section('localhost')
+            config.set('localhost', 'localhost')
+            config.add_section('localhost:vars')
+            for var, value in inventory['localhost'].items():
+                config.set('localhost:vars', var, value)
+        elif key not in ('localhost', '_meta'):
+            if 'hosts' in inventory[key]:
+                config.add_section(key)
+                for host in inventory[key]['hosts']:
+                    if host in host_meta_vars.keys():
+                        config.set(key, host + " " + host_meta_vars[host])
+                    else:
+                        config.set(key, host)
+            if 'vars' in inventory[key]:
+                config.add_section(key + ":vars")
+                for var, value in inventory[key]['vars'].items():
+                    config.set(key + ":vars", var, value)
+
+    with open(output_file, 'w') as configfile:
+        config.write(configfile)
+
+
+def _get_host_meta_vars_as_dict(inventory):
+    """parse host meta vars from inventory as dict"""
+    host_meta_vars = {}
+    if '_meta' in inventory.keys():
+        if 'hostvars' in inventory['_meta']:
+            for host in inventory['_meta']['hostvars'].keys():
+                host_meta_vars[host] = ' '.join(
+                    '{}={}'.format(key, val) for key, val in inventory['_meta']['hostvars'][host].items())
+    return host_meta_vars
+
+
+def parse_args():
+    """parse arguments to script"""
+    parser = argparse.ArgumentParser(description="Create ansible inventory.")
+    parser.add_argument('--static', type=str, default='',
+                        help='File to store a static inventory in.')
+    parser.add_argument('--list', action="store_true", default=False,
+                        help='List inventory.')
+
+    return parser.parse_args()
+
+
+def main(inventory_builder):
+    """Ansible dynamic inventory entry point."""
+    if parse_args().static:
+        output_inventory(inventory_builder(), parse_args().static)
+    else:
+        print(json.dumps(inventory_builder(), indent=4, sort_keys=True))

playbooks/openstack/scaleup_inventory.py

@@ -0,0 +1,15 @@
+#!/usr/bin/env python
+"""
+This is an Ansible dynamic inventory for OpenStack, specifically for use with
+the scaling playbooks.
+
+It requires your OpenStack credentials to be set in clouds.yaml or your shell
+environment.
+
+"""
+
+import resources
+
+
+if __name__ == '__main__':
+    resources.main(resources.build_inventory)