Fix sqs_queue module to check that boto library is installed and AWS region & credentials are provided.
This commit is contained in:
parent
e8e1e41e08
commit
a14420dcf0
1 changed files with 12 additions and 2 deletions
|
@ -84,7 +84,7 @@ EXAMPLES = '''
|
||||||
|
|
||||||
try:
|
try:
|
||||||
import boto.sqs
|
import boto.sqs
|
||||||
from boto.exception import BotoServerError
|
from boto.exception import BotoServerError, NoAuthHandlerFound
|
||||||
HAS_BOTO = True
|
HAS_BOTO = True
|
||||||
|
|
||||||
except ImportError:
|
except ImportError:
|
||||||
|
@ -204,8 +204,18 @@ def main():
|
||||||
argument_spec=argument_spec,
|
argument_spec=argument_spec,
|
||||||
supports_check_mode=True)
|
supports_check_mode=True)
|
||||||
|
|
||||||
|
if not HAS_BOTO:
|
||||||
|
module.fail_json(msg='boto required for this module')
|
||||||
|
|
||||||
region, ec2_url, aws_connect_params = get_aws_connection_info(module)
|
region, ec2_url, aws_connect_params = get_aws_connection_info(module)
|
||||||
connection = boto.sqs.connect_to_region(region)
|
if not region:
|
||||||
|
module.fail_json(msg='region must be specified')
|
||||||
|
|
||||||
|
try:
|
||||||
|
connection = connect_to_aws(boto.sqs, region, **aws_connect_params)
|
||||||
|
|
||||||
|
except (NoAuthHandlerFound, StandardError), e:
|
||||||
|
module.fail_json(msg=str(e))
|
||||||
|
|
||||||
state = module.params.get('state')
|
state = module.params.get('state')
|
||||||
if state == 'present':
|
if state == 'present':
|
||||||
|
|
Loading…
Reference in a new issue