1 files changed, 58 insertions, 0 deletions
diff --git a/qtip/driver/ansible_api.py b/qtip/driver/ansible_api.py
new file mode 100644
index 00000000..5c5baffc
--- /dev/null
+++ b/qtip/driver/ansible_api.py
@@ -0,0 +1,58 @@
+##############################################################################
+# 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