bridgeq (Python)
bridgeq is a Rust-powered queue toolkit for Python.
Install
pip install bridgeq
Quickstart
from bridgeq import BridgeQueue
queue = BridgeQueue(max_retries=2, visibility_timeout_ms=30_000, retry_backoff_ms=500)
job_id = queue.enqueue("send-email:user-42")
batch = queue.dequeue(10)
for message in batch:
print(message.id, message.payload, message.attempts)
queue.heartbeat(message.id) # renew lease while processing
queue.extend_lease(message.id, 1_000) # add 1s extra lease window
queue.ack(message.id)
stats = queue.stats()
print(stats.ready, stats.delayed, stats.in_flight, stats.dead_letter)
Adapter Selection
from bridgeq import BridgeQueue
memory = BridgeQueue(adapter="memory")
redis = BridgeQueue(adapter="redis", connection_url="redis://127.0.0.1/", namespace="jobs")
postgres = BridgeQueue.postgres("postgres://postgres@127.0.0.1/postgres", namespace="jobs")
memory.enqueue("job-memory")
redis.enqueue("job-redis")
postgres.enqueue("job-postgres")
1 maintainer
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
bridgeq-0.1.18.tar.gz
(67.8 kB
view details)
Built Distributions
Filter files by name, interpreter, ABI, and platform.
If you're not sure about the file name format, learn more about wheel file names.
Copy a direct link to the current filters
File details
Details for the file bridgeq-0.1.18.tar.gz.
File metadata
- Download URL: bridgeq-0.1.18.tar.gz
- Upload date:
- Size: 67.8 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/6.1.0 CPython/3.13.7
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
7ba28ead26fc58b6223d11a0d38fe54391fa170fdbb582b3a253d3310c367cdc
|
|
| MD5 |
c4d447ee993ba24f95a6956109f03ffa
|
|
| BLAKE2b-256 |
60e7cb6e1c3a521baaf60adcfb403b5f51c5213ebbf6b6482e627195a5ddf3fa
|
File details
Details for the file bridgeq-0.1.18-cp38-abi3-win_amd64.whl.
File metadata
- Download URL: bridgeq-0.1.18-cp38-abi3-win_amd64.whl
- Upload date:
- Size: 1.5 MB
- Tags: CPython 3.8+, Windows x86-64
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/6.1.0 CPython/3.13.7
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
221f860a797a23a72c3a63c0447c6e7f219f75d9e58d99154e632a203ce2709d
|
|
| MD5 |
5726293016addea4553131cbc6dd663f
|
|
| BLAKE2b-256 |
4de4776eefde7836856d0da5ca58061a1708a0034eb0aa350c0ae00cfaa8b6a1
|
File details
Details for the file bridgeq-0.1.18-cp38-abi3-manylinux_2_17_x86_64.manylinux2014_x86_64.whl.
File metadata
- Download URL: bridgeq-0.1.18-cp38-abi3-manylinux_2_17_x86_64.manylinux2014_x86_64.whl
- Upload date:
- Size: 1.7 MB
- Tags: CPython 3.8+, manylinux: glibc 2.17+ x86-64
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/6.1.0 CPython/3.13.7
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
cb1a069cc48dc8510428fa4662acca3bb578cb352a854089632444c38e4bb55d
|
|
| MD5 |
74bf7612fd78e645897837ab24dc655a
|
|
| BLAKE2b-256 |
b38ecc2a0c3937cee5988b137593b673903adae739840cf1fcf5996917bd89f9
|
File details
Details for the file bridgeq-0.1.18-cp38-abi3-macosx_11_0_arm64.whl.
File metadata
- Download URL: bridgeq-0.1.18-cp38-abi3-macosx_11_0_arm64.whl
- Upload date:
- Size: 1.5 MB
- Tags: CPython 3.8+, macOS 11.0+ ARM64
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/6.1.0 CPython/3.13.7
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
7125aa3f4e8cd16ea87fac7ee65644574387d6b63f8f356aa9060097862c567a
|
|
| MD5 |
4154030406e659b727f65d8d907571e1
|
|
| BLAKE2b-256 |
4508d242dbd4e7523e51025bdf96d71945307fcbc5c6f4f201b0ac6a43b34d1a
|
File details
Details for the file bridgeq-0.1.18-cp38-abi3-macosx_10_12_x86_64.whl.
File metadata
- Download URL: bridgeq-0.1.18-cp38-abi3-macosx_10_12_x86_64.whl
- Upload date:
- Size: 1.6 MB
- Tags: CPython 3.8+, macOS 10.12+ x86-64
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/6.1.0 CPython/3.13.7
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
547dd3850ffbd103f049d431ef2b559158674900d1b6c35f768bc516801213f8
|
|
| MD5 |
d414102ca6f17a6ab1e1b3d0cf08ebda
|
|
| BLAKE2b-256 |
491e6258e5baa9f789040a09fb1afe9099eeac53c56b4676c08a4e59d5a1a89c
|
