Blocking custom django command to consume a AMQP queue
Project description
What is this
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]
0.5 (2014-02-21)
Add pika dependency
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.5.zip
(6.4 kB
view details)
File details
Details for the file djamqpconsumer-0.5.zip.
File metadata
- Download URL: djamqpconsumer-0.5.zip
- Upload date:
- Size: 6.4 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 09a645cf70d76e360b266059cce8ea5996fae6d4798985544d10407f1f0728df |
|
| MD5 | d87cc03d133fd7afce8b453b33a30b9c |
|
| BLAKE2b-256 | 6a2fe8c40df4f327154108d2ab28b732b87ea43aff647b39dc5a627ccd55ad77 |
