diff options
author | 2019-01-31 14:10:49 +0000 | |
---|---|---|
committer | 2019-01-31 14:10:49 +0000 | |
commit | 72d081256d30e5591a21298d117810062eadfd3d (patch) | |
tree | deacf1e99adc58f4c4c3427847717c3ec634e8a2 /ansible-server/src/main/ansible-server/AnsibleModule.py | |
parent | dbc7a4ded01499f590e48d565152d5dc06a2aa82 (diff) | |
parent | 1bc5690a09462237d48e5ed409e985597681898f (diff) |
Merge "reduce ccsdk-ansible-server image footprint"
Diffstat (limited to 'ansible-server/src/main/ansible-server/AnsibleModule.py')
-rwxr-xr-x | ansible-server/src/main/ansible-server/AnsibleModule.py | 135 |
1 files changed, 135 insertions, 0 deletions
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 |