Knative Serverless实践：构建事件驱动的无服务器应用

一、Knative概述

Knative是一个开源的Serverless平台，构建在Kubernetes之上，提供自动扩缩容、事件驱动和请求驱动的服务部署能力。Knative包含两个核心组件：

• Serving：提供无状态服务的部署和自动扩缩容
• Eventing：提供事件驱动的消息传递和处理

Knative的核心特性：

• 自动扩缩容：支持从0到N的自动扩缩容
• 请求驱动：根据请求量自动调整实例数
• 事件驱动：支持多种事件源和事件处理
• 流量管理：支持蓝绿部署和金丝雀发布
• 平台无关：可以运行在任何Kubernetes集群上

二、Knative安装与配置

2.1 安装Knative Serving

# 安装Knative Serving CRD
kubectl apply -f https://github.com/knative/serving/releases/download/knative-v1.10.0/serving-crds.yaml

# 安装Knative Serving核心组件
kubectl apply -f https://github.com/knative/serving/releases/download/knative-v1.10.0/serving-core.yaml

# 安装Istio作为网络层
kubectl apply -l knative.dev/crd-install=true -f https://github.com/knative/net-istio/releases/download/knative-v1.10.0/net-istio.yaml
kubectl apply -f https://github.com/knative/net-istio/releases/download/knative-v1.10.0/net-istio.yaml

2.2 安装Knative Eventing

# 安装Knative Eventing CRD
kubectl apply -f https://github.com/knative/eventing/releases/download/knative-v1.10.0/eventing-crds.yaml

# 安装Knative Eventing核心组件
kubectl apply -f https://github.com/knative/eventing/releases/download/knative-v1.10.0/eventing-core.yaml

# 安装默认事件通道
kubectl apply -f https://github.com/knative/eventing/releases/download/knative-v1.10.0/in-memory-channel.yaml

2.3 验证安装

# 检查Knative Serving组件
kubectl get pods -n knative-serving

# 检查Knative Eventing组件
kubectl get pods -n knative-eventing

# 检查Knative服务
kubectl get svc -n knative-serving

三、创建Serverless服务

3.1 创建基本服务

apiVersion: serving.knative.dev/v1
kind: Service
metadata:
  name: hello-world
  namespace: default
spec:
  template:
    spec:
      containers:
        - image: gcr.io/knative-samples/helloworld-go
          ports:
            - containerPort: 8080
          env:
            - name: TARGET
              value: "Knative"

3.2 配置自动扩缩容

apiVersion: serving.knative.dev/v1
kind: Service
metadata:
  name: scalable-service
spec:
  template:
    spec:
      containers:
        - image: my-app:latest
      scaleConstraints:
        minScale: 0
        maxScale: 100
      containerConcurrency: 100

3.3 流量管理

apiVersion: serving.knative.dev/v1
kind: Service
metadata:
  name: canary-service
spec:
  traffic:
    - tag: v1
      revisionName: canary-service-00001
      percent: 80
    - tag: v2
      revisionName: canary-service-00002
      percent: 20
  template:
    spec:
      containers:
        - image: my-app:v2

四、事件驱动架构

4.1 创建事件源

apiVersion: sources.knative.dev/v1
kind: PingSource
metadata:
  name: hello-ping
spec:
  schedule: "*/1 * * * *"
  jsonData: '{"message": "Hello from PingSource!"}'
  sink:
    ref:
      apiVersion: serving.knative.dev/v1
      kind: Service
      name: event-handler

4.2 创建事件通道

apiVersion: messaging.knative.dev/v1
kind: InMemoryChannel
metadata:
  name: my-channel

4.3 创建事件订阅

apiVersion: messaging.knative.dev/v1
kind: Subscription
metadata:
  name: my-subscription
spec:
  channel:
    apiVersion: messaging.knative.dev/v1
    kind: InMemoryChannel
    name: my-channel
  subscriber:
    ref:
      apiVersion: serving.knative.dev/v1
      kind: Service
      name: event-handler

4.4 创建事件触发器

apiVersion: eventing.knative.dev/v1
kind: Trigger
metadata:
  name: my-trigger
spec:
  broker: default
  filter:
    attributes:
      type: dev.knative.sources.ping
  subscriber:
    ref:
      apiVersion: serving.knative.dev/v1
      kind: Service
      name: event-handler

五、高级配置

5.1 配置域名

apiVersion: configmaps
metadata:
  name: config-domain
  namespace: knative-serving
data:
  example.com: ""

5.2 配置自动扩缩容参数

apiVersion: configmaps
metadata:
  name: config-autoscaler
  namespace: knative-serving
data:
  enable-scale-to-zero: "true"
  scale-to-zero-grace-period: "30s"
  target-utilization-percentage: "70"

5.3 配置限流

apiVersion: serving.knative.dev/v1
kind: Service
metadata:
  name: limited-service
spec:
  template:
    spec:
      containers:
        - image: my-app:latest
      containerConcurrency: 50

六、使用Knative CLI

6.1 安装kn CLI

# 下载kn CLI
curl -L https://github.com/knative/client/releases/download/knative-v1.10.0/kn-darwin-amd64 -o kn

# 安装到PATH
chmod +x kn
sudo mv kn /usr/local/bin/

# 验证安装
kn version

6.2 创建服务

# 创建服务
kn service create hello-world \
  --image gcr.io/knative-samples/helloworld-go \
  --env TARGET=Knative

# 列出服务
kn service list

# 查看服务详情
kn service describe hello-world

# 更新服务
kn service update hello-world \
  --image my-app:v2

6.3 管理事件

# 创建事件源
kn source ping create hello-ping \
  --schedule "*/1 * * * *" \
  --sink ksvc:event-handler

# 列出事件源
kn source list

# 创建订阅
kn subscription create my-subscription \
  --channel my-channel \
  --sink ksvc:event-handler

七、监控与观测

7.1 Prometheus指标

apiVersion: v1
kind: Service
metadata:
  name: knative-serving-metrics
  namespace: knative-serving
spec:
  selector:
    app: activator
  ports:
    - name: metrics
      port: 9090
      targetPort: 9090

7.2 配置ServiceMonitor

apiVersion: monitoring.coreos.com/v1
kind: ServiceMonitor
metadata:
  name: knative-serving-monitor
  namespace: monitoring
spec:
  selector:
    matchLabels:
      app: activator
  endpoints:
    - port: metrics
      interval: 30s

7.3 日志收集

apiVersion: v1
kind: ConfigMap
metadata:
  name: config-observability
  namespace: knative-serving
data:
  logging.enable-var-log-collection: "true"
  logging.request-log-template: |
    {
      "requestId": "{{.RequestId}}",
      "method": "{{.Request.Method}}",
      "path": "{{.Request.URL.Path}}",
      "status": {{.Response.StatusCode}},
      "latency": "{{.Latency}}"
    }

八、最佳实践

8.1 扩缩容策略

1. 设置合理的最小副本数：对于延迟敏感的服务，设置minScale > 0
2. 调整容器并发数：根据服务特性设置containerConcurrency
3. 配置优雅关闭：设置terminationGracePeriodSeconds

8.2 事件驱动设计

1. 使用事件通道解耦：通过Channel隔离事件生产者和消费者
2. 配置事件过滤：使用Trigger过滤不需要的事件
3. 处理事件失败：配置Dead Letter Sink处理失败事件

8.3 安全配置

1. 启用TLS：配置HTTPS访问
2. 网络隔离：使用NetworkPolicy限制Pod访问
3. RBAC控制：配置最小权限原则

九、故障排除

9.1 常见问题

# 查看服务状态
kn service describe hello-world

# 查看Pod日志
kubectl logs -l serving.knative.dev/service=hello-world -c user-container

# 检查扩缩容状态
kubectl get pods -l serving.knative.dev/service=hello-world

# 查看事件
kubectl get events -n knative-serving

9.2 扩缩容问题

# 检查自动扩缩容配置
kubectl get configmap config-autoscaler -n knative-serving -o yaml

# 查看HPA状态
kubectl get hpa -l serving.knative.dev/service=hello-world

十、总结

Knative为Kubernetes提供了强大的Serverless能力，支持自动扩缩容、事件驱动和流量管理。通过本文的实践指南，您可以快速搭建Knative平台，构建高效的无服务器应用。建议从简单场景开始，逐步探索高级功能。

---

参考资料：

• Knative官方文档
• Knative Serving文档
• Knative Eventing文档