summaryrefslogtreecommitdiff
path: root/cloud/amazon/sns_topic.py
diff options
context:
space:
mode:
Diffstat (limited to 'cloud/amazon/sns_topic.py')
-rw-r--r--cloud/amazon/sns_topic.py13
1 files changed, 6 insertions, 7 deletions
diff --git a/cloud/amazon/sns_topic.py b/cloud/amazon/sns_topic.py
index f4916693..34bae494 100644
--- a/cloud/amazon/sns_topic.py
+++ b/cloud/amazon/sns_topic.py
@@ -122,7 +122,6 @@ sns_topic:
attributes_set: []
'''
-import sys
import time
import json
import re
@@ -134,6 +133,9 @@ try:
except ImportError:
HAS_BOTO = False
+from ansible.module_utils.basic import AnsibleModule
+from ansible.module_utils.ec2 import connect_to_aws, ec2_argument_spec, get_aws_connection_info
+
class SnsTopicManager(object):
""" Handles SNS Topic creation and destruction """
@@ -176,7 +178,7 @@ class SnsTopicManager(object):
try:
return connect_to_aws(boto.sns, self.region,
**self.aws_connect_params)
- except BotoServerError, err:
+ except BotoServerError as err:
self.module.fail_json(msg=err.message)
def _get_all_topics(self):
@@ -185,8 +187,8 @@ class SnsTopicManager(object):
while True:
try:
response = self.connection.get_all_topics(next_token)
- except BotoServerError, err:
- module.fail_json(msg=err.message)
+ except BotoServerError as err:
+ self.module.fail_json(msg=err.message)
topics.extend(response['ListTopicsResponse']['ListTopicsResult']['Topics'])
next_token = response['ListTopicsResponse']['ListTopicsResult']['NextToken']
if not next_token:
@@ -400,8 +402,5 @@ def main():
module.exit_json(**sns_facts)
-from ansible.module_utils.basic import *
-from ansible.module_utils.ec2 import *
-
if __name__ == '__main__':
main()