ansible api调用

Posted 2020-10-14

例子:
#!/usr/bin/python
import json
from collections import namedtuple
from ansible.parsing.dataloader import DataLoader
from ansible.vars.manager import VariableManager
from ansible.inventory.manager import InventoryManager
from ansible.playbook.play import Play
from ansible.executor.task_queue_manager import TaskQueueManager
from ansible.executor.task_result import TaskResult
from ansible.plugins.callback import CallbackBase

class ResultCallback(CallbackBase):
	def v2_runner_on_ok(self, result, **kwargs):
		host = result._host
		print(json.dumps({host.name: result._result}, indent=4))

Options = namedtuple(‘Options‘, [‘connection‘, ‘module_path‘, ‘forks‘, ‘become‘, ‘become_method‘, ‘become_user‘, ‘check‘, ‘diff‘])
loader = DataLoader()
options = Options(connection=‘smart‘, module_path=None, forks=2, become=None, become_method=None, become_user=None, check=False, diff=False)
#connection参数，如果执行本地节点用‘local‘, 远端节点用‘smart‘
#passwords = dict(vault_pass=‘xxxxx‘)    #密钥方式取消这步
results_callback = ResultCallback()

inventory = InventoryManager(loader=loader, sources=[‘hosts‘])
variable_manager = VariableManager(loader=loader, inventory=inventory)
#variable_manager.set_inventory(inventory)

play_source = dict(
	name = "Ansible Play",
	hosts = ‘webserver‘,
	gather_facts = ‘no‘,
	tasks = [
		dict(action=dict(module=‘shell‘, args=‘df -Th‘), register=‘shell_out‘),
	]
)

play = Play().load(play_source, variable_manager=variable_manager, loader=loader)

tqm = None
try:
	tqm = TaskQueueManager(
		inventory=inventory,
		variable_manager=variable_manager,
		loader=loader,
		options=options,
		passwords=None,
		stdout_callback=results_callback,
		)
	result = tqm.run(play)
	print(result)
finally:
	if tqm is not None:
		tqm.cleanup()

本文出自 “linux技术” 博客，请务必保留此出处http://haoyonghui.blog.51cto.com/4278020/1982517