从 AWS Lambda 迁移到 Knative

路线一：Lambda API 型应用迁移到 Knative Serving

适用于原本由 API Gateway 触发的 Lambda，例如 Webhook、REST API、轻量推理接口、后端微服务接口等。核心思路是将 Lambda Handler 改造为 HTTP 服务并打包为容器镜像，随后将其部署到 Knative Service，进而利用 Knative 提供的域名、Ingress 及流量管理能力对外统一提供服务。

路线二：事件驱动型 Lambda 迁移到 Knative Eventing

适用于由以下事件触发的函数：对象存储事件、消息队列事件、发布订阅事件、定时任务、数据流事件等。这种场景需要根据目标架构，选择使用 Knative Eventing 的 Broker/Trigger 模型。

场景一：API Gateway + Lambda → Knative Service

迁移前：Client → API Gateway → Lambda
迁移后：Client → Ingress/Gateway → Knative Service

场景二：S3/SNS/SQS 触发 Lambda → 对象事件/消息系统 + Knative

迁移前：S3/SNS/SQS → Lambda
迁移后：Object Storage / Message Queue / Event Bus → Knative Eventing → Knative Service

或：

Queue/Topic → Consumer Container → Knative Service

场景三：EventBridge 定时任务 → CronJob / Eventing

迁移前：EventBridge Schedule → Lambda
迁移后：CronJob / Event Source / EventBridge Schedule → Knative Service

从 Lambda Handler 改为 HTTP 入口

Lambda 中最常见的代码形态如下（Python Lambda 示例）：

def handler(event, context):
    name = event.get("queryStringParameters", {}).get("name", "world")
    return {
        "statusCode": 200,
        "body": f"Hello, {name}"
    }

迁移到 Knative 后，推荐改造成标准 Web 服务（Python Flask 示例）：

from flask import Flask, request

app = Flask(__name__)

@app.route("/", methods=["GET"])
def hello():
    name = request.args.get("name", "world")
    return f"Hello, {name}", 200

if __name__ == "__main__":
    app.run(host="0.0.0.0", port=8080)

打包为容器镜像

创建 Dockerfile：

FROM python:3.11-slim

WORKDIR /app
COPY requirements.txt .
RUN pip install --no-cache-dir -r requirements.txt

COPY app.py .
ENV PORT=8080
CMD ["python", "app.py"]

创建 requirements.txt：

flask==3.0.0

containerConcurrency

可通过以下方式设置containerConcurrency字段，以控制单实例可承载的并发数：

spec:
  template:
    spec:
      containerConcurrency: 10

建议根据实际情形合理设置并发数：

• 低并发：更稳定，适合 CPU 密集型任务

• 高并发：实例更少，成本更优，但需评估应用线程安全与资源瓶颈

最小副本

如果对冷启动敏感，可通过以下方式设置 min-scale字段，以控制最小副本数：

metadata:
  annotations:
    autoscaling.knative.dev/min-scale: "1"

最大副本

为防止流量突增导致资源失控，可通过以下方式设置max-scale字段，以控制最大副本数：

metadata:
  annotations:
    autoscaling.knative.dev/max-scale: "50"

资源请求与限制

可通过以下方式设置resources字段，以合理分配 CPU 和内存资源：

resources:
  requests:
    cpu: "500m"
    memory: "512Mi"
  limits:
    cpu: "1"
    memory: "1Gi"

灰度发布示例

apiVersion: serving.knative.dev/v1
kind: Service
metadata:
  name: hello-service
spec:
  traffic:
  - revisionName: hello-service-v1
    percent: 90
  - revisionName: hello-service-v2
    percent: 10
  template:
    metadata:
      name: hello-service-v2
    spec:
      containers:
      - image: registry.example.com/hello:2.0.0

这使您可以：

• 小流量验证迁移版本

• 快速回滚

• 对比新旧版本表现

推荐切换步骤

1. 在 Knative 上部署新版本。

2. 使用测试域名验证功能。

3. 小流量灰度导入。

4. 验证日志、延迟、错误率。

5. 全量切换。

6. 保留 Lambda 一段时间作为回退方案。