我想使用aioredis连接池,而不是在每个As中创建新连接yncWebsocketConsumer.connect连接我可以把鳕鱼放在哪里

2024-06-16 03:10:46 发布

您现在位置:Python中文网/ 问答频道 /正文

我想使用aioredis连接池,而不是在每个As中创建新连接yncWebsocketConsumer.connect连接。我可以把密码放在哪里。你知道吗

现在我每次都在connect事件中创建新连接,代码如下

async def connect(self):
    self.redis = await aioredis.create_redis(
            'redis://localhost',encoding='utf-8')
async def disconnect(self, close_code):
    await self.redis.close()

我需要这样的东西self.channel\u层,在每个使用者之间使用池连接。 谢谢。你知道吗


Tags: 代码selfredislocalhost密码closeasyncdef
1条回答
网友
1楼 · 发布于 2024-06-16 03:10:46

也许不是最好的解决办法,但你可以做到

你的应用程序__init__.py

from asgiref.sync import async_to_sync

redis = async_to_sync(aioredis.create_redis)('redis://localhost',encoding='utf-8')

然后在您的使用者中,您可以导入并使用现有的redis连接

from . import redis

相关问题 更多 >