RocketMQ Python client

These details have not been verified by PyPI

Project description

rocketmq-python

RocketMQ Python client

Installation

pip install rocketmq

Usage

Producer

from rocketmq.client import Producer, Message

producer = Producer('PID-XXX')
producer.set_namesrv_domain('http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet')
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')
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')
consumer.set_session_credentials('XXX', 'XXXX', 'ALIYUN')
consumer.start()

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

consumer.shutdown()

License

This work is released under the MIT license. A copy of the license is provided in the LICENSE file.

Project details

These details have not been verified by PyPI

Release history Release notifications | RSS feed

0.4.4

Nov 22, 2019

0.4.3

Aug 28, 2019

0.4.2

Aug 26, 2019

0.4.1

Aug 21, 2019

0.4.0

Aug 20, 2019

0.3.15

Aug 12, 2019

0.3.14

May 10, 2019

0.3.13

May 8, 2019

0.3.12

Apr 17, 2019

0.3.11

Apr 3, 2019

0.3.10

Mar 20, 2019

0.3.9

Mar 13, 2019

0.3.8

Mar 13, 2019

0.3.7

Feb 19, 2019

0.3.6

Feb 13, 2019

This version

0.3.5

Feb 13, 2019

0.3.4

Jan 23, 2019

0.3.3

Jan 9, 2019

0.3.2

Jan 8, 2019

0.3.1

Jan 7, 2019

0.3.0

Jan 6, 2019

0.2.3

Jan 6, 2019

0.2.2

Jan 5, 2019

0.2.1

Jan 4, 2019

0.2.0

Jan 4, 2019

0.1.1

Jan 3, 2019

0.1.0

Jan 3, 2019

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

rocketmq-0.3.5.tar.gz (1.0 MB view details)

Uploaded Feb 13, 2019 Source

Built Distribution

rocketmq-0.3.5-py2.py3-none-macosx_10_13_x86_64.whl (1.0 MB view details)

Uploaded Feb 13, 2019 Python 2 Python 3 macOS 10.13+ x86-64

File details

Details for the file rocketmq-0.3.5.tar.gz.

File metadata

Download URL: rocketmq-0.3.5.tar.gz
Upload date: Feb 13, 2019
Size: 1.0 MB
Tags: Source
Uploaded using Trusted Publishing? No
Uploaded via: twine/1.12.1 pkginfo/1.5.0.1 requests/2.21.0 setuptools/40.8.0 requests-toolbelt/0.9.1 tqdm/4.31.1 CPython/2.7.15

File hashes

Hashes for rocketmq-0.3.5.tar.gz
Algorithm	Hash digest
SHA256	`4c891d8912e9c636304301f3c71389e40c2d2d63f26df886f9acc00bda71a6d5`
MD5	`cd7153074396dc21f85a34f8078b557f`
BLAKE2b-256	`6fc58b90173b6f455ee3e6b3cb2f7bfd20fee15531cdaf92aec1118c42f4b90c`

See more details on using hashes here.

File details

Details for the file rocketmq-0.3.5-py2.py3-none-macosx_10_13_x86_64.whl.

File metadata

Download URL: rocketmq-0.3.5-py2.py3-none-macosx_10_13_x86_64.whl
Upload date: Feb 13, 2019
Size: 1.0 MB
Tags: Python 2, Python 3, macOS 10.13+ x86-64
Uploaded using Trusted Publishing? No
Uploaded via: twine/1.12.1 pkginfo/1.5.0.1 requests/2.21.0 setuptools/40.8.0 requests-toolbelt/0.9.1 tqdm/4.31.1 CPython/2.7.15

File hashes

Hashes for rocketmq-0.3.5-py2.py3-none-macosx_10_13_x86_64.whl
Algorithm	Hash digest
SHA256	`ad1c0dad5c5e3131997f61304b81c943094fc17c4fd4a94b08659fe4923a5f18`
MD5	`0b2454cd4601f82fbc407c85ef98deed`
BLAKE2b-256	`ff54592a1f15cba1f40e4dd15c35c81024fc612b0a47dc29df655318dcdcdb56`