阻止自定义django命令以消费AMQP队列
项目描述
这是什么
============
添加一个自定义命令,该命令与AMQP服务器建立一个阻塞连接并将消息传递给回调函数
设置
--------
这些设置是命令运行所必需的
``COM_BROKER``
AMQP服务器IP
``COM_VHOST``
AMQP服务器虚拟主机
``COM_USERNAME``
虚拟主机的用户名
``COM_PASSWORD``
用户名密码
``COM_QUEUE``
监听哪个队列
``CONSUMER_CALLBACK``
回调函数的路径,例如:djamqpconsumer.printconsumer.printdata
安装
-------
使用pip从PyPI安装:
pip安装djamqpconsumer
用法
-----
将``djamqpconsumer``添加到settings.py文件:
INSTALLED_APPS = (
...
'djamqpconsumer',
...
)
使用manage.py:
manage.py consumer [debug]
0.6 (2014-03-27)
================
- 解析结果以发送nack/requeue命令
回调命令必须返回一个字典,包含
{'result': 0/1
'msg': 字符串,
'retry': 布尔}
- 使用日志记录代替打印
0.5 (2014-02-21)
================
- 添加pika依赖项
============
添加一个自定义命令,该命令与AMQP服务器建立一个阻塞连接并将消息传递给回调函数
设置
--------
这些设置是命令运行所必需的
``COM_BROKER``
AMQP服务器IP
``COM_VHOST``
AMQP服务器虚拟主机
``COM_USERNAME``
虚拟主机的用户名
``COM_PASSWORD``
用户名密码
``COM_QUEUE``
监听哪个队列
``CONSUMER_CALLBACK``
回调函数的路径,例如:djamqpconsumer.printconsumer.printdata
安装
-------
使用pip从PyPI安装:
pip安装djamqpconsumer
用法
-----
将``djamqpconsumer``添加到settings.py文件:
INSTALLED_APPS = (
...
'djamqpconsumer',
...
)
使用manage.py:
manage.py consumer [debug]
0.6 (2014-03-27)
================
- 解析结果以发送nack/requeue命令
回调命令必须返回一个字典,包含
{'result': 0/1
'msg': 字符串,
'retry': 布尔}
- 使用日志记录代替打印
0.5 (2014-02-21)
================
- 添加pika依赖项