commit | d03ee08fec39362708fe24fc2edf0be66065805e | [log] [tgz] |
---|---|---|
author | Heng Du <duhengforever@apache.org> | Thu Oct 17 21:16:37 2019 +0800 |
committer | GitHub <noreply@github.com> | Thu Oct 17 21:16:37 2019 +0800 |
tree | 16743d573ba317deb240f97977f19241fc481b4d | |
parent | 9cc198fea0214e1989788f13378911add14a48df [diff] | |
parent | ee5e2d16e82a4dc7259f7b393e173e82ec8f397c [diff] |
Merge pull request #53 from messense/rocketmq-python-fix-ci Do not build librocketmq.so on CI
RocketMQ Python client, based on rocketmq-client-cpp, supports Linux and macOS
pip install rocketmq
from rocketmq.client import Producer, Message producer = 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()
import time from rocketmq.client import PushConsumer def callback(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() while True: time.sleep(3600) consumer.shutdown()
from rocketmq.client import PullConsumer consumer = 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() for msg in consumer.pull('YOUR-TOPIC'): print(msg.id, msg.body) consumer.shutdown()
This work is released under the MIT license. A copy of the license is provided in the LICENSE file.