ansible/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2024-09-14 20:13:21 +02:00
Code Releases Activity

support OS_CLOUD in openstack dynamic inventory

Browse source 
allow a user to limit to a single cloud in clouds.yaml, and support
per-cloud caching.
This commit is contained in:
Gerard Lynch 2017-03-07 11:10:40 +02:00 committed by Toshio Kuratomi
parent fe5e1a4bc4
commit d9d983160d
1 changed files with 14 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
contrib/inventory/openstack.py
View file

@ -29,8 +29,11 @@
# - /etc/openstack/clouds.yaml # - /etc/openstack/clouds.yaml
# - /etc/ansible/openstack.yml # - /etc/ansible/openstack.yml
# The clouds.yaml file can contain entries for multiple clouds and multiple # The clouds.yaml file can contain entries for multiple clouds and multiple
# regions of those clouds. If it does, this inventory module will connect to # regions of those clouds. If it does, this inventory module will by default
# all of them and present them as one contiguous inventory. # connect to all of them and present them as one contiguous inventory. You
# can limit to one cloud by passing the `--cloud` parameter, or use the
# OS_CLOUD environment variable. If caching is enabled, and a cloud is
# selected, then per-cloud cache folders will be used.
# #
# See the adjacent openstack.yml file for an example config file # See the adjacent openstack.yml file for an example config file
# There are two ansible inventory specific options that can be set in # There are two ansible inventory specific options that can be set in
@ -108,8 +111,8 @@ def get_groups_from_server(server_vars, namegroup=True):
return groups return groups
def get_host_groups(inventory, refresh=False): def get_host_groups(inventory, refresh=False, cloud=None):
(cache_file, cache_expiration_time) = get_cache_settings() (cache_file, cache_expiration_time) = get_cache_settings(cloud)
if is_cache_stale(cache_file, cache_expiration_time, refresh=refresh): if is_cache_stale(cache_file, cache_expiration_time, refresh=refresh):
groups = to_json(get_host_groups_from_cloud(inventory)) groups = to_json(get_host_groups_from_cloud(inventory))
open(cache_file, 'w').write(groups) open(cache_file, 'w').write(groups)
@ -177,12 +180,14 @@ def is_cache_stale(cache_file, cache_expiration_time, refresh=False):
return True return True
def get_cache_settings(): def get_cache_settings(cloud=None):
config = os_client_config.config.OpenStackConfig( config = os_client_config.config.OpenStackConfig(
config_files=os_client_config.config.CONFIG_FILES + CONFIG_FILES) config_files=os_client_config.config.CONFIG_FILES + CONFIG_FILES)
# For inventory-wide caching # For inventory-wide caching
cache_expiration_time = config.get_cache_expiration_time() cache_expiration_time = config.get_cache_expiration_time()
cache_path = config.get_cache_path() cache_path = config.get_cache_path()
if cloud:
cache_path = '{0}_{1}'.format(cache_path, cloud)
if not os.path.exists(cache_path): if not os.path.exists(cache_path):
os.makedirs(cache_path) os.makedirs(cache_path)
cache_file = os.path.join(cache_path, 'ansible-inventory.cache') cache_file = os.path.join(cache_path, 'ansible-inventory.cache')
@ -195,6 +200,8 @@ def to_json(in_dict):
def parse_args(): def parse_args():
parser = argparse.ArgumentParser(description='OpenStack Inventory Module') parser = argparse.ArgumentParser(description='OpenStack Inventory Module')
parser.add_argument('--cloud', default=os.environ.get('OS_CLOUD'),
help='Cloud name (default: None')
parser.add_argument('--private', parser.add_argument('--private',
action='store_true', action='store_true',
help='Use private address for ansible host') help='Use private address for ansible host')
@ -219,7 +226,7 @@ def main():
refresh=args.refresh, refresh=args.refresh,
config_files=config_files, config_files=config_files,
private=args.private, private=args.private,
cloud=os.environ.get('OS_CLOUD') cloud=args.cloud,
) )
if hasattr(shade.inventory.OpenStackInventory, 'extra_config'): if hasattr(shade.inventory.OpenStackInventory, 'extra_config'):
inventory_args.update(dict( inventory_args.update(dict(
@ -234,7 +241,7 @@ def main():
inventory = shade.inventory.OpenStackInventory(**inventory_args) inventory = shade.inventory.OpenStackInventory(**inventory_args)
if args.list: if args.list:
output = get_host_groups(inventory, refresh=args.refresh) output = get_host_groups(inventory, refresh=args.refresh, cloud=args.cloud)
elif args.host: elif args.host:
output = to_json(inventory.get_host(args.host)) output = to_json(inventory.get_host(args.host))
print(output) print(output)