我开始使用aioredis，但我无法使用aioredis创建一个Redis pubsub对象，尽管遵循文档中的方法。下面是我的代码： redis = await aioredis.create_redis(url, encoding="utf-8")await sub.subscribe(channel) 我得到了错误：AttributeError: 'Redis' object has no attribute 'pubsub' pyt
浏览 174提问于2021-06-29得票数 0
回答已采纳
2回答
我使用的是Tornado和aioredis。我想在aioredis.create_redis_pool类中测试我的tornado.testing.AsyncHTTPTestCase实例的一些tornado.testing.AsyncHTTPTestCase有没有办法在我的Tornado测试中模拟对临时Redis数据库的aioredis调用。 提前感谢
浏览 73提问于2019-01-09得票数 3
使用python 3.6.12和aioredis 2.0.0，异步3.4.3import asyncio print("Got Message:", msg)
pub = await aioredis.create_redis(
'redis:/&#x
浏览 6提问于2021-08-24得票数 6
回答已采纳
pip freeze的输出示例 aioredis @ file:///home/conda/feedstock_root/build_artifacts/aioredis_1591809643295/workfeedstock_root/build_artifacts/amqp_1591005859311/workasync-timeout==3.0.1
attrs==19.3.0 为什么aioredis</e
浏览 176提问于2020-07-12得票数 17
我以以下方式创建redis池： redis = aioredis.from_url
浏览 30提问于2022-06-24得票数 3
回答已采纳
1回答
为此，我使用了带有asyncio和aioredis的python。根据aioredis website的说法，我用以下方式实现了我的订阅： sub = await aioredis.create_redis(assert isinstance(ch1, aioredis.Channel)
async def async_reader
浏览 33提问于2019-02-15得票数 1
回答已采纳
1回答
等待协同程序与等待任务的区别
、、、、
#redis.py
import aioredis
redis = aioredis.from_url("redis://localhost") return value
redis = aioredis.from_url
浏览 2提问于2021-11-13得票数 1
1回答
我正在从__init__连接到aioredis (我不想把它移出去，因为这意味着我必须进行一些额外的重大更改)。如何在下面的task示例代码中等待aioredis连接task，并让它打印self.sub和self.pub对象？asyncio.gather是from addict import Dictimport aioredis
class S():("redis://c8:7070/0", password="
浏览 0提问于2020-03-05得票数 1
import asyncioasync def consume_a(): while True:名为"b“的使用者，订阅两个流
async def consume_b
浏览 12提问于2021-10-09得票数 0
这是我的websocket代码： import aiohttpimport aioredis
redis_pool = await aioredis.create_redis_pool
浏览 29提问于2020-03-24得票数 0
目前，我正在使用websockets来传递从Redis队列(pub/sub)接收的数据。但是由于某种原因，websocket在使用这个redis队列时不会发送消息。我的代码的工作原理是：
async def websocket_endpoint(websocket: WebSocket):
await websocket.
浏览 18提问于2022-05-10得票数 2
回答已采纳
redisS = await aioredis.create_connection(('localhost', 6379)) except: except aioredis.ChannelClosedError
浏览 3提问于2021-02-17得票数 0
4回答
("redis://localhost:8080") File "****site-packages\aioredis\pool.py", line 58, in_fill_free(override_min=False
浏览 9提问于2020-12-29得票数 0
我已经在django应用程序中集成了django通道和redis服务器，但是我正在运行django应用程序，我一直在获取以下打印信息
有人能帮助我如何禁用aioredis的连接调试打印，或者是什么原因，我得到这个打印。
浏览 2提问于2020-07-04得票数 0
我正在尝试使用python订阅redis中的keyspace事件。我希望在调用.psubscribe()之后不要使用.listen()的for循环。这个是可能的吗？ 我已经用KEA启用了所有的键空间事件。 def subscribe(self, key, handler):
def event_handler(msg):
print('Handler
浏览 72提问于2019-03-12得票数 9
1回答
我试图通过创建一个可以在aiohttp视图对象中使用的全局连接池对象来将aioredis与aiohttp结合使用。然而，load_redis函数出错了。我甚至不确定这是不是将aioredis与aiohttp结合使用的正确方式。import aiohttp_jinja2import aioredisREDIS_CONNECTION_POOL = None
async def load
浏览 55提问于2017-07-17得票数 1
回答已采纳
我想使用aioredis连接池，而不是在每个AsyncWebsocketConsumer.connect .Where中创建新的连接，我可以把代码放进去吗？现在我每次都在connect事件中创建新的连接，代码如下 async def connect(self):
self.redis = await aioredis.create_redis(
浏览 81提问于2019-05-15得票数 0
1回答
但现在我想用异步替代方案来代替它： db = await aioredis.create_connection((RedisConfig.REDIS_HOST
浏览 2提问于2020-08-20得票数 2
例如:我使用aioredis与Redis对话；但我不能在覆盖WebSocketCommonProtocol.connection_made()时使用aioredis。我能想到的唯一解决办法是在这个函数中使用同步库redis-py，但在其他地方使用aioredis。它是有效的，但是非常难看。
浏览 11提问于2018-08-10得票数 1
1回答
(**kwargs) File "D:\Web Development\DJANGO\Channels\venv\lib\site-packages\aioredis_fill_free(override_min=False)
File "D:\Web Development\
浏览 14提问于2022-05-07得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
