我有一个包含 2 个复制节点的 AWS ElastiCache 实例(已禁用集群模式)。我可以使用 redisson(在同一集群中运行的服务)通过我的 java 客户端进行连接。但是,当我使用 python redis 客户端时,它似乎没有连接。或者它似乎连接但不订阅。我没有看到任何连接错误,但是当我订阅 pub/sub 主题时,我也没有得到任何确认。甚至没有1
为成功订阅返回的第一条消息。不知道我做错了什么。如果我连接到本地 redis 实例,它也可以工作。下面是代码:
self.redis_conn = redis.Redis(host=os.environ.get(host), port=6379, password=os.environ.get('REDIS_PASSWORD'))
self.pubsub = self.redis_conn.pubsub()
self.pubsub.subscribe('XYZ_EVENTS')
for new_message in self.pubsub.listen():
self._logger.info("received: " + str(new_message['data']))