· 9 years ago · Dec 16, 2016, 02:40 PM
1# Program for creating SQS Queue
2import boto.sqs
3
4ACCESS_KEY = ""
5SECRET_KEY = ""
6
7REGION = "us-east-1"
8
9print ("Connecting")
10
11conn = boto.sqs.connect_to_region(REGION,
12 aws_access_key_id = ACCESS_KEY,
13 aws_secret_access_key = SECRET_KEY)
14
15queue_name = 'myQueue'
16
17print ("Connecting with ", queue_name)
18q = conn.create_queue(queue_name)
19print ("Created queue with ", queue_name)
20print ("Getting all queues")
21
22rs = conn.get_all_queues()
23
24for item in rs:
25 print item
26
27# Program for writing to SQS Queue
28import boto.sqs
29from boto.sqs.message import Message
30
31ACCESS_KEY = ""
32SECRET_KEY = ""
33
34REGION = "us-east-1"
35
36print ("Connecting")
37
38conn = boto.sqs.connect_to_region(REGION,
39 aws_access_key_id = ACCESS_KEY,
40 aws_secret_access_key = SECRET_KEY)
41
42queue_name = 'myQueue'
43
44print ("Connecting with ", queue_name)
45q = conn.get_all_queues(prefix = queue_name)
46
47msg_datetime = time.asctime(time.localtime(time.time()))
48msg = "Test message generated on : " + msg_datetime
49print ("Writing to queue : ", msg)
50
51m = Message()
52m.set_body(msg)
53status = q[0].write(m)
54print ("Message written to queue")
55
56count = q[0].count()
57print ("Total message in queue: ", count)
58
59# Program for reading from SQS Queue
60import boto.sqs
61from boto.sqs.message import Message
62
63ACCESS_KEY = ""
64SECRET_KEY = ""
65
66REGION = "us-east-1"
67
68print ("Conecting")
69
70conn = boto.sqs.connect_to_region(REGION,
71 aws_access_key_id = ACCESS_KEY,
72 aws_secret_access_key = SECRET_KEY)
73
74queue_name = "myQueue"
75
76print ("Connecting with ", queue_name)
77q = conn.get_all_queues(prefix = queue_name)
78
79count = q[0].count()
80print ("Total messages in queue", count)
81
82print ("Reading message from queue")
83for i in range(count):
84 m = q[0].read()
85 print ("Message", i+1, ":", m.get_body())
86 q[0].delete_message(m)
87
88print ("Read", count, "messages from queue")