internet/community.general
3
0
Fork 0
mirror of https://github.com/ansible-collections/community.general.git synced 2026-05-08 14:22:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add some failure handling for region and publish

Browse Source
This commit is contained in:
Michael J. Schultz
2014-03-28 11:08:50 -05:00
parent 9fbef265bf
commit c8a810df78
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
library/notification/sns
View File

@@ -149,6 +149,8 @@ def main():
https = module.params['https'] https = module.params['https']
region, ec2_url, aws_connect_params = get_aws_connection_info(module) region, ec2_url, aws_connect_params = get_aws_connection_info(module)
if not region:
module.fail_json(msg="region must be specified")
try: try:
connection = connect_to_aws(boto.sns, region, **aws_connect_params) connection = connect_to_aws(boto.sns, region, **aws_connect_params)
except boto.exception.NoAuthHandlerFound, e: except boto.exception.NoAuthHandlerFound, e:
@@ -177,8 +179,11 @@ def main():
dict_msg.update(https=https) dict_msg.update(https=https)
json_msg = json.dumps(dict_msg) json_msg = json.dumps(dict_msg)
connection.publish(topic=arn_topic, subject=subject, try:
message_structure='json', message=json_msg) connection.publish(topic=arn_topic, subject=subject,
message_structure='json', message=json_msg)
except boto.exception.BotoServerError, e:
module.fail_json(msg=str(e))
module.exit_json(msg="OK") module.exit_json(msg="OK")