Rabbit MQ wrapper implement with amqpstorm and with threading or multiprocessing
Project description
rmcworkers -- Manage dynamic workers rabbitmq for Python applications
Project rmcworkers offer high availability through simple, yet powerful library: This library doesn't work as a standalone.
This project require a rabbitmq server.
Please note that for development I've used a container:
How to run
docker run -d --hostname my-rabbit --name rabbitmq-server -p 15672:15672 -p 5672:5672 rabbitmq:3-management
Default has credentials: user: quest passw: quest
cd rmqworkers/examples
source venv/bin/activate or venv/Scripts/activate.sh
pip install -r requirements.txt
python example_1queue_in_and_1queue_out.py
Expected output
Default will use thread.
publish in queue in { "job_info": "11111"}
Verify if in queue out is {'job_info': '11111!!!!!!!', 'add_something': 'something'}
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Hashes for rmqworkers-0.0.3-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | b926d6f3cae6e41fbc8bbb08e44c69e9ae115b6801995288d6b1abb16eaba5cb |
|
MD5 | 1c0a448f7edaf9e098fe02f6ba9ebeb2 |
|
BLAKE2b-256 | e8817e17ff308854f9a9d356ff5a8e661999e21a604c30c508399df381821bd5 |