mirror of https://github.com/ansible/ansible.git
New generator inventory plugin (#37690)
* New generator inventory plugin Allows construction of hosts and groups through cartesian product of various group combinations * Add generator plugin documentationpull/37367/merge
parent
40a55e9f55
commit
9802088082
@ -0,0 +1,135 @@
|
||||
# Copyright (c) 2017 Ansible Project
|
||||
# GNU General Public License v3.0+ (see COPYING or https://www.gnu.org/licenses/gpl-3.0.txt)
|
||||
|
||||
from __future__ import (absolute_import, division, print_function)
|
||||
__metaclass__ = type
|
||||
|
||||
DOCUMENTATION = '''
|
||||
name: generator
|
||||
plugin_type: inventory
|
||||
version_added: "2.6"
|
||||
short_description: Uses Jinja2 to construct hosts and groups from patterns
|
||||
description:
|
||||
- Uses a YAML configuration file with a valid YAML or C(.config) extension to define var expressions and group conditionals
|
||||
- Create a template pattern that describes each host, and then use independent configuration layers
|
||||
- Every element of every layer is combined to create a host for every layer combination
|
||||
- Parent groups can be defined with reference to hosts and other groups using the same template variables
|
||||
options:
|
||||
hosts:
|
||||
description:
|
||||
- The C(name) key is a template used to generate
|
||||
hostnames based on the C(layers) option. Each variable in the name is expanded to create a
|
||||
cartesian product of all possible layer combinations.
|
||||
- The C(parents) are a list of parent groups that the host belongs to. Each C(parent) item
|
||||
contains a C(name) key, again expanded from the template, and an optional C(parents) key
|
||||
that lists its parents.
|
||||
- Parents can also contain C(vars), which is a dictionary of vars that
|
||||
is then always set for that variable. This can provide easy access to the group name. E.g
|
||||
set an C(application) variable that is set to the value of the C(application) layer name.
|
||||
layers:
|
||||
description:
|
||||
- A dictionary of layers, with the key being the layer name, used as a variable name in the C(host)
|
||||
C(name) and C(parents) keys. Each layer value is a list of possible values for that layer.
|
||||
'''
|
||||
|
||||
EXAMPLES = '''
|
||||
# inventory.config file in YAML format
|
||||
plugin: generator
|
||||
strict: False
|
||||
hosts:
|
||||
name: "{{ operation }}-{{ application }}-{{ environment }}-runner"
|
||||
parents:
|
||||
- name: "{{ operation }}-{{ application }}-{{ environment }}"
|
||||
parents:
|
||||
- name: "{{ operation }}-{{ application }}"
|
||||
parents:
|
||||
- name: "{{ operation }}"
|
||||
- name: "{{ application }}"
|
||||
- name: "{{ application }}-{{ environment }}"
|
||||
parents:
|
||||
- name: "{{ application }}"
|
||||
vars:
|
||||
application: "{{ application }}"
|
||||
- name: "{{ environment }}"
|
||||
vars:
|
||||
environment: "{{ environment }}"
|
||||
- name: runner
|
||||
layers:
|
||||
operation:
|
||||
- build
|
||||
- launch
|
||||
environment:
|
||||
- dev
|
||||
- test
|
||||
- prod
|
||||
application:
|
||||
- web
|
||||
- api
|
||||
'''
|
||||
|
||||
import os
|
||||
|
||||
from ansible import constants as C
|
||||
from ansible.errors import AnsibleParserError
|
||||
from ansible.plugins.cache import FactCache
|
||||
from ansible.plugins.inventory import BaseInventoryPlugin
|
||||
|
||||
from itertools import product
|
||||
|
||||
|
||||
class InventoryModule(BaseInventoryPlugin):
|
||||
""" constructs groups and vars using Jinaj2 template expressions """
|
||||
|
||||
NAME = 'generator'
|
||||
|
||||
def __init__(self):
|
||||
|
||||
super(InventoryModule, self).__init__()
|
||||
|
||||
self._cache = FactCache()
|
||||
|
||||
def verify_file(self, path):
|
||||
|
||||
valid = False
|
||||
if super(InventoryModule, self).verify_file(path):
|
||||
file_name, ext = os.path.splitext(path)
|
||||
|
||||
if not ext or ext in ['.config'] + C.YAML_FILENAME_EXTENSIONS:
|
||||
valid = True
|
||||
|
||||
return valid
|
||||
|
||||
def template(self, pattern, variables):
|
||||
t = self.templar
|
||||
t.set_available_variables(variables)
|
||||
return t.do_template(pattern)
|
||||
|
||||
def add_parents(self, inventory, child, parents, template_vars):
|
||||
for parent in parents:
|
||||
try:
|
||||
groupname = self.template(parent['name'], template_vars)
|
||||
except (AttributeError, ValueError):
|
||||
raise AnsibleParserError("Element %s has a parent with no name element" % child['name'])
|
||||
if groupname not in inventory.groups:
|
||||
inventory.add_group(groupname)
|
||||
group = inventory.groups[groupname]
|
||||
for (k, v) in parent.get('vars', {}).items():
|
||||
group.set_variable(k, self.template(v, template_vars))
|
||||
inventory.add_child(groupname, child)
|
||||
self.add_parents(inventory, groupname, parent.get('parents', []), template_vars)
|
||||
|
||||
def parse(self, inventory, loader, path, cache=False):
|
||||
''' parses the inventory file '''
|
||||
|
||||
super(InventoryModule, self).parse(inventory, loader, path, cache=cache)
|
||||
|
||||
config = self._read_config_data(path)
|
||||
|
||||
template_inputs = product(*config['layers'].values())
|
||||
for item in template_inputs:
|
||||
template_vars = dict()
|
||||
for i, key in enumerate(config['layers'].keys()):
|
||||
template_vars[key] = item[i]
|
||||
host = self.template(config['hosts']['name'], template_vars)
|
||||
inventory.add_host(host)
|
||||
self.add_parents(inventory, host, config['hosts'].get('parents', []), template_vars)
|
Loading…
Reference in New Issue