talus (noun) - ta·lus | ˈtā-ləs: a slope formed especially by an accumulation of rock debris; Occasional habitat of the pika.
A wrapper of connecting to RabbitMQ which constrains clients to a single purpose channel (producer or consumer) with healing for intermittent connectivity.
Features
Guided separation of connections for producers and consumers
Re-establish connections to the server when lost
Constrained interface to support simple produce / consume use cases for direct exchanges
Installation
pip install talusExamples
Consumer with defaults for connection and retry
with DurableBlockingConsumerWrapper(consumer_queue='queue_name') as consumer:
for method, properties, body in consumer.consume_generator(auto_ack=True):
pass # DO Something with the messageConsumer specifying connection and retry data
with DurableBlockingConsumerWrapper(consumer_queue='queue_name',
rabbitmq_host="localhost",
rabbitmq_port5672,
rabbitmq_user='guest',
rabbitmq_pass='guest',
retry_delay=1,
retry_backoff=2,
retry_jitter=(1, 10),
retry_max_delay=300,
prefetch_count=1,
connection_name='consumer connection') as consumer:
for method, properties, body in consumer.consume_generator(auto_ack=True):
pass # DO Something with the messageProducer with defaults for connection and retry
with DurableBlockingProducerWrapper(producer_queue_bindings=[{"routing_key": "test.m", "bound_queue": "test.q"},],
publish_exchange='amq.direct') as producer:
producer.post('test.m', {'key': 'value'})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
File details
Details for the file talus-0.0.1.tar.gz.
File metadata
- Download URL: talus-0.0.1.tar.gz
- Upload date:
- Size: 10.0 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/2.0.0 pkginfo/1.5.0.1 requests/2.22.0 setuptools/41.0.1 requests-toolbelt/0.9.1 tqdm/4.36.1 CPython/3.7.3
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 |
1d1ee2bf0720a05e6ec6c3de7f74602277ecfc478692fb2126c52cd5cfe065c8
|
|
| MD5 |
2604e153cb49e15777ee8f761f6ddcbc
|
|
| BLAKE2b-256 |
6600649e79754825d6fd8831f3d39adb34050ac43a32a4b95f553ab731585734
|
