A client for queued.
Project description
Python client for HTTP message queue Queued: https://github.com/scttnlsn/queued.
Usage
>>> import pyqueued
Get a client.
>>> client = pyqueued.Client(host='localhost', port=5353)
Enqueue a message:
>>> loc = client.enqueue("q", "my message") >>> loc 'http://localhost:5353/q/155'
Get the head of the queue. Without any timeout, the item is marked as completed when dequeued.
>>> msg, loc = client.dequeue("q") >>> msg 'my message'
THe queue is empty now, so another dequeue will fail:
>>> msg, loc = client.dequeue("q") ... RuntimeError: dequeue failed: <Response [404]>
Enqueue another message:
>>> loc = client.enqueue("q", "another message")
But dequeue with timeout (given in seconds). If the message is not completed within timeout, it will be enqueued again.
>>> client.dequeue("q", timeout=2) ('another message', 'http://localhost:5353/q/160')
The has message timed out and has been enqueued again. So we can actually dequeue it once more. But now we mark it completed in time.
>>> client.dequeue("q", timeout=20) ('my message with timeout', 'http://localhost:5353/q/160')>>> client.complete("q", "160")
Alternatively, item can be completed by URL. To the last line have been written also as:
>>> client.complete_by_url('http://localhost:5353/q/160')
Stats about the queue:
>>> client.stats("q") {'depth': 1, 'dequeued': 3, 'enqueued': 3, 'timeouts': 1}
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
File details
Details for the file pyqueued-0.1.4.tar.gz
.
File metadata
- Download URL: pyqueued-0.1.4.tar.gz
- Upload date:
- Size: 2.2 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
File hashes
Algorithm | Hash digest | |
---|---|---|
SHA256 | f7738500624d331ff16880ce87a1a93878acef40beed86b2f8ec4e01101c4180 |
|
MD5 | e9f08e2f1b5100078910a5cb2e3c4989 |
|
BLAKE2b-256 | 1829544c04609f4572eca347c43b4139b532ca06c94c37167a76d8794bfca341 |