pyqueued 0.1.4

用法

>>> import pyqueued

获取客户端。

>>> client = pyqueued.Client(host='localhost', port=5353)

入队消息

>>> loc = client.enqueue("q", "my message")
>>> loc
'http://localhost:5353/q/155'

获取队列头部。如果没有超时，当出队时项目会被标记为完成。

>>> msg, loc = client.dequeue("q")
>>> msg
'my message'

现在队列为空，因此另一个出队操作将失败

>>> msg, loc = client.dequeue("q")
...
RuntimeError: dequeue failed: <Response [404]>

入队另一个消息

>>> loc = client.enqueue("q", "another message")

但带有超时（以秒为单位）出队。如果消息在指定的超时时间内未完成，它将被重新入队。

>>> client.dequeue("q", timeout=2)
('another message', 'http://localhost:5353/q/160')

有消息超时并已被重新入队。因此我们可以再次出队它。但现在我们按时标记它完成。

>>> client.dequeue("q", timeout=20)
('my message with timeout', 'http://localhost:5353/q/160')

>>> client.complete("q", "160")

或者，可以通过URL完成项目。最后一行也被写成：

>>> client.complete_by_url('http://localhost:5353/q/160')

队列的统计信息

>>> client.stats("q")
{'depth': 1, 'dequeued': 3, 'enqueued': 3, 'timeouts': 1}