利用Python消費RocketMQ訊息佇列資料

1 安裝 rocketmq-python位址見：

pip install rocketmq

並不能直接使用rocketmq-python，需要先安裝 rocketmq-client-cpp 環境。

教程見：

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

執行示例**報錯：

from rocketmq.client import pullconsumer​​

consumer = pullconsumer('cid_***')
consumer.set_namesrv_domain('')
# 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('***', '***x', '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()

查證是動態庫錯誤，根據網上的解決方案：

先找到.so 檔案的路徑

find / -name librocketmq.so

sudo ldconfig

在python命令列輸入

from rocketmq.client import pullconsumer

鳴謝：

心得： 把報錯資訊直接複製到搜尋引擎，常常有驚喜。

Python指令碼消費kafka資料

一 簡介 詳見 二 安裝 詳見部落格 三 按照官網的樣例，先跑乙個應用 1 生產者 from kafka import kafkaproducer producer kafkaproducer bootstrap servers 172.21.10.136 9092 此處ip可以是多個 0.0.0....

Python指令碼消費kafka資料

一 簡介 詳見 二 安裝 詳見部落格 三 按照官網的樣例，先跑乙個應用 1 生產者 from kafka import kafkaproducer producer kafkaproducer bootstrap servers 172.21.10.136 9092 此處ip可以是多個 0.0.0....

python消費者問題（同步）

目錄 一 我一步你一步 二 我先走，你就不能比我腳先著地 加鎖 queue.task done 在完成一項工作之後，queue.task done 函式向任務已經完成的佇列傳送乙個訊號 queue.join 實際上意味著等到隊列為空，再執行別的操作 加了這倆兄弟就能做一碗吃一碗了 import th...