用于瓶子微结构的Pika插件模块
bottle_pika的Python项目详细描述
瓶子皮卡是一个插件,它集成了皮卡(AMQP)和你的瓶子 申请。它在 请求,将通道传递给路由回调并关闭 连接和通道。
要自动检测需要通道的路由,插件 搜索需要mq关键字参数的路由回调 (可配置)并跳过不需要的路由。这就消除了 不需要消息队列的路由。
- 此插件最初基于在: 找到的瓶子mysql插件
- https://pypi.python.org/pypi/bottle-mysql
用法示例:
import bottle import bottle_pika import pika app = bottle.Bottle() pika_plugin = bottle_pika.Plugin(pika.URLParameters('amqp://localhost/')) app.install(pika_plugin) @app.route('/hello') def hello(mq): mq.basic_publish(...) return HTTPResponse(status=200)