使用Python API 2.0.0.1运行Ansible Playbook

Question

Ansible版本：2.0.0.1

我已经看了很多遍了，我发现的大多数文档要么不完整，要么已弃用（this post is for version 1.8.4, ie）

我正在尝试通过Python API启动Ansible playbook。Ansible的文档似乎展示了如何生成和播放任务，但没有展示如何加载和运行PlaybookYML文件。我一直在深入研究代码，试图了解如何启动它，我想我已经取得了一些进展，但我真的遇到了困难。以下是我目前掌握的情况：

def createcluster(region, environment, cluster):
    Options = namedtuple('Options', ['region','env', 'cluster'])

    # initialize needed objects
    variable_manager = VariableManager()
    loader = DataLoader()
    options = Options(region=region, env=environment, cluster=cluster)
    options.listhosts = False
    vault_password = getpass.getpass('Enter vault password :')
    passwords = dict(vault_pass=vault_password)

    #Getting hosts
    hostsread = open('provisioning/inventory/hosts','r')
    hosts =  hostsread.read()
    inventory = Inventory(loader=loader, variable_manager=variable_manager, host_list=hosts)
    variable_manager.set_inventory(inventory)
    #Create and load the playbook file
    playbook = Playbook(loader)
    playbook.load('provisioning/cluster.yml', variable_manager,loader)

    #Create an executor to launch the playbook ? 
    executor = None
    executor = PlaybookExecutor(playbook,inventory,variable_manager,loader,options,passwords)
    try:
        result = executor.run()
    finally:
        if executor is not None:
            executor.cleanup()

我对执行器部分一点也不确定，当我尝试启动代码时，我一直收到一个“attributerror:”Options“object has no attribute‘listhosts’”错误（奇怪的是，它应该忽略它的不存在，我认为(line 60)）

我应该如何加载一个YML文件并通过Python API启动它？我是走在好的道路上还是迷失了自我？为什么Ansible没有更好的文档？为什么42是7*7的答案？

Answer 1

我写这篇文章时没有看到你想要版本2。留下来，尽管这不是正确的答案。

这将在1.9中起作用。您可以修改createcluster（）命令来调用它。

def run_ansible():
  vaultpass = "password"
  inventory = ansible.inventory.Inventory("provisioning/inventory/hosts", vault_password=vaultpass)

  stats = callbacks.AggregateStats()
  playbook_cb = callbacks.PlaybookCallbacks(verbose=3)

  pb = ansible.playbook.PlayBook(
            playbook=playbook,
            inventory=inventory,
            extra_vars=parsed_extra_vars,
            #private_key_file="/path/to/key.pem",
            vault_password=vaultpass,
            stats=stats,
            callbacks=playbook_cb,
            runner_callbacks=callbacks.PlaybookRunnerCallbacks(stats, verbose=3)
        )
  pb.run()

  hosts = sorted(pb.stats.processed.keys())

  failed_hosts = []
  unreachable_hosts = []
  for h in hosts:
    t = pb.stats.summarize(h)
    if t['failures'] > 0:
      failed_hosts.append(h)
    if t['unreachable'] > 0:
      unreachable_hosts.append(h)

  print("failed hosts: ", failed_hosts)
  print("unreachable hosts: ", unreachable_hosts)

  retries = failed_hosts + unreachable_hosts
  print("retries:", retries)
  if len(retries) > 0:
    return 1
  return 0