Adding feature to remove the SQS queues

aws/sqs.py

@@ -0,0 +1,12 @@
+from core.region_connection import SQSConnection
+
+def teardown_sqs():
+    conn = SQSConnection()
+
+    for queue in conn.get_all_queues(prefix='nimbostratus'):
+
+        # Empty the queue in order to remove it
+        for message in queue.get_messages():
+            queue.delete_message(message)
+
+        conn.delete_queue(queue)

core/region_connection.py

@@ -1,6 +1,7 @@
 import boto.rds
 import boto.iam
 import boto.ec2
+import boto.sqs
 
 from config import REGION
 
@@ -12,4 +13,7 @@ def RDSConnection():
     return boto.rds.connect_to_region(REGION)
 
 def IAMConnection():
-    return boto.iam.connect_to_region('universal')
+    return boto.iam.connect_to_region('universal')
+
+def SQSConnection():
+    return boto.sqs.connect_to_region(REGION)

fabfile.py

@@ -7,6 +7,7 @@
 
 from aws.rds import spawn_rds, teardown_rds
 from aws.iam import spawn_iam_user, teardown_iam_user
+from aws.sqs import teardown_sqs
 
 from core.log_handler import configure_logging
 
@@ -31,4 +32,5 @@ def teardown():
     teardown_iam_user()
 
     teardown_celery_backend()
+    teardown_sqs()