dock

dock

Wrapper around Redis for message queues.

Installation

pip install dock  # pypi
pip install git+https://github.com/vzhong/dock.git  # github

Usage

First, start your Redis server.

# server.py
from dock import Dock
dock = Dock('test')

while True:
    msg, respond = dock.recv()
    print(msg, respond)
    print('got message {}'.format(msg))
    respond({
      'ack': msg,
      'msg': 'hello'
    })

# client.py
from dock import Dock
dock = Dock('test')

for i in range(5):
    answer = dock.send('message{}'.format(i))
    print(answer)

You can see how the server and client interact by running the two files:

python server.py  # in one terminal
python client.py  # in another terminal