基于阿里云服务网格流量泳道的全链路流量管理（三）：无侵入式的宽松模式泳道

作者：尹航

在前文《基于阿里云服务网格流量泳道的全链路流量管理（一）：严格模式流量泳道》、《基于阿里云服务网格流量泳道的全链路流量管理（二）：宽松模式流量泳道》中，我们介绍了流量泳道的概念、使用流量泳道进行全链路灰度管理的方案，以及阿里云服务网格 ASM 提供的严格模式与宽松模式的流量泳道。在本文中，我们将介绍一种基于 OpenTelemetry 自动插装方案实现的宽松模式流量泳道场景，无需任何业务代码改造即可为运行在 Kubernetes 集群中的云原生应用实现灵活的全链路灰度管理能力。

概述

流量泳道是将一个云原生应用中的多个服务根据服务版本（或其他特征）隔离成的多个独立的运行环境。

在严格模式下，每条流量泳道中包含应用的调用链路上的全部服务，对于应用程序则没有任何要求。

而在宽松模式下，您只需要确保创建一条包含调用链路中所有服务的泳道：基线泳道。其它泳道可以不包含调用链路上的全部服务。当一个泳道中的服务进行相互调用时，若目标服务在当前泳道中不存在，则请求将被转发到基线泳道中的相同服务，并在请求目标存在当前泳道中存在时将请求重新转发回当前泳道。宽松模式的流量泳道虽然可以实现灵活的全链路灰度，但要求应用程序必须包含一个能够在整条调用链路中透传的请求头（链路透传请求头）。

阿里云服务网格 ASM 已经提供一种基于 baggage 透传的全新宽松模式流量泳道方案，能够在不改造业务代码的情况下，实现泳道服务的灵活灰度。

背景介绍

OpenTelemetry 是云原生计算基金会（Cloud Native Computing Foundation, CNCF）的一个项目，与其他 CNCF 项目如 Kubernetes、Prometheus 和 Envoy 等紧密相连，共同构建了云原生技术生态系统的基础。由于其提供的丰富功能和广泛适用性，OpenTelemetry 在业内已经确立了其领导地位，越来越多的企业和开发者采用它作为构建和维护可观测性平台的核心组件。

baggage 是由 OpenTelemetry 制定并推动的、在分布式系统调用链路中传递链路上下文信息的标准。它具体表现为一个名为 baggage 的请求头，其内部包含了以键值对形式存储的链路上下文信息，例如：

baggage: userId=alice,serverNode=DF%2028,isProduction=false

您可以使用 OpenTelemetry 提供的 SDK，在服务调用链路中传递 baggage 请求头、进而在整条服务链路上传递自定义的上下文信息。当服务部署在 Kubernentes 集群中时，则可以通过 OpenTelemetry Operator 的自动插装来为服务提供 baggage 透传能力、而无需修改业务代码。有关 baggage 的详细信息，可以参考 baggage [ 1] 。

基于 baggage 的透传，阿里云服务网格 ASM 提供了一种无需修改代码即可实现的宽松模式流量泳道，并针对流量泳道的引流策略进行了增强，支持基于流量权重策略对不同的泳道进行引流。本文将首先使用 OpenTelemetry 自动插装来为服务引用透传 baggage 请求头的能力，接下来创建宽松模式下的三条泳道，并基于流量权重策略对不同的泳道进行引流。

演示：实现服务 baggage 透传与宽松模式流量泳道

前提条件

• 已创建 ASM 企业版或旗舰版实例，且版本为 1.21.6.54 及以上。具体操作，请参见创建 ASM 实例 [ 2] 。
• 已添加集群到 ASM 实例。具体操作，请参见添加集群到 ASM 实例 [ 3] 。
• 已创建名称为 ingressgateway 的 ASM 网关。具体操作，请参见创建入口网关服务 [ 4] 。
• 已创建名称为 ingressgateway 且命名空间为 istio-system 的网关规则。具体操作，请参见管理网关规则 [ 5] 。

apiVersion: networking.istio.io/v1beta1
kind: Gateway
metadata:
 name: ingressgateway
  namespace: istio-system
spec:
  selector:
    istio: ingressgateway
  servers:
    - port:
        number: 80
        name: http
        protocol: HTTP
      hosts:
        - '*'

步骤一：配置服务透传 baggage 上下文

本节主要展示如何通过 OpenTelemetry Operator 自动插装的方法，为 Kubernetes 集群中的服务添加 baggage 透传能力。

1. 部署 OpenTelemetry Operator。

a. 通过 kubectl 连接到 ASM 实例添加的 Kubernetes 集群。执行以下命令，创建 opentelemetry-operator-system 命名空间。

kubectl create namespace opentelemetry-operator-system

b. 执行以下命令，使用 Helm 在 opentelemetry-operator-system 命名空间下安装 OpenTelemetry Operator。（如果尚未安装 Helm，可以参考安装 Helm 来安装 Helm 命令行工具。）

helm repo add open-telemetry https://open-telemetry.github.io/opentelemetry-helm-charts
helm install \
    --namespace=opentelemetry-operator-system \
    --version=0.46.0 \
    --set admissionWebhooks.certManager.enabled=false \
    --set admissionWebhooks.certManager.autoGenerateCert=true \
    --set manager.image.repository="registry-cn-hangzhou.ack.aliyuncs.com/acs/opentelemetry-operator" \
    --set manager.image.tag="0.92.1" \
    --set kubeRBACProxy.image.repository="registry-cn-hangzhou.ack.aliyuncs.com/acs/kube-rbac-proxy" \
    --set kubeRBACProxy.image.tag="v0.13.1" \
    --set manager.collectorImage.repository="registry-cn-hangzhou.ack.aliyuncs.com/acs/opentelemetry-collector" \
    --set manager.collectorImage.tag="0.97.0" \
    --set manager.opampBridgeImage.repository="registry-cn-hangzhou.ack.aliyuncs.com/acs/operator-opamp-bridge" \
    --set manager.opampBridgeImage.tag="0.97.0" \
    --set manager.targetAllocatorImage.repository="registry-cn-hangzhou.ack.aliyuncs.com/acs/target-allocator" \
    --set manager.targetAllocatorImage.tag="0.97.0" \
    --set manager.autoInstrumentationImage.java.repository="registry-cn-hangzhou.ack.aliyuncs.com/acs/autoinstrumentation-java" \
    --set manager.autoInstrumentationImage.java.tag="1.32.1" \
    --set manager.autoInstrumentationImage.nodejs.repository="registry-cn-hangzhou.ack.aliyuncs.com/acs/autoinstrumentation-nodejs" \
    --set manager.autoInstrumentationImage.nodejs.tag="0.49.1" \
    --set manager.autoInstrumentationImage.python.repository="registry-cn-hangzhou.ack.aliyuncs.com/acs/autoinstrumentation-python" \
    --set manager.autoInstrumentationImage.python.tag="0.44b0" \
    --set manager.autoInstrumentationImage.dotnet.repository="registry-cn-hangzhou.ack.aliyuncs.com/acs/autoinstrumentation-dotnet" \
    --set manager.autoInstrumentationImage.dotnet.tag="1.2.0" \
    --set manager.autoInstrumentationImage.go.repository="registry-cn-hangzhou.ack.aliyuncs.com/acs/opentelemetry-go-instrumentation" \
    --set manager.autoInstrumentationImage.go.tag="v0.10.1.alpha-2-aliyun" \
    opentelemetry-operator open-telemetry/opentelemetry-operator

c. 执行以下命令，检查 opentelemetry-operator 是否正常运行。

kubectl get pod -n opentelemetry-operator-system

预期输出：

NAME READY   STATUS    RESTARTS   AGE
opentelemetry-operator-854fb558b5-pvllj   2/2     Running   0          1m

2. 配置自动插装（auto-instrumentation）。

a. 使用以下内容，创建 instrumentation.yaml 文件。

apiVersion: opentelemetry.io/v1alpha1
kind: Instrumentation
metadata:
 name: demo-instrumentation
spec:
  propagators:
    - baggage
  sampler:
    type: parentbased_traceidratio
    argument: "1"

b. 执行以下命令，在 default 命名空间下声明自动插装。

kubectl apply -f instrumentation.yaml