gredis
gRedis is an asynchronous client library of Redis written with Tornado coroutine.
gRedis is standing on the shoulders of giants:
Installation
pip install gredisOR
easy_install gredisOR
git clone https://github.com/coldnight/gredis
cd gredis
python setup.py installUsage
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
