ansible api2.0 多进程执行不同的playbook

fenghzy

#!/usr/bin/env python　　
# coding=utf-8
　　
import json
　　
import logging
　　
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.executor.playbook_executor import PlaybookExecutor
　　
from ansible.plugins.callback import CallbackBase
　　
from collections import namedtuple
　　
from ansible import constants as C
　　
import ansible.executor.task_result
　　
import multiprocessing
　　

　　


　　
>　　

　　
     def v2_runner_on_ok(self, result):
　　
         host = result._host
　　
         logging.warning('===v2_runner_on_ok====host=%s===result=%s' % (host, result._result))
　　

　　

　　
     def v2_runner_on_failed(self, result, ignore_errors=False):
　　
         host = result._host
　　
         logging.warning('===v2_runner_on_failed====host=%s===result=%s' % (host, result._result))
　　

　　
     def v2_runner_on_unreachable(self, result):
　　
         host = result._host
　　
         logging.warning('===v2_runner_on_unreachable====host=%s===result=%s' % (host, result._result))
　　

　　


　　
>　　
     def __init__(self, hostlist, playbooks, *args, **kwargs):
　　
         self.hostlist = hostlist
　　
         self.playbooks = playbooks
　　
         self.passwords = None
　　
         self.callback = None
　　
         Options = namedtuple('Options', ['connection', 'remote_user', 'ask_sudo_pass', 'verbosity', 'ack_pass',
　　
                                          'module_path', 'forks', 'become', 'become_method', 'become_user',
　　
                                          'check', 'listhosts', 'listtasks', 'listtags', 'syntax',
　　
                                          'sudo_user', 'sudo', 'display_skipped_hosts'])
　　

　　
         self.options = Options(connection='smart', remote_user='root', ack_pass=None, sudo_user='root',
　　
                                forks=200, sudo='yes', ask_sudo_pass=False, verbosity=5, module_path=None,
　　
                                become=True, become_method='su', become_user='root', check=None, listhosts=False,
　　
                                listtasks=False, listtags=None, syntax=None, display_skipped_hosts=False)
　　
         self.loader = DataLoader()
　　
         self.variable_manager = VariableManager()
　　
         self.inventory = Inventory(loader=self.loader, variable_manager=self.variable_manager,
　　
                                    host_list=self.hostlist)
　　
         self.variable_manager.set_inventory(self.inventory)
　　
         self.variable_manager.extra_vars = {"ansible_ssh_user": "root"}  # 额外参数，包括playbook参数 key:value
　　

　　
     def runplaybook(self):
　　
         playbook = PlaybookExecutor(
　　
             playbooks=self.playbooks,
　　
             inventory=self.inventory,
　　
             variable_manager=self.variable_manager,
　　
             loader=self.loader,
　　
             options=self.options,
　　
             passwords=None)
　　
         playbook._tqm._stdout_callback = ResultsCollector()
　　
         playbook.run()
　　

　　
if __name__ == '__main__':
　　
     #创建对象
　　
     anl = AnsibleAPI(['10.26.222.216'], ['/root/ansibleInventory_cl/df.yml'])
　　
     an2 = AnsibleAPI(['10.26.222.210', '10.26.222.213'], ['/root/ansibleInventory_cl/ifconfig.yml'])
　　
     #多进程
　　
     processes = []
　　
     p1 = multiprocessing.Process(name='process_one', target=anl.runplaybook)
　　
     p2 = multiprocessing.Process(name='process_two', target=an2.runplaybook)
　　
     processes.append(p1)
　　
     processes.append(p2)
　　
     for p in processes:
　　
         p.start()
　　

　　
     print('tasks completed')