同一K8s Pod内FastAPI无法连接Redis问题求助

核心问题原因 #

同一个Pod内的容器共享网络命名空间，无需通过K8s Service访问，直接使用localhost即可互通；同时容器启动顺序无保证，FastAPI可能在Redis未就绪时发起连接导致失败。此外你配置的Redis Service因Selector不匹配，根本无法关联到目标Pod，导致通过服务名redis连接也失败。

解决方案1：修正Redis连接地址 #

将FastAPI的Redis连接目标改为localhost，兼容K8s Pod内网络环境，同时保留Docker Compose的兼容性：

步骤1：修改FastAPI代码，通过环境变量读取连接参数

# redis connection
redis_host = os.getenv("REDIS_HOST", "localhost")
redis_port = os.getenv("REDIS_PORT", 6379)
redis_client = aioredis.from_url(
    f"redis://{redis_host}:{redis_port}", encoding="utf-8", decode_responses=True)

步骤2：在K8s Deployment中配置环境变量

修改deployment.yaml中auth-service容器的配置，添加Redis相关环境变量：

- name: auth-service
  image: localhost:5000/auth-service:latest
  ports:
  - containerPort: 8000
  resources:
    limits:
      cpu: "1"
      memory: "1Gi"
    requests:
      cpu: "0.5"
      memory: "500Mi"
  envFrom:
    - secretRef:
        name: auth-service-fastapi-secrets
  # 添加以下环境变量
  env:
    - name: REDIS_HOST
      value: "localhost"
    - name: REDIS_PORT
      value: "6379"

解决方案2：添加Redis就绪探针，确保服务就绪 #

给Redis容器添加就绪探针，K8s会等待Redis完全启动后，才将Pod标记为就绪，避免FastAPI在Redis未就绪时发起连接：

- name: redis
  image: redis:alpine
  ports:
  - containerPort: 6379
  resources:
    limits:
      cpu: "1"
      memory: "1Gi"
    requests:
      cpu: "0.5"
      memory: "500Mi"
  # 添加就绪探针
  readinessProbe:
    exec:
      command:
        - redis-cli
        - ping
    initialDelaySeconds: 5
    periodSeconds: 5

解决方案3：清理无效的Redis Service #

当前Redis Service的Selector为app: redis，但Pod的Labels是app: auth-service，导致Service无法关联到Pod。由于Redis和FastAPI在同一个Pod内，该Service完全多余，直接删除即可；如果需要其他Pod访问此Redis，需将Service的Selector改为app: auth-service。

可选优化：添加连接重试逻辑 #

在FastAPI代码中添加Redis连接重试逻辑，避免单次连接失败导致服务无法恢复：

import asyncio

async def get_redis_client():
    redis_host = os.getenv("REDIS_HOST", "localhost")
    redis_port = os.getenv("REDIS_PORT", 6379)
    max_retries = 5
    retry_delay = 2
    for _ in range(max_retries):
        try:
            client = aioredis.from_url(
                f"redis://{redis_host}:{redis_port}", encoding="utf-8", decode_responses=True)
            await client.ping()
            return client
        except ConnectionError:
            await asyncio.sleep(retry_delay)
    raise ConnectionError("Failed to connect to Redis after multiple retries")

@app.on_event("startup")
async def startup_event():
    global redis_client
    redis_client = await get_redis_client()

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