mirror of
https://github.com/ansible-collections/community.general.git
synced 2024-09-14 20:13:21 +02:00
Add debug usage to comments in the ziploader wrapper and don't strip comments if ANSIBLE_KEEP_REMOTE_FILES=1
This commit is contained in:
parent
44e21f7062
commit
e9553c975f
1 changed files with 54 additions and 20 deletions
|
@ -134,12 +134,36 @@ def invoke_module(module, modlib_path, json_params):
|
||||||
|
|
||||||
def debug(command, zipped_mod, json_params):
|
def debug(command, zipped_mod, json_params):
|
||||||
# The code here normally doesn't run. It's only used for debugging on the
|
# The code here normally doesn't run. It's only used for debugging on the
|
||||||
# remote machine. Run with ANSIBLE_KEEP_REMOTE_FILES=1 envvar and -vvv
|
# remote machine.
|
||||||
# to save the module file remotely. Login to the remote machine and use
|
#
|
||||||
# /path/to/module explode to extract the ZIPDATA payload into source
|
# The subcommands in this function make it easier to debug ziploader
|
||||||
# files. Edit the source files to instrument the code or experiment with
|
# modules. Here's the basic steps:
|
||||||
# different values. Then use /path/to/module execute to run the extracted
|
#
|
||||||
# files you've edited instead of the actual zipped module.
|
# Run ansible with the environment variable: ANSIBLE_KEEP_REMOTE_FILES=1 and -vvv
|
||||||
|
# to save the module file remotely::
|
||||||
|
# $ ANSIBLE_KEEP_REMOTE_FILES=1 ansible host1 -m ping -a 'data=october' -vvv
|
||||||
|
#
|
||||||
|
# Part of the verbose output will tell you where on the remote machine the
|
||||||
|
# module was written to::
|
||||||
|
# [...]
|
||||||
|
# <host1> SSH: EXEC ssh -C -q -o ControlMaster=auto -o ControlPersist=60s -o KbdInteractiveAuthentication=no -o
|
||||||
|
# PreferredAuthentications=gssapi-with-mic,gssapi-keyex,hostbased,publickey -o PasswordAuthentication=no -o ConnectTimeout=10 -o
|
||||||
|
# ControlPath=/home/badger/.ansible/cp/ansible-ssh-%%h-%%p-%%r -tt rhel7 '/bin/sh -c '"'"'LANG=en_US.UTF-8 LC_ALL=en_US.UTF-8
|
||||||
|
# LC_MESSAGES=en_US.UTF-8 /usr/bin/python /home/badger/.ansible/tmp/ansible-tmp-1461173013.93-9076457629738/ping'"'"''
|
||||||
|
# [...]
|
||||||
|
#
|
||||||
|
# Login to the remote machine and run the module file via from the previous
|
||||||
|
# step with the explode subcommand to extract the module payload into
|
||||||
|
# source files::
|
||||||
|
# $ ssh host1
|
||||||
|
# $ /usr/bin/python /home/badger/.ansible/tmp/ansible-tmp-1461173013.93-9076457629738/ping explode
|
||||||
|
# Module expanded into:
|
||||||
|
# /home/badger/.ansible/tmp/ansible-tmp-1461173408.08-279692652635227/ansible
|
||||||
|
#
|
||||||
|
# You can now edit the source files to instrument the code or experiment with
|
||||||
|
# different parameter values. When you're ready to run the code you've modified
|
||||||
|
# (instead of the code from the actual zipped module), use the execute subcommand like this::
|
||||||
|
# $ /usr/bin/python /home/badger/.ansible/tmp/ansible-tmp-1461173013.93-9076457629738/ping execute
|
||||||
|
|
||||||
# Okay to use __file__ here because we're running from a kept file
|
# Okay to use __file__ here because we're running from a kept file
|
||||||
basedir = os.path.abspath(os.path.dirname(__file__))
|
basedir = os.path.abspath(os.path.dirname(__file__))
|
||||||
|
@ -225,6 +249,10 @@ def debug(command, zipped_mod, json_params):
|
||||||
return exitcode
|
return exitcode
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
|
#
|
||||||
|
# See comments in the debug() method for information on debugging
|
||||||
|
#
|
||||||
|
|
||||||
ZIPLOADER_PARAMS = %(params)s
|
ZIPLOADER_PARAMS = %(params)s
|
||||||
if PY3:
|
if PY3:
|
||||||
ZIPLOADER_PARAMS = ZIPLOADER_PARAMS.encode('utf-8')
|
ZIPLOADER_PARAMS = ZIPLOADER_PARAMS.encode('utf-8')
|
||||||
|
@ -252,6 +280,24 @@ if __name__ == '__main__':
|
||||||
sys.exit(exitcode)
|
sys.exit(exitcode)
|
||||||
'''
|
'''
|
||||||
|
|
||||||
|
def _strip_comments(source):
|
||||||
|
# Strip comments and blank lines from the wrapper
|
||||||
|
buf = []
|
||||||
|
for line in source.splitlines():
|
||||||
|
l = line.strip()
|
||||||
|
if not l or l.startswith(u'#'):
|
||||||
|
continue
|
||||||
|
buf.append(line)
|
||||||
|
return u'\n'.join(buf)
|
||||||
|
|
||||||
|
if C.DEFAULT_KEEP_REMOTE_FILES:
|
||||||
|
# Keep comments when KEEP_REMOTE_FILES is set. That way users will see
|
||||||
|
# the comments with some nice usage instructions
|
||||||
|
ACTIVE_ZIPLOADER_TEMPLATE = ZIPLOADER_TEMPLATE
|
||||||
|
else:
|
||||||
|
# ZIPLOADER_TEMPLATE stripped of comments for smaller over the wire size
|
||||||
|
ACTIVE_ZIPLOADER_TEMPLATE = _strip_comments(ZIPLOADER_TEMPLATE)
|
||||||
|
|
||||||
class ModuleDepFinder(ast.NodeVisitor):
|
class ModuleDepFinder(ast.NodeVisitor):
|
||||||
# Caveats:
|
# Caveats:
|
||||||
# This code currently does not handle:
|
# This code currently does not handle:
|
||||||
|
@ -301,19 +347,6 @@ class ModuleDepFinder(ast.NodeVisitor):
|
||||||
self.generic_visit(node)
|
self.generic_visit(node)
|
||||||
|
|
||||||
|
|
||||||
def _strip_comments(source):
|
|
||||||
# Strip comments and blank lines from the wrapper
|
|
||||||
buf = []
|
|
||||||
for line in source.splitlines():
|
|
||||||
l = line.strip()
|
|
||||||
if not l or l.startswith(u'#'):
|
|
||||||
continue
|
|
||||||
buf.append(line)
|
|
||||||
return u'\n'.join(buf)
|
|
||||||
|
|
||||||
# ZIPLOADER_TEMPLATE stripped of comments for smaller over the wire size
|
|
||||||
STRIPPED_ZIPLOADER_TEMPLATE = _strip_comments(ZIPLOADER_TEMPLATE)
|
|
||||||
|
|
||||||
def _slurp(path):
|
def _slurp(path):
|
||||||
if not os.path.exists(path):
|
if not os.path.exists(path):
|
||||||
raise AnsibleError("imported module support code does not exist at %s" % os.path.abspath(path))
|
raise AnsibleError("imported module support code does not exist at %s" % os.path.abspath(path))
|
||||||
|
@ -555,10 +588,11 @@ def _find_snippet_imports(module_name, module_data, module_path, module_args, ta
|
||||||
raise AnsibleError('A different worker process failed to create module file. Look at traceback for that process for debugging information.')
|
raise AnsibleError('A different worker process failed to create module file. Look at traceback for that process for debugging information.')
|
||||||
# Fool the check later... I think we should just remove the check
|
# Fool the check later... I think we should just remove the check
|
||||||
py_module_names.add(('basic',))
|
py_module_names.add(('basic',))
|
||||||
|
|
||||||
shebang, interpreter = _get_shebang(u'/usr/bin/python', task_vars)
|
shebang, interpreter = _get_shebang(u'/usr/bin/python', task_vars)
|
||||||
if shebang is None:
|
if shebang is None:
|
||||||
shebang = u'#!/usr/bin/python'
|
shebang = u'#!/usr/bin/python'
|
||||||
output.write(to_bytes(STRIPPED_ZIPLOADER_TEMPLATE % dict(
|
output.write(to_bytes(ACTIVE_ZIPLOADER_TEMPLATE % dict(
|
||||||
zipdata=zipdata,
|
zipdata=zipdata,
|
||||||
ansible_module=module_name,
|
ansible_module=module_name,
|
||||||
params=python_repred_params,
|
params=python_repred_params,
|
||||||
|
|
Loading…
Reference in a new issue