rocketmq python客户端
rocketmq的Python项目详细描述
RocketMQPython
rocketmq python客户端
安装
pip install rocketmq
用法
生产者
fromrocketmq.clientimportProducer,Messageproducer=Producer('PID-XXX')producer.set_namesrv_domain('http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet')# For ip and port name server address, use `set_namesrv_addr` method, for example:# producer.set_namesrv_addr('127.0.0.1:9887')producer.set_session_credentials('XXX','XXXX','ALIYUN')# No need to call this function if you don't use Aliyun.producer.start()msg=Message('YOUR-TOPIC')msg.set_keys('XXX')msg.set_tags('XXX')msg.set_body('XXXX')ret=producer.send_sync(msg)print(ret.status,ret.msg_id,ret.offset)producer.shutdown()
推送消费者
importtimefromrocketmq.clientimportPushConsumerdefcallback(msg):print(msg.id,msg.body)consumer=PushConsumer('CID_XXX')consumer.set_namesrv_domain('http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet')# For ip and port name server address, use `set_namesrv_addr` method, for example:# consumer.set_namesrv_addr('127.0.0.1:9887')consumer.set_session_credentials('XXX','XXXX','ALIYUN')# No need to call this function if you don't use Aliyun.consumer.subscribe('YOUR-TOPIC',callback)consumer.start()whileTrue:time.sleep(3600)consumer.shutdown()
pullconsumer
fromrocketmq.clientimportPullConsumerconsumer=PullConsumer('CID_XXX')consumer.set_namesrv_domain('http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet')# For ip and port name server address, use `set_namesrv_addr` method, for example:# consumer.set_namesrv_addr('127.0.0.1:9887')consumer.set_session_credentials('XXX','XXXX','ALIYUN')# No need to call this function if you don't use Aliyun.consumer.start()formsginconsumer.pull('YOUR-TOPIC'):print(msg.id,msg.body)consumer.shutdown()
许可证
这项工作是在麻省理工学院的许可下发布的。许可证的副本在LICENSE文件中提供。
欢迎加入QQ群-->： 979659372
