跳转到主要内容

用于使用pika的辅助库。

项目描述

皮卡康是一个辅助库,它可以减少使用pika创建到代理的连接和声明交换机和队列时所需的样板代码量。使用皮卡康,您可以轻松地启动并运行队列,而不需要做出任何妥协。

要求

  • python 2.7

  • pika >= 0.9.8

使用方法

Pikacon提供了一个可以帮助类,可以导入到您的程序中。类接受一个指向.ini样式配置文件的路径作为参数,并从中自动创建连接、交换机、队列和绑定。您所需提供的只是一个合适的配置。

创建顺序如下

  1. 连接

  2. 通道

  3. 交换机

  4. 队列

  5. 绑定

配置

皮卡康使用Python的ConfigParser来获取连接、交换机和队列的配置。

代理

代理配置如下示例。部分名称是代理,选项是代理的常规pika参数。如果您想配置ssl_options,为这些选项创建一个新的部分,并在代理选项中引用该部分名称。例如。

[broker]
...
ssl = True
ssl_options = my_ssl_options

[my_ssl_options]
...

交换机

交换机的部分名称由两部分组成,由‘:’分隔。第一部分是‘exchange’,第二部分是交换机的名称。例如。

[exchange:myexchange]
...

在交换机部分下的实际选项是pika中使用的正常键=值参数。

队列

队列的部分由两部分组成,由‘:’分隔。第一部分是‘queue’,第二部分是队列的名称。例如。

[queue:myqueue]
...

在队列部分下的选项是

durable = True|False
exclusive = True|False
arguments = queue:queuename:arguments

队列的额外参数由另一个部分提供。皮卡康假设参数部分的名称遵循以下约定‘queue:queuename:nameofargumentsection’。

在队列部分下的实际选项是pika中使用的正常键=值参数。

绑定

绑定部分的名称由三部分组成,由冒号“:”分隔。第一部分始终是“binding”。第二部分是我们绑定队列的名称。第三部分是我们绑定队列的交换机的名称。例如:

[binding:myqueue:myexchange]
...

绑定部分以下的实际选项是pika中使用的正常键=值参数。

完整的配置示例

[broker]
host = localhost
port = 5672
username = guest
password = guest
virtual_host = /
heartbeat = 60

[exchange:exchangename]
type = direct
durable = False
auto_delete = True

[queue:testqueue1]
durable = True
exclusive = False

[queue:testqueue2]
durable = False
exclusive = False

[queue:testqueue3]
durable = True
exclusive = False
arguments = queue:testqueue3:arguments

[queue:testqueue4]
durable = True
exclusive = False

[queue:testqueue3:arguments]
x-message-ttl = 1800000
x-dead-letter-exchange = exchangename
x-dead-letter-routing-key = key4

[binding:testqueue1:exchangename]
routing_key = key1

[binding:testqueue2:exchangename]
routing_key = key2

[binding:testqueue3:exchangename]
routing_key = key3

[binding:testqueue4:exchangename]
routing_key = key4

上述示例配置了连接到本地主机的代理。它定义了一个名为exchangename的直接交换机,以及四个名为testqueue1、testqueue2、testqueue3和testqueue4的队列。Testqueue3有额外的参数,定义了死信交换机。所有队列都绑定到我们的唯一交换机,使用路由键key1、key2、key3和key4。

变更日志

0.3.1 - 2012-12-02

  • 修复了setup.py和README.rst。

0.3 - 2012-12-02

  • 需要Pika >= 0.9.8

  • 支持与pika相同的连接参数集。

  • 缩短了配置文件结构。为pikacon旧版本制作的配置文件不再适用。

项目详情


下载文件

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

源分发

pikacon-0.3.1.zip (12.3 kB 查看哈希值)

上传时间

由支持