tornado-redis
tornado-redis copied to clipboard
leporo
Asynchronous Redis client that works within Tornado IO loop.
 
In tornado.BaseStream.__init__, The `io_loop` argument (deprecated since version 4.1) has been removed. Signed-off-by: corvofeng
I have a stackoverflow question [here](https://stackoverflow.com/questions/47496922/tornado-redis-garantee-order-of-published-messages). Is it possible to consume redis messages within same order as they were published? E.g. see code below: ``` def __init__(self): self.async_redis_publisher = tornadoredis.Client(port=TORNADO_REDIS_PORT)...
I try to use sscan, but it already return None, my python version is 3.6 ``` c=tornadoredis.Client(host='localhost', port=6379) c.connect() c.sadd("testset", "additional") y=c.sscan("testset", 0) ``` when I try to print y,...
I have an error: ``` tornadoredis.exceptions.ResponseError: ResponseError (on SMEMBERS [('user_id:12345',), {}]): Unknown response type c ``` What does it mean and how to fix that? Thanks!
Reverted where the code was attempting to unicode encode a value pulled from redis. The to_unicode would cause an exception to be thrown if there was a multibulk reply (eg....
When tornado-redis used as a shared client, it will sometimes crash in `process_data` Test code ``` from tornado.ioloop import IOLoop from tornado.web import RequestHandler, Application, url, asynchronous from tornado.gen import...
Fault condition: in tornado-redis/demos/websockets/app.py, I hope to sub more than one channels. yield tornado.gen.Task(self.client.subscribe, 'test_channel1,test_channel2'). But, when I run the app.py, subscribe method is provided by tornadoredis/client.py. 1036 if isinstance(channels,...
Has this project been abandoned? There are many open issues and unmerged pull-requests. The last activity of the owner @leporo was a year ago. Anyone has news of him?
