我想使用aioredis连接池，而不是在每个AsyncWebsocketConsumer.connect中创建新连接.我可以在哪里放置代码 [英] I want to use aioredis connection pool ,not create new connection in every AsyncWebsocketConsumer.connect .Where can I put the code

问题描述

我想使用aioredis连接池，而不是在每个AsyncWebsocketConsumer.connect中创建新连接.我可以在哪里放置代码.

I want to use aioredis connection pool ,not create new connection in every AsyncWebsocketConsumer.connect .Where can I put the code.

现在我每次都在connect事件中创建新的连接，像这样的代码

Now I create new connection in connect event every time, code like this

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_layer之类的东西，在每个使用者之间使用池连接.谢谢.

I need something like self.channel_layer ,using pool connection across every consumer. Thanks.

推荐答案

可能不是最好的解决方案，但您可以这样做

Probably not the best solution, but you can do this

您应用的 __ init __.py

from asgiref.sync import async_to_sync

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

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

Then in your consumer, you can import and use the existing redis connection

from . import redis

这篇关于我想使用aioredis连接池，而不是在每个AsyncWebsocketConsumer.connect中创建新连接.我可以在哪里放置代码的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！