X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=ansible-server%2Fsrc%2Fmain%2Fansible-server%2FAnsibleModule.py;fp=ansible-server%2Fsrc%2Fmain%2Fansible-server%2FAnsibleModule.py;h=2da7912929a310d458182a01bf446779a2054bb2;hb=1bc5690a09462237d48e5ed409e985597681898f;hp=0000000000000000000000000000000000000000;hpb=dc4950ba68c4c6dadd530f7f808bbb4c9458571d;p=ccsdk%2Fdistribution.git

diff --git a/ansible-server/src/main/ansible-server/AnsibleModule.py b/ansible-server/src/main/ansible-server/AnsibleModule.py
new file mode 100755
index 00000000..2da79129
--- /dev/null
+++ b/ansible-server/src/main/ansible-server/AnsibleModule.py
@@ -0,0 +1,135 @@
+'''
+/*-
+* ============LICENSE_START=======================================================
+* ONAP : APPC
+* ================================================================================
+* Copyright (C) 2019 AT&T Intellectual Property.  All rights reserved.
+* ================================================================================
+* Copyright (C) 2019 Amdocs
+* =============================================================================
+* Licensed under the Apache License, Version 2.0 (the "License");
+* you may not use this file except in compliance with the License.
+* You may obtain a copy of the License at
+*
+*      http://www.apache.org/licenses/LICENSE-2.0
+*
+* Unless required by applicable law or agreed to in writing, software
+* distributed under the License is distributed on an "AS IS" BASIS,
+* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+* See the License for the specific language governing permissions and
+* limitations under the License.
+*
+* ECOMP is a trademark and service mark of AT&T Intellectual Property.
+* ============LICENSE_END=========================================================
+*/
+'''
+
+import os, subprocess
+import sys
+from collections import namedtuple
+import json
+
+import uuid
+import cherrypy
+from cherrypy.lib.httputil import parse_query_string
+from cherrypy.lib import auth_basic
+
+def ansibleSysCall (inventory_path, playbook_path, nodelist, mandatory,
+                    envparameters, localparameters, timeout, playbookdir):
+
+    cherrypy.log( "***> in AnsibleModule.ansibleSysCall")
+    log = []
+
+    str_parameters = ''
+
+    if not envparameters == '':
+        for key in envparameters:
+            if str_parameters == '':
+                str_parameters = '"'  + str(key) + '=\'' + str(envparameters[key])  + '\''
+            else:
+                #str_parameters += ' '  + str(key) + '=\'' + str(envparameters[key])  + '\''
+                str_parameters += ', '  + str(key) + '=\'' + str(envparameters[key])  + '\''
+        str_parameters += '"'
+
+    if len(str_parameters) > 0:
+        cmd = 'export HOME=/root; env; cd ' + playbookdir + ';' +'timeout -s KILL -t ' + str(timeout) + \
+              ' ansible-playbook -v --timeout ' + str(timeout) + ' --extra-vars ' + str_parameters + ' -i ' + \
+              inventory_path + ' ' + playbook_path + ' | tee log.file'
+    else:
+        cmd = 'export HOME=/root; env; cd ' + playbookdir + ';' +'timeout -s KILL -t ' + str(timeout) + \
+              ' ansible-playbook -v --timeout ' + str(timeout) + ' -i ' + inventory_path + ' ' + playbook_path +' | tee log.file'
+
+    cherrypy.log("CMD: " + cmd)
+
+    cherrypy.log("PlayBook Start: " + playbookdir )
+    p = subprocess.Popen(cmd, shell=True,
+                         stdout=subprocess.PIPE,
+                         stderr=subprocess.STDOUT)
+    #PAP
+    #p.wait()
+    (stdout_value, err) = p.communicate()
+
+    stdout_value_cleanup = ''
+    for line in stdout_value:
+        stdout_value_cleanup += line.replace('  ', ' ')
+    stdout_value = stdout_value_cleanup.splitlines()
+
+    ParseFlag = False
+    retval = {}
+    returncode = p.returncode
+
+    if returncode == 137:
+
+        cherrypy.log("   ansible-playbook system call timed out")
+        # ansible-playbook system call timed out
+        for line in stdout_value: # p.stdout.readlines():
+            log.append (line)
+
+
+    else:
+
+        for line in stdout_value: # p.stdout.readlines():
+            print line # line,
+            if ParseFlag and len(line.strip())>0:
+                ip_address = line.split(':')[0].strip()
+                ok_flag = line.split(':')[1].strip().split('=')[1].split('changed')[0].strip()
+                changed_flag = line.split(':')[1].strip().split('=')[2].split('unreachable')[0].strip()
+                unreachable_flag = line.split(':')[1].strip().split('=')[3].split('failed')[0].strip()
+                failed_flag = line.split(':')[1].strip().split('=')[4].strip()
+                retval[ip_address]=[ok_flag, changed_flag, unreachable_flag, failed_flag]
+            if "PLAY RECAP" in line:
+                ParseFlag = True
+            log.append (line)
+            if "Killed" in line: # check for timeout
+                cherrypy.log(" Playbook Killed(timeout)")
+                returncode = 137
+
+    # retval['p'] = p.wait()
+
+    #cherrypy.log("*** <" + playbookdir + "> [" + str(log) + "] ***")
+    cherrypy.log("PlayBook Complete: " + playbookdir )
+    f = open(playbookdir + "/output.log", "w")
+    f.write(str(log))
+    f.close()
+
+    return retval, log, returncode
+
+if __name__ == '__main__':
+
+    from multiprocessing import Process, Value, Array, Manager
+    import time
+
+    nodelist = 'host'
+
+    playbook_file = 'ansible_sleep@0.00.yml'
+
+
+    d = Manager().dict()
+
+    p = Process(nodelist=ansible_call, args=('ansible_module_config', playbook_file, nodelist,d, ))
+    p.start()
+
+    print "Process running"
+    print d
+    p.join()
+    print d