Skip to main content
Join the official 2019 Python Developers SurveyStart the survey!

A wrapper for connecting to RabbitMQ which constrains clients to a single purpose channel (producer or consumer) with healing for intermittent connectivity.

Project description

codecov

talus (noun) - ta·​lus | ˈtā-ləs: a slope formed especially by an accumulation of rock debris; Occasional habitat of the pika.

A wrapper for 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 talus

Examples

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 message

Consumer 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 message

Producer 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'})

Project details


Download files

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

Files for talus, version 0.1.0
Filename, size File type Python version Upload date Hashes
Filename, size talus-0.1.0.tar.gz (10.0 kB) File type Source Python version None Upload date Hashes View hashes

Supported by

Elastic Elastic Search Pingdom Pingdom Monitoring Google Google BigQuery Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN SignalFx SignalFx Supporter DigiCert DigiCert EV certificate StatusPage StatusPage Status page