Need help with rocketmq-client-python?
Click the “chat” button below for chat support from the developer who created it, or find similar developers for support.

About the developer

apache
144 Stars 69 Forks Apache License 2.0 321 Commits 8 Opened issues

Description

Apache RocketMQ python client

Services available

!
?

Need anything else?

Contributors list

rocketmq-client-python

License Build Status codecov PyPI GitHub release Average time to resolve an issue Percentage of issues still open Twitter Follow

RocketMQ Python client, based on rocketmq-client-cpp, supports Linux and macOS

Prerequisites

Install
librocketmq

rocketmq-client-python is a lightweight wrapper around rocketmq-client-cpp, so you need install

librocketmq
first.

Download by binary release.

download specific release according you OS: rocketmq-client-cpp-2.0.0 - centos

take centos7 as example, you can install the library in centos6 by the same method.
```bash
    wget https://github.com/apache/rocketmq-client-cpp/releases/download/2.0.0/rocketmq-client-cpp-2.0.0-centos7.x86_64.rpm
    sudo rpm -ivh rocketmq-client-cpp-2.0.0-centos7.x86_64.rpm
```
  • debian
    bash
        wget https://github.com/apache/rocketmq-client-cpp/releases/download/2.0.0/rocketmq-client-cpp-2.0.0.amd64.deb
        sudo dpkg -i rocketmq-client-cpp-2.0.0.amd64.deb
    
  • macOS
    bash
        wget https://github.com/apache/rocketmq-client-cpp/releases/download/2.0.0/rocketmq-client-cpp-2.0.0-bin-release.darwin.tar.gz
        tar -xzf rocketmq-client-cpp-2.0.0-bin-release.darwin.tar.gz
        cd rocketmq-client-cpp
        mkdir /usr/local/include/rocketmq
        cp include/* /usr/local/include/rocketmq
        cp lib/* /usr/local/lib
        install_name_tool -id "@rpath/librocketmq.dylib" /usr/local/lib/librocketmq.dylib
    
    #### Build from source you can also build it manually from source according to Build and Install

Installation

pip install rocketmq-client-python

Usage

Producer

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

PushConsumer

import time

from rocketmq.client import PushConsumer, ConsumeStatus

def callback(msg): print(msg.id, msg.body) return ConsumeStatus.CONSUME_SUCCESS

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

License

Apache License, Version 2.0 Copyright (C) Apache Software Foundation

We use cookies. If you continue to browse the site, you agree to the use of cookies. For more information on our use of cookies please see our Privacy Policy.