This is a simple library for building AMQP consumers. It allows you to easily create runnable scripts that process incoming messages for an AMQP queue. It also allows for messages that produce uncaught exceptions to be put on timeout and be automatically reinserted into the queue. After a specified amount of "deaths" you can again custom-handle it. Messages will be processed asynchroniously.
pip install -U https://github.com/riyad/python-consumerlib.gitpip install -Ur test-requirements.txt
py.test tests/There is an example consumer in examples/consumer.py. It will run and wait for messages from a queue defined by the constants at the top.
python -m "examples.consumer" setup
python -m "examples.consumer" run --message-ttl=1000 --max-deaths=2There are other examples that may also be used as helpers in certain cases:
- dump_messages dumps messages from a queue to STDOUT.
- publish_messages publishes a batch of messages to a queue directly or via exchange + routing key.
- requeue_failed_messages requeues messages from the failed_messages queue into their original queue.
Please, report all issues on our issue tracker on GitHub: https://gitlab.com/riyad/python-consumerlib