summaryrefslogtreecommitdiffstats
path: root/qtip/driver/ansible_api.py
diff options
context:
space:
mode:
Diffstat (limited to 'qtip/driver/ansible_api.py')
-rw-r--r--qtip/driver/ansible_api.py58
1 files changed, 0 insertions, 58 deletions
diff --git a/qtip/driver/ansible_api.py b/qtip/driver/ansible_api.py
deleted file mode 100644
index 5c5baffc..00000000
--- a/qtip/driver/ansible_api.py
+++ /dev/null
@@ -1,58 +0,0 @@
-##############################################################################
-# Copyright (c) 2017 ZTE Corp and others.
-#
-# All rights reserved. This program and the accompanying materials
-# are made available under the terms of the Apache License, Version 2.0
-# which accompanies this distribution, and is available at
-# http://www.apache.org/licenses/LICENSE-2.0
-##############################################################################
-
-from collections import namedtuple
-
-from ansible.executor.playbook_executor import PlaybookExecutor
-from ansible.inventory import Inventory
-from ansible.parsing.dataloader import DataLoader
-from ansible.vars import VariableManager
-
-
-class AnsibleApi(object):
-
- def __init__(self):
- self.variable_manager = VariableManager()
- self.loader = DataLoader()
- self.passwords = {}
- self.playbook_executor = None
-
- def execute_playbook(self, playbook_path, hosts_file=None,
- key_file=None, extra_vars=None):
- inventory = Inventory(loader=self.loader,
- variable_manager=self.variable_manager,
- host_list=hosts_file)
- Options = namedtuple('Options',
- ['listtags', 'listtasks', 'listhosts', 'syntax',
- 'connection', 'module_path', 'forks', 'remote_user',
- 'private_key_file', 'ssh_common_args', 'ssh_extra_args',
- 'sftp_extra_args', 'scp_extra_args', 'become',
- 'become_method', 'become_user', 'verbosity', 'check'])
- options = Options(listtags=False, listtasks=False, listhosts=False,
- syntax=False, connection='ssh', module_path=None,
- forks=100, remote_user='root', private_key_file=key_file,
- ssh_common_args=None, ssh_extra_args=None, sftp_extra_args=None,
- scp_extra_args=None, become=None, become_method=None,
- become_user='root', verbosity=None, check=False)
- self.variable_manager.extra_vars = extra_vars
-
- self.playbook_executor = PlaybookExecutor(playbooks=[playbook_path],
- inventory=inventory,
- variable_manager=self.variable_manager,
- loader=self.loader,
- options=options,
- passwords=self.passwords)
- return self.playbook_executor.run()
-
- def get_detail_playbook_stats(self):
- if self.playbook_executor:
- stats = self.playbook_executor._tqm._stats
- return map(lambda x: (x, stats.summarize(x)), stats.processed.keys())
- else:
- return None