弹性队列是承载pubsub项目的库。
equeue的Python项目详细描述
#弹性队列是承担公共子项目的一个库,如何使用它来安装pip
1]:从equeue.rabbit.publisher导入publisher
in[2]:pub=publisher(host'localhost'localhost'localhost'username'guest'password'guest'guest'password'guest'queue'name't't')
[3]:pub.put(message'dict={'id'{'1})
出[3]:<;promise@0x10ef18b78>;
`````
1]:来自equeue.rabbit。subscriber导入subscriber
in[2]:sub=订阅者(host='localhost',username='guest',password='guest',在[3]:msg=sub.get()
>
…:print(msg)
……
```python
>事件输出(回调、消息,传递标记:
打印(消息)
打印(传递标记)
回调.ack(传递标记)
def main():
sub=订阅者(host=”localhost',username=”guest',
password=”guest”,排队
sub.setup消费者(callbackback=events-out)
while true:
sub.consume()
br/>如果\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\开发模式
运行测试
测试您需要安装pytest。安装简单如下:
``shell
$pip install py test
````
1]:从equeue.rabbit.publisher导入publisher
in[2]:pub=publisher(host'localhost'localhost'localhost'username'guest'password'guest'guest'password'guest'queue'name't't')
[3]:pub.put(message'dict={'id'{'1})
出[3]:<;promise@0x10ef18b78>;
`````
1]:来自equeue.rabbit。subscriber导入subscriber
in[2]:sub=订阅者(host='localhost',username='guest',password='guest',在[3]:msg=sub.get()
>
…:print(msg)
……
```python
>事件输出(回调、消息,传递标记:
打印(消息)
打印(传递标记)
回调.ack(传递标记)
def main():
sub=订阅者(host=”localhost',username=”guest',
password=”guest”,排队
sub.setup消费者(callbackback=events-out)
while true:
sub.consume()
br/>如果\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\\开发模式
运行测试
测试您需要安装pytest。安装简单如下:
``shell
$pip install py test
````