Merge pull request #2830 from ralph-tice/devel
amended s3 plugin to support 'dest' parameter
This commit is contained in:
commit
8849be6695
1 changed files with 15 additions and 4 deletions
|
@ -39,6 +39,12 @@ options:
|
||||||
required: false
|
required: false
|
||||||
default: null
|
default: null
|
||||||
aliases: []
|
aliases: []
|
||||||
|
dest:
|
||||||
|
description:
|
||||||
|
- the destination in s3, if different from path
|
||||||
|
required: false
|
||||||
|
default: null
|
||||||
|
aliases: []
|
||||||
expiry:
|
expiry:
|
||||||
description:
|
description:
|
||||||
- expiry period (in seconds) for returned download URL.
|
- expiry period (in seconds) for returned download URL.
|
||||||
|
@ -52,7 +58,7 @@ options:
|
||||||
default: false
|
default: false
|
||||||
version_added: "1.2"
|
version_added: "1.2"
|
||||||
requirements: [ "boto" ]
|
requirements: [ "boto" ]
|
||||||
author: Lester Wade
|
author: Lester Wade, Ralph Tice
|
||||||
'''
|
'''
|
||||||
|
|
||||||
EXAMPLES = '''
|
EXAMPLES = '''
|
||||||
|
@ -95,6 +101,7 @@ def main():
|
||||||
argument_spec = dict(
|
argument_spec = dict(
|
||||||
bucket = dict(),
|
bucket = dict(),
|
||||||
path = dict(),
|
path = dict(),
|
||||||
|
dest = dict(),
|
||||||
state = dict(choices=['present', 'absent']),
|
state = dict(choices=['present', 'absent']),
|
||||||
expiry = dict(default=600),
|
expiry = dict(default=600),
|
||||||
s3_url = dict(aliases=['S3_URL']),
|
s3_url = dict(aliases=['S3_URL']),
|
||||||
|
@ -107,6 +114,7 @@ def main():
|
||||||
|
|
||||||
bucket_name = module.params.get('bucket')
|
bucket_name = module.params.get('bucket')
|
||||||
path = os.path.expanduser(module.params['path'])
|
path = os.path.expanduser(module.params['path'])
|
||||||
|
dest = module.params.get('dest')
|
||||||
state = module.params.get('state')
|
state = module.params.get('state')
|
||||||
expiry = int(module.params['expiry'])
|
expiry = int(module.params['expiry'])
|
||||||
s3_url = module.params.get('s3_url')
|
s3_url = module.params.get('s3_url')
|
||||||
|
@ -159,9 +167,12 @@ def main():
|
||||||
module.fail_json(msg="Source %s cannot be found" % (path), failed=failed)
|
module.fail_json(msg="Source %s cannot be found" % (path), failed=failed)
|
||||||
sys.exit(0)
|
sys.exit(0)
|
||||||
|
|
||||||
# Default to setting the key to the same as the filename if not downloading. Adding custom key would be trivial.
|
# Default to setting the key to the same as the filename if dest is not provided.
|
||||||
key_name = os.path.basename(path)
|
if dest is None:
|
||||||
|
key_name = os.path.basename(path)
|
||||||
|
else:
|
||||||
|
key_name = dest
|
||||||
|
|
||||||
# Check to see if the key already exists
|
# Check to see if the key already exists
|
||||||
if bucket_exists is True:
|
if bucket_exists is True:
|
||||||
try:
|
try:
|
||||||
|
|
Loading…
Reference in a new issue