Skip to main content

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


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

pyqueued-0.1.4.tar.gz (2.2 kB view details)

Uploaded Source

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

Hashes for pyqueued-0.1.4.tar.gz
Algorithm Hash digest
SHA256 f7738500624d331ff16880ce87a1a93878acef40beed86b2f8ec4e01101c4180
MD5 e9f08e2f1b5100078910a5cb2e3c4989
BLAKE2b-256 1829544c04609f4572eca347c43b4139b532ca06c94c37167a76d8794bfca341

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page