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.4.zip
(5.1 kB
view details)
File details
Details for the file djamqpconsumer-0.4.zip.
File metadata
- Download URL: djamqpconsumer-0.4.zip
- Upload date:
- Size: 5.1 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 100cae5b85fb15a83ab572e8417938fbf9fd9faddc4ca0b504c7579906f90497 |
|
| MD5 | b6cc36ce5013223570e409c912fe3fe2 |
|
| BLAKE2b-256 | a23ea7476598bb746c22543815fd15ab1b74de03deec0d961c88233ac0fa79ba |
