channels_redis
channels_redis copied to clipboard
Redis channel layer backend for Django Channels
When using RedisChannelLayer, if multiple redis hosts are set in CONFIG, some messages from outside of consumer will not be received. Use **send** method, not **group_send**. - django 3.0.9 -...
Running on the latest versions of the channels packages: ``` /srv/venv/bin/pip freeze asgiref==3.2.10 ... channels==2.4.0 channels-redis==3.0.1 ... daphne==2.5.0 ... Django==3.0.3 ``` I started noticing that when I sent certain messages...
Right now, the tests only cover single-host mode; it would be nice to have proper tests for sharded mode as it's the easiest one to get wrong.
https://github.com/django/channels_redis/blob/0c27648b60a1918c867b96a5ad3f67ef58ccceda/channels_redis/core.py#L105 In the implementation of this method, it's annotation says "Close all connections owned by the pool on the given loop" and the method body is: ``` async def close_loop(self,...
I am currently debugging the following situation, for which I have not been able to create a reproducible situation in a testing environment, mostly due to time contraints. I am...
Hello, we are using group to send notifications from channels worker process to the websocket consumer in the server process. There is exactly one worker in the group and exactly...
ASGI Channels for the same `RedisChannelLayer` instance (https://github.com/django/channels_redis/blob/54d935beb6842333ba4f3e6c29cbe86c4307cf16/channels_redis/core.py#L239) are factorized into one redis queue (also sometimes called a channel, which is confusing). The ASGI channels capacity is check against the...
After upgrading to `channels-redis==4.0.0`, our celery tasks are all reporting the following traceback: ``` future: Traceback (most recent call last): File "/usr/local/lib/python3.9/site-packages/redis/asyncio/connection.py", line 828, in disconnect self._writer.close() # type: ignore[union-attr]...
Just upgraded my project to 4.0.0b1 (with also updating channels/daphne/etc) and started to get this error after doing a `layer.group_send` inside a django ASGI view (i.e. not a channels consumer):...
What is the right way to specify `connection_kwargs`? Based on the changelog - it was implemented a while ago, but there are no examples on how to set that and...