Python客户端连接AWS ElastiCache无法完成Pub/Sub订阅问题咨询

1. 优先检查连接的ElastiCache端点类型 #

Redis的Pub/Sub消息是节点本地属性，不会通过主从复制同步到副本节点，存在以下场景会导致订阅无响应：

• 你Python代码中使用的是ElastiCache的只读端点/副本节点端点，而消息生产者将消息发送到了主节点，订阅副本节点无法收到任何消息
• Java服务的Redisson客户端默认配置了优先连接主节点，因此可以正常接收消息
  修复方案：将Python代码中的Redis连接地址改为ElastiCache复制组的主端点（Primary Endpoint），而非只读端点或单副本节点地址。

2. 检查传输加密配置 #

如果你的ElastiCache实例开启了「传输中加密（in-transit encryption）」，redis-py客户端默认不会开启SSL连接，会出现连接建立成功但所有命令无响应的现象，这和你描述的特征完全吻合：

• 本地Redis未开启加密，因此代码运行正常
• Redisson客户端已经主动配置了SSL参数，因此连接正常
  修复方案：在初始化Redis连接时新增ssl=True参数，代码修改如下：

self.redis_conn = redis.Redis(
    host=os.environ.get(host),
    port=6379,
    password=os.environ.get('REDIS_PASSWORD'),
    ssl=True  # 新增该行，开启SSL适配ElastiCache传输加密
)

3. 连接有效性验证 #

你可以先执行简单的读写命令验证连接有效性，排除连接层面的问题：

# 执行测试命令，确认连接正常且有响应
self.redis_conn.set("test_key", "test_val")
print(self.redis_conn.get("test_key"))

如果上述命令无返回或者报错，就可以确认是连接参数（SSL、端点地址）的问题。

4. 其他可能性排查 #

• 升级redis-py到最新稳定版：pip install --upgrade redis，避免老版本的已知Bug
• 确认订阅的主题名称大小写、特殊字符和发布端完全一致，Redis Pub/Sub主题名称是大小写敏感的
• 检查ElastiCache实例的安全组入站规则，确认你Python服务所在节点的IP已经开放6379端口的访问权限

内容的提问来源于stack exchange，提问作者shellHell