Redis clustering with Python:StirctRedisClusterpubsub.订阅给了凯伊

2024-10-03 04:34:58 发布

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

我一直在尝试用pythonwepapp配置Redis集群(目前使用的是单个Redis实例)

由于3.x版本支持redis集群,因此将redis服务器版本升级到3.0.7

在我的python应用程序中使用redis-py-clusterV1.2.0模块。在

发布和订阅特定通道的PubSub命令似乎无法处理下面在堆栈跟踪中提到的KeyError。如果有人能帮忙就好了。在

from rediscluster import StrictRedisCluster
startup_nodes = [{"host": "127.0.0.1", "port": "6379"}]
redis_conn = StrictRedisCluster(startup_nodes=startup_nodes,  
             decode_responses=True)
redis_conn.pubsub()
pubsub.subscribe(['a_b:c:d']) //tried with diff keys, getting the same error

错误的堆栈跟踪:

^{pr2}$

当我调试时self.nodes.slots[]似乎是空的。不知道我为什么会犯这个错误。在

提前谢谢 普里亚


Tags: 实例版本服务器redis堆栈错误集群conn