问题描述
官方 Redis 文档说-“如上所述,Redis 集群的每个节点都会生成有关其自己的键空间子集的事件。但是,与集群中的常规 Pub/Sub 通信不同,事件的通知不会广播到所有节点。换句话说,keyspace 事件是特定于节点的。这意味着要接收集群的所有 keyspace 事件,客户端需要订阅每个节点。”
我使用了 redis-py-cluster 包并编写了以下代码:
def test_pub_sub():
pubsub = rs.pubsub()
#pubsub.subscribe('music')
pubsub.psubscribe('__key*__:*')
for message in pubsub.listen():
if message.get("type") == "message":
print(message.get("data"))
if __name__ == '__main__':
rs = RedisCluster(startup_nodes=startup_nodes,decode_responses=True)
test_pub_sub()
这是订阅集群中随机节点的通知。我想听所有节点。如何使用 redis-py-cluster 包实现此目的?
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)