一. 简述：
ansible是一个非常强大的工具，可以支持多种类型(字符,数字,列表，字典等)的变量。除了有大量的内置变量及fact变量，也可以通过多种方式进行变量自定义 。不同方式定义的变量，优先级也不太一样，之前有写过变量定义的说明，这里，从在使用api的过程中说明下。
二. VariableManager变量详解与使用案例
如果了解/使用过python 2.0版本以上的同学， 应该不会陌生以下几个类：
from collections import namedtuple
from ansible.parsing.dataloader import DataLoader
from ansible.vars import VariableManager
from ansible.inventory import Inventory
from ansible.playbook.play import Play
from ansible.executor.task_queue_manager import TaskQueueManager
from ansible.plugins.callback import CallbackBase 其中VariableManager是用来存储各类的变量信息的。大家都知道，ansible可以分别通过yaml配置文件中的var，命令行的方式进行变量定义，hosts文件，也可以通过register(task内部专递)，交互式的定义。 其实，还可以在一些比较特殊的场景进行变量定义。比如，我们动态生成hosts时(inventory),也可以定义。当然，在走api时，也可以通过这里要说的，VariableManager模块定义。
案例 (抛砖引玉)：
通常情况下，我们可能会把变量定义在hosts文件，或者var下， 但在有些特殊的环境下，其实并不能满足我们的需求。比如，我司有aws，ali，ten等多个云运营商，同时，我们还会使用不同的系统版本(如centos6、fedora7)在在这个环境系下，我们不希望在初始化时，不同的商家/版本，使用不同的初始化脚本(playbook )【如果单独使用，意味着我们需要维护至少6个,三个运营商的提供环境是有差异性的， 当然，我们也考虑过基于某一个运营商的系统，打镜像，然后上传至其他运行商，实现环境统一的情况，但我们不能保证，这样操作会不会跟云平台能够完全契合】。所以，对于这种环境，我们需要设计一个统一的操作script，动态获取系统所属版本，所在运营商。include对应的配合文件，进行初始化工作。
结构如下：
# tree roles/ -d
initial_system.yaml
roles/
├── initial_system_6
│ ├── files
│ ├── handlers
│ ├── tasks
│ │ ├── disk_initial.yaml
│ │ ├── file_copy.yaml
│ │ ├── jenkins_node.yaml
│ │ ├── main_ten.yaml
│ │ ├── main_ali.yaml
│ │ ├── main_aws.yaml
│ │ ├── main.yaml
│ │ ├── mysql_master.yaml
│ │ ├── mysql_slave.yaml
│ │ ├── nginx.yaml
│ │ ├── nodejs.yaml
│ │ ├── package_install.yaml
│ │ ├── py35.yaml
│ │ └── tomcat.yaml
│ ├── templates
│ └── vars
├── initial_system_7
│ ├── files
│ ├── handlers
│ ├── tasks
│ │ ├── disk_initial.yaml
│ │ ├── file_copy.yaml
│ │ ├── jenkins_node.yaml
│ │ ├── main_ten.yaml
│ │ ├── main_ali.yaml
│ │ ├── main_aws.yaml
│ │ ├── main.yaml
│ │ ├── mysql_master.yaml
│ │ ├── mysql_slave.yaml
│ │ ├── nginx.yaml
│ │ ├── nodejs.yaml
│ │ ├── package_install.yaml
│ │ ├── py35.yaml
│ │ └── tomcat.yaml
│ ├── templates
│ └── vars如上图，我需要根据系统版本号，include对应的系统版本role(initial_system_6/7)。然后加载对应的task/main.yaml, 再根据获取的idc/运营商，加载不同的配置文件(main_aws.yaml)
我的playbook主配置内容如下：
# cat initial_system.yaml
---
- hosts: "{{ host_name }}"
remote_user: ansible
become: yes
serial: 5
gather_facts: no
roles:
- initial_system_{{ system_versions }}在这种情况下，我们是不能通过hosts/（inventory）来定义system_versions(系统版本)变量的，因为它在执行时roles时，还未获取到对应的变量， 这种情况下，如果不走api(源码入手)，我们只能通过命令(ansible-playbook -e)的方式进行传递。 由于我们采用了api， 所以，我们可以通过上文中的VariableManager模块进行变量定义。
代码片段如下：
。。。。。。。。。。。。。。。。
class vipkidplayexecutor(PlaybookExecutor):
def __init__(self,playbooks,inventory,variable_manager,loader,options,passwords,stdout_callback=None):
self._playbooks = playbooks
self._inventory = inventory
self._variable_manager = variable_manager
self._loader = loader
self._options = options
self.passwords = passwords
self._unreachable_hosts = dict()
if options.listhosts or options.listtasks or options.listtags or options.syntax:
self._tqm = None
else:
self._tqm = TaskQueueManager(inventory=inventory, variable_manager=variable_manager, loader=loader, options=options, passwords=self.passwords, stdout_callback=stdout_callback)
check_for_controlpersist(C.ANSIBLE_SSH_EXECUTABLE)
class Playbookjob(object):
def __init__(self,playbooks,host_list,host_name,support_service=[],ssh_user='ansiblle',passwords=None,forks=5):
self.playbooks = playbooks
self.host_list = host_list
self.ssh_user = ssh_user
self.passwords = dict(vault_pass=passwords)
self.forks = forks
self.host_variable = {'host_name':host_name,'support_service':support_service}
self.variable_manager = VariableManager()
self.variable_manager.extra_vars = dict(data_obtain(host_name),**self.host_variable)
print(self.variable_manager.extra_vars)
self.loader = DataLoader()
self.Options = namedtuple('Options', ['connection', 'module_path', 'forks', 'become', 'become_method', 'become_user','remote_user', 'check', 'sudo_user', 'sudo','listhosts','listtasks','listtags','syntax'])
self.options = self.Options(connection='smart', module_path=None, forks=self.forks, become=True, become_method='sudo', become_user='root',remote_user=self.ssh_user, check=False,sudo_user=None,sudo='yes',listhosts=None,listtasks=None,listtags=None,syntax=None)
self.results_callback = CallbackModule()
#host_list produce
inev_data = open(self.host_list,'r').read()
inev_file = '#!/usr/bin/python\nhost_info={"all":{"hosts":%s}}\n%s' % (host_name.split(','),inev_data)
self.hostsFile = NamedTemporaryFile(delete=False)
self.hostsFile.write(inev_file)
self.hostsFile.close()
self.inventory = Inventory(loader=self.loader, variable_manager=self.variable_manager, host_list=self.hostsFile.name)
# print('-----%s' %self.host_list)
# self.inventory = Inventory(loader=self.loader, variable_manager=self.variable_manager, host_list=self.host_list)
self.variable_manager.set_inventory(self.inventory)
def run(self):
playbook_control = vipkidplayexecutor(
playbooks = self.playbooks,
inventory = self.inventory,
variable_manager = self.variable_manager,
loader = self.loader,
options = self.options,
passwords = self.passwords,
stdout_callback = self.results_callback
)
playbook_control.run()
。。。。。。。。。。。。。。。。先定义类self.variable_manager = VariableManager()
然后添加变量脚本传入变量: {'host_name':host_name,'support_service':support_service}
然后将变量加载至variable_manager的extra_vars方法,然后交给api(vipkidPlaybookExecutor)操作。
存储的变量(extra_vars)其实就是一个字典(dict), 代码中引入了变量和data_obtain方法的结果，可解析为：
{'host_name': 'l-ansible-initial1.ops.prod.aws.dm', 'system_versions': 6, 'b': 'c', 'support_service': ['tomcat','nginx']}传入要初始化的主机(host_name)，系统版本(system_versions),部署的服务(tomcat，nginx)。
然后通过TaskQueueManager将变量传递到Task。
感兴趣或有相关需求的同学，可以根据实际情况适配。
----------------------------------------------------------------------------------------------
深耕运维行业多年，擅长linux、容器云原生、运维自动化等方面。
承接各类运维环境部署、方案设计/实施、服务代运维工作，欢迎沟通交流 ！
