利用Python消费RocketMQ消息队列数据

• 语言:python3.6
• 环境:centos 7

1 安装 rocketmq-python 地址见：https://pypi.org/project/rocketmq/

pip install rocketmq

2 安装rocketmq-client-cpp 环境 

并不能直接使用rocketmq-python，需要先安装 rocketmq-client-cpp 环境。

教程见：https://github.com/apache/rocketmq-client-python

步骤： 下载对应版本，安装。

 sudo rpm -ivh rocketmq-client-cpp-2.0.0-centos7.x86_64.rpm

3 建立软链接

运行示例代码报错：

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

OSError: librocketmq.so: cannot open shared object file: No such file or dir

查证是动态库错误，根据网上的解决方案：

先找到.so 文件的路径

find / -name librocketmq.so

再执行

ln -s 前面的路径地址/librocketmq.so /usr/lib
sudo ldconfig

在Python命令行输入

from rocketmq.client import PullConsumer

不报错，则成功，可以根据示例代码拉取数据了。

 

鸣谢：

https://blog.csdn.net/weixin_39586584/article/details/107185329?utm_medium=distribute.pc_relevant.none-task-blog-title-2&spm=1001.2101.3001.4242

https://blog.csdn.net/hhhuua/article/details/80705655

 

心得： 把报错信息直接复制到搜索引擎，常常有惊喜。