马耳他全民 ChatGPT Plus：当 AI 变成国家基础设施，开发者该关注什么

# org_ai_gateway.py — 组织级 AI 能力分发网关示例
# 运行前：pip install fastapi uvicorn openai pydantic

import time
from fastapi import FastAPI, HTTPException, Header, Depends
from pydantic import BaseModel
from openai import OpenAI
from collections import defaultdict

app = FastAPI(title="Org AI Gateway")
client = OpenAI()  # 从环境变量 OPENAI_API_KEY 读取

# ── 配额管理 ──────────────────────────────────
QUOTA_LIMIT = 80       # 每 3 小时每人上限（与 Plus 对齐）
QUOTA_WINDOW = 10800   # 3 小时 = 10800 秒
user_usage: dict[str, list[float]] = defaultdict(list)

def check_quota(user_id: str):
    now = time.time()
    # 清理过期记录
    user_usage[user_id] = [
        t for t in user_usage[user_id] if now - t < QUOTA_WINDOW
    ]
    if len(user_usage[user_id]) >= QUOTA_LIMIT:
        raise HTTPException(429, "本时段配额已用尽，请稍后再试")
    user_usage[user_id].append(now)

# ── 身份验证（简化版，实际应对接 OAuth / eID）─────
ALLOWED_USERS = {"citizen_001": "马耳他公民A", "citizen_002": "马耳他公民B"}

def verify_user(x_user_id: str = Header(...)):
    if x_user_id not in ALLOWED_USERS:
        raise HTTPException(403, "非授权用户")
    check_quota(x_user_id)
    return x_user_id

# ── 请求模型 ──────────────────────────────────
class ChatRequest(BaseModel):
    message: str
    model: str = "gpt-4o"  # 默认 Plus 级别模型
    max_tokens: int = 1024

@app.post("/v1/chat")
def chat(req: ChatRequest, user_id: str = Depends(verify_user)):
    """代理转发到 OpenAI，附带审计日志"""
    try:
        response = client.chat.completions.create(
            model=req.model,
            messages=[{"role": "user", "content": req.message}],
            max_tokens=req.max_tokens,
        )
        # 审计日志（实际应写入持久化存储）
        print(f"[AUDIT] user={user_id} model={req.model} tokens={response.usage.total_tokens}")
        return {
            "reply": response.choices[0].message.content,
            "tokens_used": response.usage.total_tokens,
        }
    except Exception as e:
        raise HTTPException(502, f"上游服务异常: {e}")

# ── 启动 ──────────────────────────────────────
if __name__ == "__main__":
    import uvicorn
    uvicorn.run(app, host="0.0.0.0", port=8000)

# 设置 API Key
export OPENAI_API_KEY="sk-your-key-here"

# 启动网关
python org_ai_gateway.py

# 模拟公民请求
curl -X POST http://localhost:8000/v1/chat \
  -H "Content-Type: application/json" \
  -H "X-User-Id: citizen_001" \
  -d '{"message": "用 Python 计算斐波那契数列前 20 项", "model": "gpt-4o"}'