使用asyncio实现amqp

aioamqp的Python项目详细描述


https://badge.fury.io/py/aioamqp.svghttps://travis-ci.org/Polyconseil/aioamqp.svg?branch=masterDocumentation Status

aioamqp库是AMQP 0.9.1 protocol的纯python实现。

基于python在PEP 3156中引入的异步i/o支持,它提供了一个基于协程的api,使得编写高度并发的应用程序变得容易。

欢迎使用错误报告、补丁和建议!打开一个issue或发送一个pull request

测试

要运行测试,您需要安装python测试依赖项:

pip install -r requirements_dev.txt

测试需要rabbitmq的实例。您可以使用Docker启动一个新实例:

docker run -d --log-driver=syslog -e RABBITMQ_NODENAME=my-rabbit --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:3-management

然后可以使用make test运行测试。

使用docker compose的测试

使用docker-compose up -d rabbitmq启动rabbitmq。rabbitmq启动后,使用docker-compose up --buildaioamqp-test

启动测试

欢迎加入QQ群-->: 979659372 Python中文网_新手群

推荐PyPI第三方库


热门话题
java如何使用Scanner用文件中的文本填充数组,然后从数组中随机选择文本?   java如何在windows中使用BlueJ进行无限缓冲   java为什么JPA中存在“太多连接”?   java如何在recyclerview中创建和填充公共字段?   当我在Google Play上发布应用程序时,很多设备都不支持java xWalkWebView 64位   HTML文档文本中位置或偏移量的java含义   java如何在JTextArea中打开文件,并使用FileReader和FileWriter类进行读写   java`elementtobelickable`只是检查它是否可见并已启用   安卓中图像下方的java绘图文本   java我如何为我的Android应用程序启用Google signin,使其只允许来自特定Google域的用户?   在超级Java调用中调用父级的内部类   java在没有定时器的情况下运行代码   java使用hashset值作为hashmap中的键   java我需要为我的应用程序获取API密钥,为此,我需要证书的MD5签名   java编写一个方法来查看字符串x是否包含字母“G”