RocketMQ 的 Python 客户端 rocketmq-python

MIT
Python
跨平台
2019-06-02
messense
rocketmq-python 正在参加 2019 年度最受欢迎开源中国软件评选,请投票支持!
rocketmq-python 在 2019 年度最受欢迎开源中国软件评选 中已获得 {{ projectVoteCount }} 票,请投票支持!
投票赢奖品
已投票

rocketmq-python 是一个基于 rocketmq-client-cpp 封装的 RocketMQ Python 客户端。

示例代码:

Producer

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

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')
consumer.subscribe('YOUR-TOPIC', callback)
consumer.start()

while True:
    time.sleep(3600)

consumer.shutdown()

PullConsumer

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')
consumer.start()

for msg in consumer.pull('YOUR-TOPIC'):
    print(msg.id, msg.body)

consumer.shutdown()
的码云指数为
超过 的项目
加载中

评论(0)

暂无评论

暂无资讯

暂无问答

第三方推送方案选择

背景 第三方介入开放平台后,开放平台需要将设备状态、属性等值发给第三方,目前使用的方案是HTTP方式推送,但是由于数据量大,使用HTTP推送有很大的局限性; 经过评估,使用rocketmq可很好的...

11/12 15:21
13
0
阿里云消息队列RocketMQ使用示例

本文代码示例参见:https://gitee.com/imlichao/RocketMQ-example Apache RocketMQ文档:http://rocketmq.apache.org/docs/quick-start/ 阿里云RocketMQ文档:https://help.aliyun.com/produ...

05/09 16:08
1K
0
基于 RocketMQ 的同城双活架构在美菜网的挑战与实践

本文整理自李样兵在北京站 RocketMQ meetup分享美菜网使用 RocketMQ 过程中的一些心得和经验,偏重于实践。 嘉宾李样兵,现就职于美菜网基础服务平台组,负责 MQ ,配置中心和任务调度等基础...

09/16 14:41
11
0
基于 RocketMQ 的同城双活架构在美菜网的挑战与实践

本文整理自李样兵在北京站 RocketMQ meetup分享美菜网使用 RocketMQ 过程中的一些心得和经验,偏重于实践。 嘉宾李样兵,现就职于美菜网基础服务平台组,负责 MQ ,配置中心和任务调度等基础...

09/16 16:03
22
0
今日头条在消息服务平台和容灾体系建设方面的实践与思考

本篇文章整理自今日头条的沈辉在 RocketMQ 开发者沙龙中的演讲,主要和大家分享一下,RocketMQ 在微服务架构下的实践和容灾体系建设。沈辉是今日头条的架构师,主要负责 RocketMQ 在头条的落...

11/12 15:35
10
0
RocketMQ原理学习--索引

1、RocketMQ原理学习--RocketMQ源码运行 2、RocketMQ原理学习--RocketMQ整体架构窥探 3、RocketMQ原理学习--消息类型 4、RocketMQ原理学习-- Name Server 5、RocketMQ原理学习---生产者普通消...

02/22 16:28
40
0
Install rocketMQ in 2ms-noslave mode step by step

#Install rocketMQ in 2ms-noslave mode ##Two linux hosts: 192.168.11.60 192.168.11.91 ##1.download rocket mq from apache official site wget http://apache.01link.hk/rocketmq/4.2.0...

2018/12/17 15:56
18
0
rocketmq源码解析合集

rocketmq源码解析之NamesrvController创建 rocketmq源码解析之NamesrvController启动① rocketmq源码解析之NamesrvController启动②创建mqclient① rocketmq源码解析之NamesrvController启动...

08/24 13:01
113
0

没有更多内容

加载失败,请刷新页面

返回顶部
顶部