0

我有一个包含 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']))
4

1 回答 1

0

必须设置 ssl=True 并且做到了。Elasticache 实例已启用加密,因此必须将此配置设置为 true。

于 2021-08-22T21:11:05.627 回答