I am wanting to use Redis queues to store updates that are sent to the Websocket, so that disconnected players (offline) who become reconnected can then be sent the queued messages. I am using the free Upstash redis db, doing a test run in a view shows that the connection and commands work. However inside my consumer 'def connect(self):', I am able to connect but then the redis server immediately closes the connection. Why is it working inside my view but not inside the AsyncWebsocketConsumer?

Some variations I have tried:
1. Creating redis instance globally at top of file rather than in the connect method
2. from upstash_redis import Redis
3. Synchronous redis call instead of redis.asyncio

poetry run daphne -b 0.0.0.0 -p 8000 app.asgi:application


# /consumers.py
import redis.asyncio as redis

class TaskUpdatesConsumer(AsyncWebsocketConsumer):
    async def connect(self):
        self.r = redis.StrictRedis(
            host=os.getenv("REDIS_HOST"),
            port=os.getenv("REDIS_PORT"),
            password=os.getenv("REDIS_PASSWORD"),
            ssl=True,
            decode_responses=True,
        )
        print("UPSTASH REDIS = ", await self.r.ping()) 

These are the logs from Upstash

14:19:33.183    [0 89.205.129.243:4884] AUTH    "(redacted)"

14:19:33.268    [0 89.205.129.243:4884] PING

And these are the logs from Daphne server

127.0.0.1:56715 - - [17/Mar/2025:13:19:32] "WSCONNECTING /game_updates/53/19/" - -
UPSTASH REDIS =  True
2025-03-17 13:19:32,833 ERROR    Exception inside application: Connection closed by server.
Traceback (most recent call last):
  File "/home/keisler/.cache/pypoetry/virtualenvs/backend-0Uga-fli-py3.11/lib/python3.11/site-packages/channels/routing.py", line 48, in __call__
    return await application(scope, receive, send)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/home/keisler/.cache/pypoetry/virtualenvs/backend-0Uga-fli-py3.11/lib/python3.11/site-packages/channels/routing.py", line 118, in __call__
    return await application(
           ^^^^^^^^^^^^^^^^^^
  File "/home/keisler/.cache/pypoetry/virtualenvs/backend-0Uga-fli-py3.11/lib/python3.11/site-packages/channels/consumer.py", line 95, in app
    return await consumer(scope, receive, send)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/home/keisler/.cache/pypoetry/virtualenvs/backend-0Uga-fli-py3.11/lib/python3.11/site-packages/channels/consumer.py", line 58, in __call__
    await await_many_dispatch(
  File "/home/keisler/.cache/pypoetry/virtualenvs/backend-0Uga-fli-py3.11/lib/python3.11/site-packages/channels/utils.py", line 57, in await_many_dispatch
    await task
redis.exceptions.ConnectionError: Connection closed by server.