Blocking custom django command to consume a AMQP queue
Project description
Adds a custom command which opens a blocking connection with an AMQP server and passes messages to a callback fuction
Settings
This settings are requiered for the command run
COM_BROKER = “AMQP server ip” COM_VHOST = “AMQP server Virtual Host” COM_USERNAME = “Username” COM_PASSWORD = “Password” COM_QUEUE = ‘Which queue listen to’ CONSUMER_CALLBACK = ‘Path to the callback func. ex.: djamqpconsumer.printconsumer.printdata’
Install
pip install djamqpconsumer
Usage
Add djamqpconsumer to your INSTALLED_APPS run manage.py consumer
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
djamqpconsumer-0.1.zip
(5.3 kB
view details)
File details
Details for the file djamqpconsumer-0.1.zip.
File metadata
- Download URL: djamqpconsumer-0.1.zip
- Upload date:
- Size: 5.3 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 001569a5ccbf95bed56f23aefd5f00a0da9f349ec91399f503b7bb170ef71308 |
|
| MD5 | 33d21719d053e639de968c17ca8f186b |
|
| BLAKE2b-256 | eb037d2570c32c76c476201ee275049af14b3cb4fb328c046b1ca284a892aaca |
