sprockets.mixins.amqp 3.0.1

安装

sprockets.mixins.amqp 可在 Python包索引 上找到，并且可以通过 pip 安装

pip3 install sprockets.mixins.amqp

文档

https://sprocketsamqp.readthedocs.io

Python兼容性

• Python 3.7

• Python 3.8

需求

• Pika==0.13.1

• Tornado>=6,<7

示例

您可以选择将 sprockets.mixins.correlation 安装到您的请求处理程序中，以利用自动 correlation_id 获取。否则，在发送AMQP消息之前，请确保在您的请求处理程序实例变量上设置 correlation_id。

以下示例演示了 sprockets.mixins.amqp 的最基本用法

export AMQP_URL="amqp://user:password@rabbitmq_host:5672/%2f"
python my-example-app.py

import json

from tornado import gen, web
from sprockets.mixins import amqp

def make_app(**settings):
    application = web.Application(
        [
            web.url(r'/', RequestHandler),
        ], **settings)

    amqp_settings = {
        "reconnect_delay": 5,
    }

    amqp.install(application, **amqp_settings)
    return application


class RequestHandler(amqp.PublishingMixin,
                     correlation.HandlerMixin,
                     web.RequestHandler):

    async def get(self, *args, **kwargs):
        body = {'request': self.request.path, 'args': args, 'kwargs': kwargs}
        await self.amqp_publish(
            'exchange',
            'routing.key',
            json.dumps(body),
            {'content_type': 'application/json'}
        )

来源

sprockets.mixins.amqp 源代码可在 Github 上找到，网址为 https://github.com/sprockets/sprockets.mixins.amqp

本地运行测试

您需要安装 python 3.7、Docker 和 Docker Compose。

$ python3 -m venv env
$ env/bin/activate
(env) $ pip3 install -r requires/testing.txt
(env) $ ./bootstrap.sh
(env) $ coverage run && coverage report

许可证

sprockets.mixins.amqp 在 3-Clause BSD 许可证 下发布。