未知
aionsq的Python项目详细描述
使用async/await功能为asyncio实现nsq客户端。
文档可在http://aio.errorist.io/aionsq获得。
安装
python -m pip install aionsq
用法
向NSQ发布消息：
fromaionsq.httpimportNSQWriterwriter=NSQWriter('http://120.0.0.1:4567')awaitwriter.publish('test','hello world 2')
直接连接到NSQ后台程序：
fromaionsq.tcpimportNSQReaderreader=NSQReader('http://120.0.0.1:4567','topic1','chan1')@reader.subscribe('test')asyncdefconsumer(msg):msg.success()awaitreader.start()
请求NSQ查找：
fromaionsqimportNSQLookuplookup=NSQLookup('http://120.0.0.1:4567')info=awaitlookup.info()
开始验证：
python -m aionsq.authd
欢迎加入QQ群-->： 979659372
