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

[cloud] Fix #23152 in route53 module and pep8 cleanup (#23156)

update module to support more standard state=present/absent syntax

update module to use required_if, required_together, mutually_exclusive functions where possible

per ryansb review: make documentation section more clear, fix some extra quotes, remove FIXME comment

pre willthames review: force private_zone to True if vpc_id is set and fix word wrap
This commit is contained in:
Daniel Shepherd 2017-04-18 11:49:25 -04:00 committed by Ryan Brown
parent 586fcae398
commit 698fa37a44
2 changed files with 152 additions and 150 deletions

View file

@ -27,11 +27,12 @@ short_description: add or delete entries in Amazons Route53 DNS service
description: description:
- Creates and deletes DNS records in Amazons Route53 service - Creates and deletes DNS records in Amazons Route53 service
options: options:
command: state:
description: description:
- Specifies the action to take. - Specifies the state of the resource record.
required: true required: true
choices: [ 'get', 'create', 'delete' ] aliases: [ 'command' ]
choices: [ 'present', 'absent', 'get', 'create', 'delete' ]
zone: zone:
description: description:
- The DNS zone to modify - The DNS zone to modify
@ -77,8 +78,8 @@ options:
default: false default: false
value: value:
description: description:
- The new value when creating a DNS record. Multiple comma-spaced values are allowed for non-alias records. When deleting a record all values - The new value when creating a DNS record. YAML lists or multiple comma-spaced values are allowed for non-alias records.
for the record must be specified or Route53 will not delete it. - When deleting a record all values for the record must be specified or Route53 will not delete it.
required: false required: false
default: null default: null
overwrite: overwrite:
@ -163,12 +164,11 @@ author:
extends_documentation_fragment: aws extends_documentation_fragment: aws
''' '''
# FIXME: the command stuff should have a more state like configuration alias -- MPD
EXAMPLES = ''' EXAMPLES = '''
# Add new.foo.com as an A record with 3 IPs and wait until the changes have been replicated # Add new.foo.com as an A record with 3 IPs and wait until the changes have been replicated
- route53: - route53:
command: create state: present
zone: foo.com zone: foo.com
record: new.foo.com record: new.foo.com
type: A type: A
@ -176,9 +176,22 @@ EXAMPLES = '''
value: 1.1.1.1,2.2.2.2,3.3.3.3 value: 1.1.1.1,2.2.2.2,3.3.3.3
wait: yes wait: yes
# Update new.foo.com as an A record with a list of 3 IPs and wait until the changes have been replicated
- route53:
state: present
zone: foo.com
record: new.foo.com
type: A
ttl: 7200
value:
- 1.1.1.1
- 2.2.2.2
- 3.3.3.3
wait: yes
# Retrieve the details for new.foo.com # Retrieve the details for new.foo.com
- route53: - route53:
command: get state: get
zone: foo.com zone: foo.com
record: new.foo.com record: new.foo.com
type: A type: A
@ -186,7 +199,7 @@ EXAMPLES = '''
# Delete new.foo.com A record using the results from the get command # Delete new.foo.com A record using the results from the get command
- route53: - route53:
command: delete state: absent
zone: foo.com zone: foo.com
record: "{{ rec.set.record }}" record: "{{ rec.set.record }}"
ttl: "{{ rec.set.ttl }}" ttl: "{{ rec.set.ttl }}"
@ -194,48 +207,48 @@ EXAMPLES = '''
value: "{{ rec.set.value }}" value: "{{ rec.set.value }}"
# Add an AAAA record. Note that because there are colons in the value # Add an AAAA record. Note that because there are colons in the value
# that the entire parameter list must be quoted: # that the IPv6 address must be quoted. Also shows using the old form command=create.
- route53: - route53:
command: "create" command: create
zone: "foo.com" zone: foo.com
record: "localhost.foo.com" record: localhost.foo.com
type: "AAAA" type: AAAA
ttl: "7200" ttl: 7200
value: "::1" value: "::1"
# Add a SRV record with multiple fields for a service on port 22222 # Add a SRV record with multiple fields for a service on port 22222
# For more information on SRV records see: # For more information on SRV records see:
# https://en.wikipedia.org/wiki/SRV_record # https://en.wikipedia.org/wiki/SRV_record
- route53: - route53:
command: "create" state: present
"zone": "foo.com" zone: foo.com
"record": "_example-service._tcp.foo.com" record: "_example-service._tcp.foo.com"
"type": "SRV" type: SRV
"value": "0 0 22222 host1.foo.com,0 0 22222 host2.foo.com" value: "0 0 22222 host1.foo.com,0 0 22222 host2.foo.com"
# Add a TXT record. Note that TXT and SPF records must be surrounded # Add a TXT record. Note that TXT and SPF records must be surrounded
# by quotes when sent to Route 53: # by quotes when sent to Route 53:
- route53: - route53:
command: "create" state: present
zone: "foo.com" zone: foo.com
record: "localhost.foo.com" record: localhost.foo.com
type: "TXT" type: TXT
ttl: "7200" ttl: 7200
value: '"bar"' value: '"bar"'
# Add an alias record that points to an Amazon ELB: # Add an alias record that points to an Amazon ELB:
- route53: - route53:
command: create state: present
zone: foo.com zone: foo.com
record: elb.foo.com record: elb.foo.com
type: A type: A
value: "{{ elb_dns_name }}" value: "{{ elb_dns_name }}"
alias: True alias: True
alias_hosted_zone_id: "{{ elb_zone_id }}" alias_hosted_zone_id: "{{ elb_zone_id }}"
# Retrieve the details for elb.foo.com # Retrieve the details for elb.foo.com
- route53: - route53:
command: get state: get
zone: foo.com zone: foo.com
record: elb.foo.com record: elb.foo.com
type: A type: A
@ -243,7 +256,7 @@ EXAMPLES = '''
# Delete an alias record using the results from the get command # Delete an alias record using the results from the get command
- route53: - route53:
command: delete state: absent
zone: foo.com zone: foo.com
record: "{{ rec.set.record }}" record: "{{ rec.set.record }}"
ttl: "{{ rec.set.ttl }}" ttl: "{{ rec.set.ttl }}"
@ -254,7 +267,7 @@ EXAMPLES = '''
# Add an alias record that points to an Amazon ELB and evaluates it health: # Add an alias record that points to an Amazon ELB and evaluates it health:
- route53: - route53:
command: create state: present
zone: foo.com zone: foo.com
record: elb.foo.com record: elb.foo.com
type: A type: A
@ -263,35 +276,23 @@ EXAMPLES = '''
alias_hosted_zone_id: "{{ elb_zone_id }}" alias_hosted_zone_id: "{{ elb_zone_id }}"
alias_evaluate_target_health: True alias_evaluate_target_health: True
# Add an AAAA record with Hosted Zone ID. Note that because there are colons in the value # Add an AAAA record with Hosted Zone ID.
# that the entire parameter list must be quoted:
- route53: - route53:
command: "create" state: present
zone: "foo.com" zone: foo.com
hosted_zone_id: "Z2AABBCCDDEEFF" hosted_zone_id: Z2AABBCCDDEEFF
record: "localhost.foo.com" record: localhost.foo.com
type: "AAAA" type: AAAA
ttl: "7200" ttl: 7200
value: "::1"
# Add an AAAA record with Hosted Zone ID. Note that because there are colons in the value
# that the entire parameter list must be quoted:
- route53:
command: "create"
zone: "foo.com"
hosted_zone_id: "Z2AABBCCDDEEFF"
record: "localhost.foo.com"
type: "AAAA"
ttl: "7200"
value: "::1" value: "::1"
# Use a routing policy to distribute traffic: # Use a routing policy to distribute traffic:
- route53: - route53:
command: "create" state: present
zone: "foo.com" zone: foo.com
record: "www.foo.com" record: www.foo.com
type: "CNAME" type: CNAME
value: "host1.foo.com" value: host1.foo.com
ttl: 30 ttl: 30
# Routing policy # Routing policy
identifier: "host1@www" identifier: "host1@www"
@ -307,6 +308,10 @@ WAIT_RETRY_SLEEP = 5 # how many seconds to wait between propagation status poll
import time import time
import distutils.version import distutils.version
# import module snippets
from ansible.module_utils.basic import AnsibleModule
from ansible.module_utils.ec2 import ec2_argument_spec, get_aws_connection_info
try: try:
import boto import boto
import boto.ec2 import boto.ec2
@ -339,7 +344,7 @@ def get_zone_by_name(conn, module, zone_name, want_private, zone_id, want_vpc_id
if isinstance(zone_details['VPCs'], dict): if isinstance(zone_details['VPCs'], dict):
if zone_details['VPCs']['VPC']['VPCId'] == want_vpc_id: if zone_details['VPCs']['VPC']['VPCId'] == want_vpc_id:
return zone return zone
else: # Forward compatibility for when boto fixes that bug else: # Forward compatibility for when boto fixes that bug
if want_vpc_id in [v['VPCId'] for v in zone_details['VPCs']]: if want_vpc_id in [v['VPCId'] for v in zone_details['VPCs']]:
return zone return zone
else: else:
@ -377,46 +382,60 @@ def commit(changes, retry_interval, wait, wait_timeout):
# Shamelessly copied over from https://git.io/vgmDG # Shamelessly copied over from https://git.io/vgmDG
IGNORE_CODE = 'Throttling' IGNORE_CODE = 'Throttling'
MAX_RETRIES=5 MAX_RETRIES = 5
def invoke_with_throttling_retries(function_ref, *argv, **kwargs): def invoke_with_throttling_retries(function_ref, *argv, **kwargs):
retries=0 retries = 0
while True: while True:
try: try:
retval=function_ref(*argv, **kwargs) retval = function_ref(*argv, **kwargs)
return retval return retval
except boto.exception.BotoServerError as e: except boto.exception.BotoServerError as e:
if e.code != IGNORE_CODE or retries==MAX_RETRIES: if e.code != IGNORE_CODE or retries == MAX_RETRIES:
raise e raise e
time.sleep(5 * (2**retries)) time.sleep(5 * (2**retries))
retries += 1 retries += 1
def main(): def main():
argument_spec = ec2_argument_spec() argument_spec = ec2_argument_spec()
argument_spec.update(dict( argument_spec.update(dict(
command = dict(choices=['get', 'create', 'delete'], required=True), state=dict(aliases=['command'], choices=['present', 'absent', 'get', 'create', 'delete'], required=True),
zone = dict(required=True), zone=dict(required=True),
hosted_zone_id = dict(required=False, default=None), hosted_zone_id=dict(required=False, default=None),
record = dict(required=True), record=dict(required=True),
ttl = dict(required=False, type='int', default=3600), ttl=dict(required=False, type='int', default=3600),
type = dict(choices=['A', 'CNAME', 'MX', 'AAAA', 'TXT', 'PTR', 'SRV', 'SPF', 'NS', 'SOA'], required=True), type=dict(choices=['A', 'CNAME', 'MX', 'AAAA', 'TXT', 'PTR', 'SRV', 'SPF', 'NS', 'SOA'], required=True),
alias = dict(required=False, type='bool'), alias=dict(required=False, type='bool'),
alias_hosted_zone_id = dict(required=False), alias_hosted_zone_id=dict(required=False),
alias_evaluate_target_health = dict(required=False, type='bool', default=False), alias_evaluate_target_health=dict(required=False, type='bool', default=False),
value = dict(required=False), value=dict(required=False, type='list'),
overwrite = dict(required=False, type='bool'), overwrite=dict(required=False, type='bool'),
retry_interval = dict(required=False, default=500), retry_interval=dict(required=False, default=500),
private_zone = dict(required=False, type='bool', default=False), private_zone=dict(required=False, type='bool', default=False),
identifier = dict(required=False, default=None), identifier=dict(required=False, default=None),
weight = dict(required=False, type='int'), weight=dict(required=False, type='int'),
region = dict(required=False), region=dict(required=False),
health_check = dict(required=False), health_check=dict(required=False),
failover = dict(required=False,choices=['PRIMARY','SECONDARY']), failover=dict(required=False, choices=['PRIMARY', 'SECONDARY']),
vpc_id = dict(required=False), vpc_id=dict(required=False),
wait = dict(required=False, type='bool', default=False), wait=dict(required=False, type='bool', default=False),
wait_timeout = dict(required=False, type='int', default=300), wait_timeout=dict(required=False, type='int', default=300),
) ))
)
module = AnsibleModule(argument_spec=argument_spec) # state=present, absent, create, delete THEN value is required
required_if = [('state', 'present', ['value']), ('state', 'create', ['value'])]
required_if.extend([('state', 'absent', ['value']), ('state', 'delete', ['value'])])
# If alias is True then you must specify alias_hosted_zone as well
required_together = [['alias', 'alias_hosted_zone_id']]
# failover, region, and weight are mutually exclusive
mutually_exclusive = [('failover', 'region', 'weight')]
module = AnsibleModule(argument_spec=argument_spec, required_together=required_together, required_if=required_if,
mutually_exclusive=mutually_exclusive)
if not HAS_BOTO: if not HAS_BOTO:
module.fail_json(msg='boto required for this module') module.fail_json(msg='boto required for this module')
@ -424,37 +443,40 @@ def main():
if distutils.version.StrictVersion(boto.__version__) < distutils.version.StrictVersion(MINIMUM_BOTO_VERSION): if distutils.version.StrictVersion(boto.__version__) < distutils.version.StrictVersion(MINIMUM_BOTO_VERSION):
module.fail_json(msg='Found boto in version %s, but >= %s is required' % (boto.__version__, MINIMUM_BOTO_VERSION)) module.fail_json(msg='Found boto in version %s, but >= %s is required' % (boto.__version__, MINIMUM_BOTO_VERSION))
command_in = module.params.get('command') if module.params['state'] in ('present', 'create'):
zone_in = module.params.get('zone').lower() command_in = 'create'
hosted_zone_id_in = module.params.get('hosted_zone_id') elif module.params['state'] in ('absent', 'delete'):
ttl_in = module.params.get('ttl') command_in = 'delete'
record_in = module.params.get('record').lower() elif module.params['state'] == 'get':
type_in = module.params.get('type') command_in = 'get'
value_in = module.params.get('value')
alias_in = module.params.get('alias') zone_in = module.params.get('zone').lower()
alias_hosted_zone_id_in = module.params.get('alias_hosted_zone_id') hosted_zone_id_in = module.params.get('hosted_zone_id')
ttl_in = module.params.get('ttl')
record_in = module.params.get('record').lower()
type_in = module.params.get('type')
value_in = module.params.get('value')
alias_in = module.params.get('alias')
alias_hosted_zone_id_in = module.params.get('alias_hosted_zone_id')
alias_evaluate_target_health_in = module.params.get('alias_evaluate_target_health') alias_evaluate_target_health_in = module.params.get('alias_evaluate_target_health')
retry_interval_in = module.params.get('retry_interval') retry_interval_in = module.params.get('retry_interval')
private_zone_in = module.params.get('private_zone')
identifier_in = module.params.get('identifier') if module.params['vpc_id'] is not None:
weight_in = module.params.get('weight') private_zone_in = True
region_in = module.params.get('region') else:
health_check_in = module.params.get('health_check') private_zone_in = module.params.get('private_zone')
failover_in = module.params.get('failover')
vpc_id_in = module.params.get('vpc_id') identifier_in = module.params.get('identifier')
wait_in = module.params.get('wait') weight_in = module.params.get('weight')
wait_timeout_in = module.params.get('wait_timeout') region_in = module.params.get('region')
health_check_in = module.params.get('health_check')
failover_in = module.params.get('failover')
vpc_id_in = module.params.get('vpc_id')
wait_in = module.params.get('wait')
wait_timeout_in = module.params.get('wait_timeout')
region, ec2_url, aws_connect_kwargs = get_aws_connection_info(module) region, ec2_url, aws_connect_kwargs = get_aws_connection_info(module)
value_list = ()
if isinstance(value_in, str):
if value_in:
value_list = sorted([s.strip() for s in value_in.split(',')])
elif isinstance(value_in, list):
value_list = sorted(value_in)
if zone_in[-1:] != '.': if zone_in[-1:] != '.':
zone_in += "." zone_in += "."
@ -462,34 +484,18 @@ def main():
record_in += "." record_in += "."
if command_in == 'create' or command_in == 'delete': if command_in == 'create' or command_in == 'delete':
if not value_in: if alias_in and len(value_in) != 1:
module.fail_json(msg = "parameter 'value' required for create/delete") module.fail_json(msg="parameter 'value' must contain a single dns name for alias records")
elif alias_in: if (weight_in is not None or region_in is not None or failover_in is not None) and identifier_in is None:
if len(value_list) != 1: module.fail_json(msg="If you specify failover, region or weight you must also specify identifier")
module.fail_json(msg = "parameter 'value' must contain a single dns name for alias create/delete") if (weight_in is None and region_in is None and failover_in is None) and identifier_in is not None:
elif not alias_hosted_zone_id_in: module.fail_json(msg="You have specified identifier which makes sense only if you specify one of: weight, region or failover.")
module.fail_json(msg = "parameter 'alias_hosted_zone_id' required for alias create/delete")
elif ( weight_in is not None or region_in is not None or failover_in is not None ) and identifier_in is None:
module.fail_json(msg= "If you specify failover, region or weight you must also specify identifier")
if command_in == 'create':
if ( weight_in is not None or region_in is not None or failover_in is not None ) and identifier_in is None:
module.fail_json(msg= "If you specify failover, region or weight you must also specify identifier")
elif ( weight_in is None and region_in is None and failover_in is None ) and identifier_in is not None:
module.fail_json(msg= "You have specified identifier which makes sense only if you specify one of: weight, region or failover.")
if vpc_id_in and not private_zone_in:
module.fail_json(msg="parameter 'private_zone' must be true when specifying parameter"
" 'vpc_id'")
# connect to the route53 endpoint # connect to the route53 endpoint
try: try:
conn = Route53Connection(**aws_connect_kwargs) conn = Route53Connection(**aws_connect_kwargs)
except boto.exception.BotoServerError as e: except boto.exception.BotoServerError as e:
module.fail_json(msg = e.error_message) module.fail_json(msg=e.error_message)
# Find the named zone ID # Find the named zone ID
zone = get_zone_by_name(conn, module, zone_in, private_zone_in, hosted_zone_id_in, vpc_id_in) zone = get_zone_by_name(conn, module, zone_in, private_zone_in, hosted_zone_id_in, vpc_id_in)
@ -497,15 +503,16 @@ def main():
# Verify that the requested zone is already defined in Route53 # Verify that the requested zone is already defined in Route53
if zone is None: if zone is None:
errmsg = "Zone %s does not exist in Route53" % zone_in errmsg = "Zone %s does not exist in Route53" % zone_in
module.fail_json(msg = errmsg) module.fail_json(msg=errmsg)
record = {} record = {}
found_record = False found_record = False
wanted_rset = Record(name=record_in, type=type_in, ttl=ttl_in, wanted_rset = Record(name=record_in, type=type_in, ttl=ttl_in,
identifier=identifier_in, weight=weight_in, region=region_in, identifier=identifier_in, weight=weight_in,
health_check=health_check_in, failover=failover_in) region=region_in, health_check=health_check_in,
for v in value_list: failover=failover_in)
for v in value_in:
if alias_in: if alias_in:
wanted_rset.set_alias(alias_hosted_zone_id_in, v, alias_evaluate_target_health_in) wanted_rset.set_alias(alias_hosted_zone_id_in, v, alias_evaluate_target_health_in)
else: else:
@ -518,7 +525,7 @@ def main():
# tripping of things like * and @. # tripping of things like * and @.
decoded_name = rset.name.replace(r'\052', '*') decoded_name = rset.name.replace(r'\052', '*')
decoded_name = decoded_name.replace(r'\100', '@') decoded_name = decoded_name.replace(r'\100', '@')
#Need to save this changes in rset, because of comparing rset.to_xml() == wanted_rset.to_xml() in next block # Need to save this changes in rset, because of comparing rset.to_xml() == wanted_rset.to_xml() in next block
rset.name = decoded_name rset.name = decoded_name
if identifier_in is not None: if identifier_in is not None:
@ -573,7 +580,7 @@ def main():
if command_in == 'create' or command_in == 'delete': if command_in == 'create' or command_in == 'delete':
if command_in == 'create' and found_record: if command_in == 'create' and found_record:
if not module.params['overwrite']: if not module.params['overwrite']:
module.fail_json(msg = "Record already exists with different value. Set 'overwrite' to replace it") module.fail_json(msg="Record already exists with different value. Set 'overwrite' to replace it")
command = 'UPSERT' command = 'UPSERT'
else: else:
command = command_in.upper() command = command_in.upper()
@ -587,15 +594,11 @@ def main():
if "but it already exists" in txt: if "but it already exists" in txt:
module.exit_json(changed=False) module.exit_json(changed=False)
else: else:
module.fail_json(msg = txt) module.fail_json(msg=txt)
except TimeoutError: except TimeoutError:
module.fail_json(msg='Timeout waiting for changes to replicate') module.fail_json(msg='Timeout waiting for changes to replicate')
module.exit_json(changed=True) module.exit_json(changed=True)
# import module snippets
from ansible.module_utils.basic import *
from ansible.module_utils.ec2 import *
if __name__ == '__main__': if __name__ == '__main__':
main() main()

View file

@ -207,7 +207,6 @@ lib/ansible/modules/cloud/amazon/rds.py
lib/ansible/modules/cloud/amazon/rds_param_group.py lib/ansible/modules/cloud/amazon/rds_param_group.py
lib/ansible/modules/cloud/amazon/rds_subnet_group.py lib/ansible/modules/cloud/amazon/rds_subnet_group.py
lib/ansible/modules/cloud/amazon/redshift.py lib/ansible/modules/cloud/amazon/redshift.py
lib/ansible/modules/cloud/amazon/route53.py
lib/ansible/modules/cloud/amazon/route53_facts.py lib/ansible/modules/cloud/amazon/route53_facts.py
lib/ansible/modules/cloud/amazon/route53_health_check.py lib/ansible/modules/cloud/amazon/route53_health_check.py
lib/ansible/modules/cloud/amazon/s3.py lib/ansible/modules/cloud/amazon/s3.py