-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathexample.py
39 lines (32 loc) · 1.08 KB
/
example.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
37
38
39
from py_queue_factory import QueueFactory
ACCOUNTS_SIGNUP_QUEUE = {
'name': 'accounts-signup',
'visibility_timeout': 100, # in secs, default 60 secs
'encoding': 'json', # default base64
}
queue = QueueFactory.get_queue(
'https://<aws_access_key>:<aws_secret_key>@sqs.<region>.amazonaws.com/<account_id>/<queue_prefix>'
'https://subscriptions-stag.practodev.com',
'subscriptions'
)
payload_to_send = {'test': 'some data'}
print('Sending message')
queue \
.set_queue_properties(ACCOUNTS_SIGNUP_QUEUE) \
.send_message(payload_to_send, delay=5)
# delay is optinal, default is 0
print('Message sent')
print('Receiving message')
message = queue \
.set_queue_properties(ACCOUNTS_SIGNUP_QUEUE) \
.receive_message()
print('Message received')
payload = message.get_body()
print(payload['test']) # prints some data
print('Deleting message')
queue \
.set_queue_properties(ACCOUNTS_SIGNUP_QUEUE) \
.delete_message(message)
print('Message deleted')
# Note: Multiple calls to set_queue_properties not needed if not dealing
# with multiple queues in the samw worker