ansible/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2024-09-14 20:13:21 +02:00
Code Releases Activity

Find or Create volume by name

Browse source
This commit is contained in:
Jell 2015-01-30 15:53:46 +01:00 committed by Matt Clay
parent 5336217649
commit 2e007167b9
1 changed files with 18 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

30
lib/ansible/modules/cloud/amazon/ec2_vol.py
View file

@ -143,9 +143,9 @@ EXAMPLES = '''
with_items: ec2.instances with_items: ec2.instances
register: ec2_vol register: ec2_vol
# Example: Launch an instance and then add a volume if not already present # Example: Launch an instance and then add a volume if not already attached
# * Volume will be created with the given name if not already created.
# * Nothing will happen if the volume is already attached. # * Nothing will happen if the volume is already attached.
# * Volume must exist in the same zone.
- ec2: - ec2:
keypair: "{{ keypair }}" keypair: "{{ keypair }}"
@ -215,7 +215,13 @@ def get_volume(module, ec2):
module.fail_json(msg = "%s: %s" % (e.error_code, e.error_message)) module.fail_json(msg = "%s: %s" % (e.error_code, e.error_message))
if not vols: if not vols:
module.fail_json(msg="Could not find volume in zone (if specified): %s" % name or id) if id:
msg = "Could not find the volume with id: %s" % id
if name:
msg += (" and name: %s" % name)
module.fail_json(msg=msg)
else:
return None
if len(vols) > 1: if len(vols) > 1:
module.fail_json(msg="Found more than one volume in zone (if specified) with name: %s" % name) module.fail_json(msg="Found more than one volume in zone (if specified) with name: %s" % name)
return vols[0] return vols[0]
@ -268,12 +274,8 @@ def create_volume(module, ec2, zone):
if instance == 'None' or instance == '': if instance == 'None' or instance == '':
instance = None instance = None
# If no instance supplied, try volume creation based on module parameters.
if name or id:
if iops or volume_size:
module.fail_json(msg = "Parameters are not compatible: [id or name] and [iops or volume_size]")
volume = get_volume(module, ec2) volume = get_volume(module, ec2)
if volume:
if volume.attachment_state() is not None: if volume.attachment_state() is not None:
if instance is None: if instance is None:
return volume return volume
@ -297,8 +299,12 @@ def create_volume(module, ec2, zone):
while volume.status != 'available': while volume.status != 'available':
time.sleep(3) time.sleep(3)
volume.update() volume.update()
if name:
ec2.create_tags([volume.id], {"Name": name})
except boto.exception.BotoServerError, e: except boto.exception.BotoServerError, e:
module.fail_json(msg = "%s: %s" % (e.error_code, e.error_message)) module.fail_json(msg = "%s: %s" % (e.error_code, e.error_message))
return volume return volume
@ -409,9 +415,6 @@ def main():
module.exit_json(changed=False, volumes=returned_volumes) module.exit_json(changed=False, volumes=returned_volumes)
if id and name:
module.fail_json(msg="Both id and name cannot be specified")
if encrypted and not boto_supports_volume_encryption(): if encrypted and not boto_supports_volume_encryption():
module.fail_json(msg="You must use boto >= v2.29.0 to use encrypted volumes") module.fail_json(msg="You must use boto >= v2.29.0 to use encrypted volumes")
@ -437,9 +440,8 @@ def main():
if not volume_size and not (id or name): if not volume_size and not (id or name):
module.fail_json(msg="You must specify an existing volume with id or name or a volume_size") module.fail_json(msg="You must specify an existing volume with id or name or a volume_size")
if volume_size and (id or name): if volume_size and id:
module.fail_json(msg="Cannot specify volume_size and either one of name or id") module.fail_json(msg="Cannot specify volume_size and id")
if state == 'absent': if state == 'absent':
delete_volume(module, ec2) delete_volume(module, ec2)