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
AMQP server User name for the virtual host
COM_PASSWORD
Username’s password
COM_QUEUE
Which queue listen to
CONSUMER_CALLBACK
Path to the callback func. ex.: djamqpconsumer.printconsumer.printdata
Install
Use pip to install from PyPI:
pip install djamqpconsumer
Usage
Add djamqpconsumer to your settings.py file:
INSTALLED_APPS = (
...
'djamqpconsumer',
...
)
Use with manage.py:
manage.py consumer [debug]
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.3.zip
(5.1 kB
view details)
File details
Details for the file djamqpconsumer-0.3.zip.
File metadata
- Download URL: djamqpconsumer-0.3.zip
- Upload date:
- Size: 5.1 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 74876f068c3ccc52ade3f6e16b9ef579d635c748851c288319b46587f9bc102a |
|
| MD5 | 63eeae1912d999f3db0ee6ab761dbb5f |
|
| BLAKE2b-256 | 23afb72cc1eabfcf3d633830104d211c434ee7e487c8d6f904827f6d3c48cf62 |
