ansible-collections/community.general
1
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2025-09-01 10:51:01 -07:00
Code Issues Projects Releases Packages Wiki Activity Actions 10

added 'facts' action

Browse source
This commit is contained in:
Bruce Pennypacker 2013-06-11 10:45:50 -04:00
commit 26c37d7c07
1 changed files with 17 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

21
library/cloud/rds
View file

@ -23,7 +23,7 @@ description:
options: options:
action: action:
description: description:
- Specifies the action to take. Must be one of: create | replicate | delete - Specifies the action to take. Must be one of: create | replicate | delete | facts
required: true required: true
default: null default: null
aliases: [] aliases: []
@ -224,6 +224,13 @@ EXAMPLES = '''
action=delete action=delete
instance_name=new_database instance_name=new_database
snapshot=new_database_snapshot snapshot=new_database_snapshot
# Get facts about an instance
action: rds
action=facts
instance_name=new_database
register: new_database_facts
''' '''
import sys import sys
@ -253,7 +260,7 @@ except ImportError:
def main(): def main():
module = AnsibleModule( module = AnsibleModule(
argument_spec = dict( argument_spec = dict(
action = dict(choices=['create', 'replicate', 'delete'], required=True), action = dict(choices=['create', 'replicate', 'delete', 'facts'], required=True),
instance_name = dict(required=True), instance_name = dict(required=True),
source_instance = dict(required=False), source_instance = dict(required=False),
db_engine = dict(choices=['MySQL', 'oracle-se1', 'oracle-se', 'oracle-ee', 'sqlserver-ee', 'sqlserver-se', 'sqlserver-ex', 'sqlserver-web'], required=False), db_engine = dict(choices=['MySQL', 'oracle-se1', 'oracle-se', 'oracle-ee', 'sqlserver-ee', 'sqlserver-se', 'sqlserver-ex', 'sqlserver-web'], required=False),
@ -351,7 +358,10 @@ def main():
invalid_vars = [ 'db_engine', 'size', 'username', 'password', 'db_name', 'engine_version', 'parameter_group', 'license_model', 'multi_zone', 'iops', 'security_groups', 'option_group', 'maint_window', 'backup_window', 'backup_retention', 'subnet', 'snapshot'] invalid_vars = [ 'db_engine', 'size', 'username', 'password', 'db_name', 'engine_version', 'parameter_group', 'license_model', 'multi_zone', 'iops', 'security_groups', 'option_group', 'maint_window', 'backup_window', 'backup_retention', 'subnet', 'snapshot']
elif action == 'delete': elif action == 'delete':
required_vars = [ 'instance_name' ] required_vars = [ 'instance_name' ]
invalid_vars = [ 'db_engine', 'size', 'instance_type', 'username', 'password', 'db_name', 'engine_version', 'parameter_group', 'license_model', 'multi_zone', 'iops', 'security_groups', 'option_group', 'maint_window', 'backup_window', 'backup_retention', 'port', 'upgrade', 'subnet', 'zone' ] invalid_vars = [ 'db_engine', 'size', 'instance_type', 'username', 'password', 'db_name', 'engine_version', 'parameter_group', 'license_model', 'multi_zone', 'iops', 'security_groups', 'option_group', 'maint_window', 'backup_window', 'backup_retention', 'port', 'upgrade', 'subnet', 'zone' , 'source_instance']
elif action == 'facts':
required_vars = [ 'instance_name' ]
invalid_vars = [ 'db_engine', 'size', 'instance_type', 'username', 'password', 'db_name', 'engine_version', 'parameter_group', 'license_model', 'multi_zone', 'iops', 'security_groups', 'option_group', 'maint_window', 'backup_window', 'backup_retention', 'port', 'upgrade', 'subnet', 'zone', 'wait', 'source_instance' ]
for v in required_vars: for v in required_vars:
if not module.params.get(v): if not module.params.get(v):
@ -428,6 +438,9 @@ def main():
db = conn.delete_dbinstance(instance_name, **params) db = conn.delete_dbinstance(instance_name, **params)
# Don't do anything for the 'facts' action since we'll just drop down
# to get_all_dbinstances below to collect the facts
except boto.exception.BotoServerError, e: except boto.exception.BotoServerError, e:
module.fail_json(msg = e.error_message) module.fail_json(msg = e.error_message)
@ -442,7 +455,7 @@ def main():
# Wait for the instance to be available if requested # Wait for the instance to be available if requested
if wait: if wait:
try: try:
wait_timeout = time.time() + wait_timeout wait_timeout = time.time() + wait_timeout
time.sleep(5) time.sleep(5)
while wait_timeout > time.time() and my_inst.status != 'available': while wait_timeout > time.time() and my_inst.status != 'available':