没有项目描述
aioamqp-ext的Python项目详细描述
#异步amqp基本使用者和生产者。
amqp使用者和生产者基类。在“aioamqp”之上工作。
路由密钥='bar'
)
producer.close()
使用者:
'url':'amqp://localhost:5672/',
'exchange':'my'exchange',
'queue':'my'u queue',
'routing'u key':'foo.bar'
})
尝试:
loop=asyncio.get'u event'loop()
循环。运行直至完成(consumer.consume())
循环。永远运行(
除了键盘中断:
loop.run廑until廑complete(consumer.close())
最后:
loop.close()
\tests
要运行测试,需要安装python测试依赖项::
pip install-r./requirements-ci.txt
,然后可以使用“make unit test”运行测试。
amqp使用者和生产者基类。在“aioamqp”之上工作。
路由密钥='bar'
)
producer.close()
使用者:
'url':'amqp://localhost:5672/',
'exchange':'my'exchange',
'queue':'my'u queue',
'routing'u key':'foo.bar'
})
尝试:
loop=asyncio.get'u event'loop()
循环。运行直至完成(consumer.consume())
循环。永远运行(
除了键盘中断:
loop.run廑until廑complete(consumer.close())
最后:
loop.close()
\tests
要运行测试,需要安装python测试依赖项::
pip install-r./requirements-ci.txt
,然后可以使用“make unit test”运行测试。