05 Oct 2016
ansible api 1.0使用非常方便和简单，但是2.0为了解耦和其他原因，将一些原生类提取出来直接作为api使用，ansible本身也是靠这些原生类驱动，可参考源码文件去了解以下api 源码文件所在路径为
/path/to/python's basedir/lib/python2.7/site-packages/ansible/cli/adhoc.py
下面为对官方示例的注释
#!/usr/bin/env python # # 导入ansible所需模块 # DataLoader, 负责数据解析 # VariableManager, 负责存储各类变量 # Inventory, 负责初始化hosts # Play, 负责初始化playbook # TaskQueueManager, 负责初始化执行对象, 其run()函数负责执行play # # ''' # TaskQueueManager(**, inventory=Inventory(**, host_list=hostsfile), options=options) # .run(Play().load(dict, variable_manager=VariableManager(), loader=DataLoader()) # ''' # import json 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 # # 用于执行结果的调用，使用示例如下 # TaskQueueManager(**, stdout_callback=results_callback, **).run(***) # class ResultCallback(CallbackBase): """A sample callback plugin used for performing an action as results come in If you want to collect all results into a single object for processing at the end of the execution, look into utilizing the ``json`` callback plugin or writing your own custom callback plugin """ def v2_runner_on_ok(self, result, **kwargs): """Print a json representation of the result This method could store the result in an instance attribute for retrieval later """ host = result._host print json.dumps({host.name: result._result}, indent=4) # # 初始化options(tuple) # 初始化passwords(dict) # 实例化数据解析器DataLoader()为loader # 实例化变量存储器VariableManager()为variable_manager # Options = namedtuple('Options', ['connection', 'module_path', 'forks', 'become', 'become_method', 'become_user', 'check']) # initialize needed objects variable_manager = VariableManager() loader = DataLoader() options = Options(connection='local', module_path='/path/to/mymodules', forks=100, become=None, become_method=None, become_user=None, check=False) passwords = dict(vault_pass='secret') # # 结果回调类实例化 # # Instantiate our ResultCallback for handling results as they come in # results_callback = ResultCallback() # # 指定loader, variable_manager和host_list, 来实例化Inventory()为inventory # 把inventory传递给variable_manager管理 # # create inventory and pass to var manager # inventory = Inventory(loader=loader, variable_manager=variable_manager, host_list='localhost') variable_manager.set_inventory(inventory) # # 创建playbook # # create play with tasks # play_source = dict( name = "Ansible Play", hosts = 'localhost', gather_facts = 'no', tasks = [ dict(action=dict(module='shell', args='ls'), register='shell_out'), dict(action=dict(module='debug', args=dict(msg='{{shell_out.stdout}}'))) ] ) play = Play().load(play_source, variable_manager=variable_manager, loader=loader) # # 通过TaskQueueManager().run()执行ansible，具体语法如下 # "TaskQueueManager(指定inventory，loader，variable_manager, options，passwords, stdout_callback).run(play)" # # actually run it # tqm = None try: tqm = TaskQueueManager( inventory=inventory, variable_manager=variable_manager, loader=loader, options=options, passwords=passwords, stdout_callback=results_callback, # Use our custom callback instead of the ``default`` callback plugin ) result = tqm.run(play) finally: if tqm is not None: tqm.cleanup()