gredis

gRedis is an asynchronous client library of Redis written with Tornado coroutine.

gRedis is standing on the shoulders of giants:

• redis-py
• Tornado

Installation

pip install gredis

OR

easy_install gredis

OR

git clone https://github.com/coldnight/gredis
cd gredis
python setup.py install

Usage

from tornado import gen
from tornado import web
from gredis.client import AsyncRedis

client = AsyncRedis("ip.or.host", 6379)

class DemoHandler(web.RequestHandler):

    @gen.coroutine
    def get(self):
        ret = yield client.incr("key")
        redis = client.to_blocking_client()
        ret2 = redis.incr("key")
        self.write(str(ret + ret2))

Pub/Sub

from tornado import gen
from tornado import web
from gredis.client import AsyncRedis

client = AsyncRedis("ip.or.host", 6379)

class PubSubHandler(web.RequestHandler):

    @gen.coroutine
    def get(self):
        pubsub = client.pubsub()
        channel = "test"
        yield pubsub.subscribe(channel)
        response = yield pubsub.get_message(True)
        assert response["type"] == "subscribe"
        response = yield pubsub.get_message(True)
        assert response["type"] == "message"
        self.write(response['data'])

    @gen.coroutine
    def post(self):
        yield client.publish(channel, "test")

Not Implementation

• pipeline