tornado-redis
tornado-redis copied to clipboard
leporo
Asynchronous Redis client that works within Tornado IO loop.
The current code will yield at different points thus allowing for multiple commands to be inserted and expecting results. The following code only allows one command at a time to...
I try to debug a tornadoredis Client connection and try to get some values I'm using redis 2.8 and redis 3.0.2 ``` c = Client(...) c.connect() c.get('asd') c.set('asd','asd') c.get('asd') ```...
Hi @leporo I set redis `requirepass xxxxx`, and use tornado-redis like: ``` python self.conn = tornadoredis.Client(host='127.0.0.1', port=6379, password='xxxxx', selected_db=15) ``` Most of the time, it's ok, but occasionally, auth failed...
If I make a query to redis that needs to open a connection, and that connection blocks (eg. slow network, network partition), then the whole tornado process blocks. No requests...
We fell into a trap when using the unsubscribe, the callback does not trigger when the subscription listen loop has been exited or is not running yet. So if an...
Issue: Tornado server no longer responds to HTTP requests. Backtracking: Debugged the Tornado process with gdb. Managed to backtrace the code to a mutex deadlock in IOLoop's addCallback. It happens...
See: http://redis.io/commands/pubsub In my use case I would use it to count the number of active connections to a channel ``` PUBSUB NUMSUB $channels ```
When trying to retrieve a binary value (e.g. an image) an UnicodeDecodeError raises as it tries to decode the response to utf-8. While debugging I've noticed a couple of things:...
Hello! Consider this test case: ``` python class SequentialPubSubTestCase(RedisTestCase): def setUp(self): super(SequentialPubSubTestCase, self).setUp() self.subscriber = self._new_client() def tearDown(self): try: self.subscriber.connection.disconnect() del self.subscriber except AttributeError: pass super(SequentialPubSubTestCase, self).tearDown() @async_test @gen.engine def...
If the redis server goes down and comes back up, there is no subscription to redis, however the SockJSSubscriber still retains the list of subscribers. These subscribers will never receive...
