-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathempty_sqs.py
37 lines (31 loc) · 1.42 KB
/
empty_sqs.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
import boto3
import base64
req_q = boto3.client('sqs')
response = req_q.get_queue_attributes(
QueueUrl='https://sqs.us-east-1.amazonaws.com/533267346617/1230868550-req-queue',
AttributeNames=['ApproximateNumberOfMessages']
)
print('Request Queue:' ,int(response['Attributes']['ApproximateNumberOfMessages']))
for i in range(int(response['Attributes']['ApproximateNumberOfMessages'])):
received_message = req_q.receive_message(
QueueUrl = 'https://sqs.us-east-1.amazonaws.com/533267346617/1230868550-req-queue'
)
handler = received_message['Messages'][0]['ReceiptHandle']
req_q.delete_message(
QueueUrl='https://sqs.us-east-1.amazonaws.com/533267346617/1230868550-req-queue',
ReceiptHandle=handler
)
response = req_q.get_queue_attributes(
QueueUrl='https://sqs.us-east-1.amazonaws.com/533267346617/1230868550-resp-queue',
AttributeNames=['ApproximateNumberOfMessages']
)
print('Response Queue:' ,int(response['Attributes']['ApproximateNumberOfMessages']))
for i in range(int(response['Attributes']['ApproximateNumberOfMessages'])):
received_message = req_q.receive_message(
QueueUrl = 'https://sqs.us-east-1.amazonaws.com/533267346617/1230868550-resp-queue'
)
handler = received_message['Messages'][0]['ReceiptHandle']
req_q.delete_message(
QueueUrl='https://sqs.us-east-1.amazonaws.com/533267346617/1230868550-resp-queue',
ReceiptHandle=handler
)