🏗️ 系统架构

# 示例：用户注册事件
@event_handler("user.registered")
async def on_user_registered(event: UserRegisteredEvent):
    # 发送欢迎邮件
    await send_welcome_email(event.user_id)
    # 初始化用户配置
    await init_user_settings(event.user_id)

GET    /api/v1/users          # 获取用户列表
POST   /api/v1/users          # 创建用户
GET    /api/v1/users/{id}     # 获取特定用户
PUT    /api/v1/users/{id}     # 更新用户信息
DELETE /api/v1/users/{id}     # 删除用户

GET    /api/v1/chats          # 获取对话列表
POST   /api/v1/chats          # 创建新对话
GET    /api/v1/chats/{id}     # 获取对话详情
POST   /api/v1/chats/{id}/messages  # 发送消息

@router.post("/chats/{chat_id}/stream")
async def stream_chat(chat_id: int, message: MessageCreate):
    """流式对话 API"""
    async def generate():
        async for chunk in ai_service.stream_chat(chat_id, message):
            yield f"data: {json.dumps(chunk)}\n\n"
    
    return StreamingResponse(generate(), media_type="text/plain")

version: '3.8'
services:
  nginx:
    image: nginx:alpine
    ports: ["80:80", "443:443"]
    
  web:
    build: ./web
    environment:
      - NODE_ENV=production
      
  api:
    build: ./api
    environment:
      - ENV=production
      
  postgres:
    image: postgres:15
    volumes: ["./data/postgres:/var/lib/postgresql/data"]
    
  redis:
    image: redis:7-alpine
    volumes: ["./data/redis:/data"]

# 结构化日志示例
logger.info(
    "用户登录成功",
    extra={
        "user_id": user.id,
        "email": user.email,
        "ip_address": request.client.host,
        "user_agent": request.headers.get("user-agent")
    }
)