Installation

pip install rocketmq

Usage

Producer

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()

PushConsumer

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