| commit | 439dff5b03d3819c0ab19b2b8189a4e4bd67fd2c | [log] [tgz] |
|---|---|---|
| author | ShannonDing <libya_003@163.com> | Thu Nov 21 21:21:36 2019 +0800 |
| committer | ShannonDing <libya_003@163.com> | Thu Nov 21 21:21:36 2019 +0800 |
| tree | 064a948164206963a2a90e7f86e03c22b636bf16 | |
| parent | 08bc79c9fcd1c851433f6ad4fd44abac00c0d1ba [diff] | |
| parent | bf88e10c3bdabc8b8d91e4452d78a3d56685f719 [diff] |
feat(platforms): switch branch ctypes to master to support both python2.x and python 3.x
RocketMQ Python client, based on rocketmq-client-cpp, supports Linux and macOS
pip install rocketmq-client-python
from rocketmq.client import Producer, Message producer = Producer('PID-XXX') producer.set_name_server_address('127.0.0.1:9876') 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_name_server_address('127.0.0.1:9876') consumer.subscribe('YOUR-TOPIC', callback) consumer.start() while True: time.sleep(3600) consumer.shutdown()
Apache License, Version 2.0 Copyright (C) Apache Software Foundation