用于使用pika的辅助库。
项目描述
皮卡康是一个辅助库,它可以减少使用pika创建到代理的连接和声明交换机和队列时所需的样板代码量。使用皮卡康,您可以轻松地启动并运行队列,而不需要做出任何妥协。
要求
python 2.7
pika >= 0.9.8
使用方法
Pikacon提供了一个可以帮助类,可以导入到您的程序中。类接受一个指向.ini样式配置文件的路径作为参数,并从中自动创建连接、交换机、队列和绑定。您所需提供的只是一个合适的配置。
创建顺序如下
连接
通道
交换机
队列
绑定
配置
皮卡康使用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的哈希值
算法 | 哈希摘要 | |
---|---|---|
SHA256 | 36e80af7644324d0a6c5adf20a21cf2ae4af69ddb082c27f899c864a6d1e55ba |
|
MD5 | 67068256da4c3bd74c8e630afdb7ffc4 |
|
BLAKE2b-256 | 84405924dcf82efcebd7250537fab8faeec085d271e6afd1ab534d9867d1b5f1 |