a PIKA based, Cuter and more Human rabbitmq queue Utility (´_ゝ`)
Project description
PIKACHU
a PIKA based, Cuter and more Human rabbitmq queue Utility (´_ゝ`)
Simple to use
put a message into queue(independent by namespace):
import PIKACHU
PIKACHU.SimpleProducor("amqp://localhost").put(dict(data="some message"))
get some messages from queue:
for envelope in PIKACHU.SimpleConsumer("amqp://localhost").get():
print("get message:", envelope.message)
envelope.message_read()
use listener to listen message arrival constantly:
def callback(envelope):
print("get message:", envelope.message)
envelope.message_read()
consumer = PIKACHU.SimpleAsyncConsumer(settings.amqp)
ioloop = consumer.start_listen(callback)
ioloop.start()
installation
pip install git+https://github.com/smilefufu/PIKACHU@master
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
PI-KA-CHU-0.1.0.tar.gz
(5.6 kB
view hashes)
Built Distribution
Close
Hashes for PI_KA_CHU-0.1.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 26e24a462f33b39866720c9dfea32658345019ab161e45d4abdaa51a85146091 |
|
MD5 | d19dfe394fb6c9655b6c6d0c91ffe4ab |
|
BLAKE2b-256 | 8dcba0434691768862bdef8375d9e0cf9474019b0ce85cf88d0f4cb591c17e20 |