Add evaluate taget health for alias based records
This commit is contained in:
Mike Buzzetti
parent
2dba0d8d3a
commit
b00e1b556c
1 changed files with 60 additions and 38 deletions
|
|
@ -64,6 +64,12 @@ options:
|
||||||
required: false
|
required: false
|
||||||
version_added: "1.9"
|
version_added: "1.9"
|
||||||
default: null
|
default: null
|
||||||
|
alias_evaluate_target_health:
|
||||||
|
description:
|
||||||
|
- Whether or not to evaluate an alias target health. Useful for aliases to Elastic Load Balancers.
|
||||||
|
required: false
|
||||||
|
version_added: "2.0"
|
||||||
|
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 for the record must be specified or Route53 will not delete it.
|
- The new value when creating a DNS record. Multiple comma-spaced values are allowed for non-alias records. When deleting a record all values for the record must be specified or Route53 will not delete it.
|
||||||
|
|
@ -131,7 +137,9 @@ options:
|
||||||
required: false
|
required: false
|
||||||
default: null
|
default: null
|
||||||
version_added: "2.0"
|
version_added: "2.0"
|
||||||
author: "Bruce Pennypacker (@bpennypacker)"
|
author:
|
||||||
|
- "Bruce Pennypacker (@bpennypacker)"
|
||||||
|
- "Mike Buzzetti <mike.buzzetti@gmail.com>"
|
||||||
extends_documentation_fragment: aws
|
extends_documentation_fragment: aws
|
||||||
'''
|
'''
|
||||||
|
|
||||||
|
|
@ -194,6 +202,17 @@ EXAMPLES = '''
|
||||||
alias=True
|
alias=True
|
||||||
alias_hosted_zone_id="{{ elb_zone_id }}"
|
alias_hosted_zone_id="{{ elb_zone_id }}"
|
||||||
|
|
||||||
|
# Add an alias record that points to an Amazon ELB and evaluates it health:
|
||||||
|
- route53:
|
||||||
|
command=create
|
||||||
|
zone=foo.com
|
||||||
|
record=elb.foo.com
|
||||||
|
type=A
|
||||||
|
value="{{ elb_dns_name }}"
|
||||||
|
alias=True
|
||||||
|
alias_hosted_zone_id="{{ elb_zone_id }}"
|
||||||
|
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. Note that because there are colons in the value
|
||||||
# that the entire parameter list must be quoted:
|
# that the entire parameter list must be quoted:
|
||||||
- route53:
|
- route53:
|
||||||
|
|
@ -283,24 +302,25 @@ def commit(changes, retry_interval):
|
||||||
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),
|
command = dict(choices=['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'], required=True),
|
type = dict(choices=['A', 'CNAME', 'MX', 'AAAA', 'TXT', 'PTR', 'SRV', 'SPF', 'NS'], 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),
|
||||||
value = dict(required=False),
|
alias_evaluate_target_health = dict(required=False, type='bool', default=False),
|
||||||
overwrite = dict(required=False, type='bool'),
|
value = dict(required=False),
|
||||||
retry_interval = dict(required=False, default=500),
|
overwrite = dict(required=False, type='bool'),
|
||||||
private_zone = dict(required=False, type='bool', default=False),
|
retry_interval = dict(required=False, default=500),
|
||||||
identifier = dict(required=False, default=None),
|
private_zone = dict(required=False, type='bool', default=False),
|
||||||
weight = dict(required=False, type='int'),
|
identifier = dict(required=False, default=None),
|
||||||
region = dict(required=False),
|
weight = dict(required=False, type='int'),
|
||||||
health_check = dict(required=False),
|
region = dict(required=False),
|
||||||
failover = dict(required=False),
|
health_check = dict(required=False),
|
||||||
vpc_id = dict(required=False),
|
failover = dict(required=False),
|
||||||
|
vpc_id = dict(required=False),
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
module = AnsibleModule(argument_spec=argument_spec)
|
module = AnsibleModule(argument_spec=argument_spec)
|
||||||
|
|
@ -308,23 +328,24 @@ def main():
|
||||||
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')
|
||||||
|
|
||||||
command_in = module.params.get('command')
|
command_in = module.params.get('command')
|
||||||
zone_in = module.params.get('zone').lower()
|
zone_in = module.params.get('zone').lower()
|
||||||
hosted_zone_id_in = module.params.get('hosted_zone_id')
|
hosted_zone_id_in = module.params.get('hosted_zone_id')
|
||||||
ttl_in = module.params.get('ttl')
|
ttl_in = module.params.get('ttl')
|
||||||
record_in = module.params.get('record').lower()
|
record_in = module.params.get('record').lower()
|
||||||
type_in = module.params.get('type')
|
type_in = module.params.get('type')
|
||||||
value_in = module.params.get('value')
|
value_in = module.params.get('value')
|
||||||
alias_in = module.params.get('alias')
|
alias_in = module.params.get('alias')
|
||||||
alias_hosted_zone_id_in = module.params.get('alias_hosted_zone_id')
|
alias_hosted_zone_id_in = module.params.get('alias_hosted_zone_id')
|
||||||
retry_interval_in = module.params.get('retry_interval')
|
alias_evaluate_target_health_in = module.params.get('alias_evaluate_target_health')
|
||||||
private_zone_in = module.params.get('private_zone')
|
retry_interval_in = module.params.get('retry_interval')
|
||||||
identifier_in = module.params.get('identifier')
|
private_zone_in = module.params.get('private_zone')
|
||||||
weight_in = module.params.get('weight')
|
identifier_in = module.params.get('identifier')
|
||||||
region_in = module.params.get('region')
|
weight_in = module.params.get('weight')
|
||||||
health_check_in = module.params.get('health_check')
|
region_in = module.params.get('region')
|
||||||
failover_in = module.params.get('failover')
|
health_check_in = module.params.get('health_check')
|
||||||
vpc_id_in = module.params.get('vpc_id')
|
failover_in = module.params.get('failover')
|
||||||
|
vpc_id_in = module.params.get('vpc_id')
|
||||||
|
|
||||||
region, ec2_url, aws_connect_kwargs = get_aws_connection_info(module)
|
region, ec2_url, aws_connect_kwargs = get_aws_connection_info(module)
|
||||||
|
|
||||||
|
|
@ -378,7 +399,7 @@ def main():
|
||||||
health_check=health_check_in, failover=failover_in)
|
health_check=health_check_in, failover=failover_in)
|
||||||
for v in value_list:
|
for v in value_list:
|
||||||
if alias_in:
|
if alias_in:
|
||||||
wanted_rset.set_alias(alias_hosted_zone_id_in, v)
|
wanted_rset.set_alias(alias_hosted_zone_id_in, v, alias_evaluate_target_health_in)
|
||||||
else:
|
else:
|
||||||
wanted_rset.add_value(v)
|
wanted_rset.add_value(v)
|
||||||
|
|
||||||
|
|
@ -389,7 +410,7 @@ def main():
|
||||||
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 rset.type == type_in and decoded_name.lower() == record_in.lower() and str(rset.identifier) == str(identifier_in):
|
if rset.type == type_in and decoded_name.lower() == record_in.lower() and str(rset.identifier) == str(identifier_in):
|
||||||
found_record = True
|
found_record = True
|
||||||
|
|
@ -413,6 +434,7 @@ def main():
|
||||||
record['value'] = rset.alias_dns_name
|
record['value'] = rset.alias_dns_name
|
||||||
record['values'] = [rset.alias_dns_name]
|
record['values'] = [rset.alias_dns_name]
|
||||||
record['alias_hosted_zone_id'] = rset.alias_hosted_zone_id
|
record['alias_hosted_zone_id'] = rset.alias_hosted_zone_id
|
||||||
|
record['alias_evaluate_target_health'] = rset.alias_evaluate_target_health
|
||||||
else:
|
else:
|
||||||
record['alias'] = False
|
record['alias'] = False
|
||||||
record['value'] = ','.join(sorted(rset.resource_records))
|
record['value'] = ','.join(sorted(rset.resource_records))
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue