RocketMQ Python客户端
rocketmq-client-python的Python项目详细描述
rocketmq客户端python
RocketMQ Python客户端基于rocketmq-client-cpp，支持Linux和macOS
安装
pip install rocketmq-client-python
使用
生产商
^{pr2}$推动消费者
importtimefromrocketmq.clientimportPushConsumerdefcallback(msg):print(msg.id,msg.body)consumer=PushConsumer('CID_XXX')consumer.set_name_server_address('127.0.0.1:9876')consumer.subscribe('YOUR-TOPIC',callback)consumer.start()whileTrue:time.sleep(3600)consumer.shutdown()
许可证
Apache License, Version 2.0版权所有（C）Apache Software Foundation
- 项目
标签：
欢迎加入QQ群-->： 979659372
