跳转到主要内容

阻止自定义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依赖项

项目详情


下载文件

下载适合您平台的文件。如果您不确定选择哪个,请了解有关安装包的更多信息。

源分发

djamqpconsumer-0.7.zip (7.0 kB 查看哈希值)

上传时间:

支持