一. 简述：

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: ansiblebecome: yesserial: 5gather_facts: noroles:- 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 = playbooksself._inventory = inventoryself._variable_manager = variable_managerself._loader = loaderself._options = optionsself.passwords = passwordsself._unreachable_hosts = dict()if options.listhosts or options.listtasks or options.listtags or options.syntax:self._tqm = Noneelse: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 = playbooksself.host_list = host_listself.ssh_user = ssh_userself.passwords = dict(vault_pass=passwords)self.forks = forksself.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 produceinev_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']}

 感兴趣或有相关需求的同学，可以根据实际情况适配。

 ----------------------------------------------------------------------------------------------

深耕运维行业多年，擅长linux、容器云原生、运维自动化等方面。
承接各类运维环境部署、方案设计/实施、服务代运维工作，欢迎沟通交流 ！