1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
'''
/*-
* ============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.
*
* ============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 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 = '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 = '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)
|
