cool, now we can delete sns topics
This commit is contained in:
19
libs/sns.py
19
libs/sns.py
@@ -57,3 +57,22 @@ def list_sns_subscribers(topic,region):
|
|||||||
print("Unexpected error: {}" .format(e))
|
print("Unexpected error: {}" .format(e))
|
||||||
except KeyboardInterrupt:
|
except KeyboardInterrupt:
|
||||||
print("CTRL-C received, exiting...")
|
print("CTRL-C received, exiting...")
|
||||||
|
|
||||||
|
def delete_sns_topic(topic, region):
|
||||||
|
try:
|
||||||
|
client = boto3.client('sns', region_name=region)
|
||||||
|
action = client.delete_topic(TopicArn=topic)
|
||||||
|
print("Deleted Topic: {}".format(topic))
|
||||||
|
except botocore.exceptions.ClientError as e:
|
||||||
|
if e.response['Error']['Code'] == 'InvalidClientTokenId':
|
||||||
|
sys.exit("The AWS KEY IS INVALID. Exiting")
|
||||||
|
if e.response['Error']['Code'] == 'AccessDenied':
|
||||||
|
print('{} : Is NOT a root key' .format(AWS_ACCESS_KEY_ID))
|
||||||
|
elif e.response['Error']['Code'] == 'SubscriptionRequiredException':
|
||||||
|
print('{} : Has permissions but isnt signed up for service - usually means you have a root account' .format(AWS_ACCESS_KEY_ID))
|
||||||
|
elif e.response['Error']['Code'] == 'InvalidParameter':
|
||||||
|
print('The region you provided ({}) is invalid for the Topic ARN. Are you sure this topic exists in this region?'.format(region))
|
||||||
|
else:
|
||||||
|
print("Unexpected error: {}" .format(e))
|
||||||
|
except KeyboardInterrupt:
|
||||||
|
print("CTRL-C received, exiting...")
|
||||||
|
|||||||
@@ -21,3 +21,14 @@ def module_sns_list_subscribers(*args):
|
|||||||
list_sns_subscribers(args[0][0], args[0][1])
|
list_sns_subscribers(args[0][0], args[0][1])
|
||||||
except IndexError:
|
except IndexError:
|
||||||
print("Please provide a topic arn *AND* region, ex: -a arn:aws:sns:us-east-1:123456789123:sometopic,us-east-1")
|
print("Please provide a topic arn *AND* region, ex: -a arn:aws:sns:us-east-1:123456789123:sometopic,us-east-1")
|
||||||
|
|
||||||
|
def module_sns_delete_topic(*args):
|
||||||
|
'''
|
||||||
|
SNS delete a topic. Takes two arguments - the topic arn and the region.
|
||||||
|
python3 weirdAAL.py -m sns_delete_topic -a arn:aws:sns:us-east-1:123456789123:sometopic,us-east-1
|
||||||
|
'''
|
||||||
|
try:
|
||||||
|
if args[0][0] and args[0][1]:
|
||||||
|
delete_sns_topic(args[0][0], args[0][1])
|
||||||
|
except IndexError:
|
||||||
|
print("Please provide a topic arn *AND* region, ex: -a arn:aws:sns:us-east-1:123456789123:sometopic,us-east-1")
|
||||||
|
|||||||
Reference in New Issue
Block a user