-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathqueueReader.py
More file actions
34 lines (26 loc) · 956 Bytes
/
queueReader.py
File metadata and controls
34 lines (26 loc) · 956 Bytes
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
#!/usr/bin/python
# -----------------------------------------------------------------------------
#
# Queue reader - Simple script to read and print entries in the queue
# Pedro Perez - 2015
#
# -----------------------------------------------------------------------------
import sys
import os
import subprocess
from azure.storage.queue import QueueService
account_name = "mcdockerqueue"
account_key = sys.argv[1]
queuename = "servers"
queue_service = QueueService(account_name, account_key)
queue_metadata = queue_service.get_queue_metadata(queuename)
count = queue_metadata['x-ms-approximate-messages-count']
print "There are %s messages in the queue" % count
if count > 0:
messages = queue_service.get_messages(queuename)
for message in messages:
print(message.message_text)
# Remove message from the queue
queue_service.delete_message(queuename, message.message_id, message.pop_receipt)
else:
print "There are no messages to process"