sqs_queue 0.1.2

安装

python setup.py install

示例

from sqs_queue import Queue

my_queue = Queue('YOUR_QUEUE_NAME')
for message in my_queue:
    process(message)

或者，如果您希望将无法处理的消息留在队列中 稍后重试：

for message in my_queue:
    try:
        process(message)
    except RetryableError:
        message.defer()
    except Exception as e:
        logger.warn(e)

而且，您还可以发布到队列：

queue.publish('This is the body of my message.')

参数

在幕后，生成器正在轮询sqs以获取新消息。什么时候？ 队列是空的，该呼叫将等待最多20秒 信息，如果它在任何到达之前超时，它将睡眠40分钟 几秒钟后再试。这些时间间隔是可配置的：

queue = Queue('YOUR_QUEUE_NAME', poll_wait=20, poll_sleep=40)