Could you post
a) what the output looks like now (sans the logging part)
b) what output do you expect
In any event, this routine does not look right to me:
def consume_queue(queue_name):
conn = boto.connect_sqs()
q = conn.get_queue(queue_name)
m = q.read()
while m is not None:
yiel
hi, I am struggling to understand how to leverage python's multiprocessing
module in a while loop. the examples I have found seem to assume it is known
ahead of time how many items need to be processed.
specifically, I am reading from an external queue. I currently process items
one at a time