使用模型服务网格部署和管理多模型推理服务 - 服务网格 ASM

当您需要同时运行多个机器学习模型并进行推理时，可以使用模型服务网格部署和管理多模型推理服务。模型服务网格基于KServe ModelMesh实现，针对大容量、高密度和频繁变化的模型用例进行了优化，可以智能地将模型加载到内存中或从内存中卸载，以在响应性和计算之间取得平衡，简化多模型推理服务的部署和运维，提高推理效率和性能。

前提条件

已添加集群到ASM实例，且ASM实例版本为1.18.0.134及以上。
已为集群添加入口网关。具体操作，请参见创建入口网关。

说明

本文使用ASM入口网关作为集群网关，网关名称为默认的ingressgateway，开放8008端口，协议为HTTP。

功能介绍

模型服务网格提供了以下功能：

功能	说明
缓存管理	Pod作为根据使用频率和最近访问时间自动进行优化和管理。根据使用频率和当前请求量，加载和卸载模型的副本。
智能放置和加载	模型放置通过Pod之间的缓存寿命和请求负载来平衡。使用队列来处理并发模型加载，并最大限度地减少对运行时流量的影响。
弹性	失败的模型加载会在不同的Pod中自动重试。
操作简便性	自动和无缝地处理滚动模型更新。

步骤一：在ASM中开启ModelMesh功能

登录ASM控制台，在左侧导航栏，选择服务网格 > 网格管理。
在网格管理页面，单击目标实例名称，然后在左侧导航栏，选择生态集成中心 > KServe on ASM。
在KServe on ASM页面，单击安装模型服务网格, 开启ModelMesh功能。
注意：KServe依赖于CertManager，安装KServe会自动安装CertManager组件。如需使用自建CertManager，请关闭在集群中自动安装CertManager组件。
等待几分钟就绪之后, 在ACK集群对应的KubeConfig环境下，执行以下命令，确认ServingRuntime资源是否可用。
```
kubectl get servingruntimes -n modelmesh-serving
```
预期输出：
```
NAME                DISABLED   MODELTYPE     CONTAINERS   AGE
mlserver-1.x                   sklearn       mlserver     1m
ovms-1.x                       openvino_ir   ovms         1m
torchserve-0.x                 pytorch-mar   torchserve   1m
triton-2.x                     keras         triton       1m
```
ServingRuntime定义为一个或多个特定模型格式提供服务的Pod模板，根据部署的模型的框架，会自动提供相应的Pod。
目前默认包含的运行时及支持的模型格式如下。详细信息，请参见supported-model-formats。如果这些模型服务器不能满足您的所有特定要求，可以自定义模型运行时。具体操作，请参见使用模型服务网格自定义模型运行时。
模型服务运行时
支持的模型框架
mlserver-1.x
sklearn、xgboost、lightgbm
ovms-1.x
openvino_ir、onnx
torchserve-0.x
pytorch-mar
triton-2.x
tensorflow、pytorch、onnx、tensorrt

步骤二：配置ASM环境

从Kubernetes集群同步命名空间到ASM中, 具体操作，请参见从数据平面集群同步自动注入标签至ASM实例。同步之后, 确认命名空间modelmesh-serving已经存在。

创建入口网关规则。

使用以下内容，创建grpc-gateway.yaml。

展开查看grpc-gateway.yaml

apiVersion: networking.istio.io/v1beta1
kind: Gateway
metadata:
  name: grpc-gateway
  namespace: modelmesh-serving
spec:
  selector:
    istio: ingressgateway
  servers:
    - hosts:
        - '*'
      port:
        name: grpc
        number: 8008
        protocol: GRPC

在ASM集群（实例）对应的KubeConfig环境下，执行以下命令，创建网关规则。
```
kubectl apply -f grpc-gateway.yaml
```

创建虚拟服务。

使用以下内容，创建vs-modelmesh-serving-service.yaml。

展开查看vs-modelmesh-serving-service.yaml

apiVersion: networking.istio.io/v1beta1
kind: VirtualService
metadata:
  name: vs-modelmesh-serving-service
  namespace: modelmesh-serving
spec:
  gateways:
    - grpc-gateway
  hosts:
    - '*'
  http:
    - match:
        - port: 8008
      name: default
      route:
        - destination:
            host: modelmesh-serving
            port:
              number: 8033

在ASM集群（实例）对应的KubeConfig环境下，执行以下命令，创建虚拟服务。
```
kubectl apply -f vs-modelmesh-serving-service.yaml
```

配置gRPCJSON转码器。

使用以下内容，创建grpcjsontranscoder-for-kservepredictv2.yaml。

apiVersion: istio.alibabacloud.com/v1beta1
kind: ASMGrpcJsonTranscoder
metadata:
  name: grpcjsontranscoder-for-kservepredictv2
  namespace: istio-system
spec:
  builtinProtoDescriptor: kserve_predict_v2
  isGateway: true
  portNumber: 8008
  workloadSelector:
    labels:
      istio: ingressgateway

在ASM集群（实例）对应的KubeConfig环境下，执行以下命令，部署gRPC-Json-Transcoder。
```
kubectl apply -f grpcjsontranscoder-for-kservepredictv2.yaml
```

使用以下内容，创建grpcjsontranscoder-increasebufferlimit.yaml，设置per_connection_buffer_limit_bytes，以提升响应的大小。

展开查看grpcjsontranscoder-increasebufferlimit.yaml

apiVersion: networking.istio.io/v1alpha3
kind: EnvoyFilter
metadata:
  labels:
    asm-system: "true"
    manager: asm-voyage
    provider: asm
  name: grpcjsontranscoder-increasebufferlimit
  namespace: istio-system
spec:
  configPatches:
  - applyTo: LISTENER
    match:
      context: GATEWAY
      listener:
        portNumber: 8008
      proxy:
        proxyVersion: ^1.*
    patch:
      operation: MERGE
      value:
        per_connection_buffer_limit_bytes: 100000000
  workloadSelector:
    labels:
      istio: ingressgateway

在ASM集群（实例）对应的KubeConfig环境下，执行以下命令，部署EnvoyFilter。
```
kubectl apply -f grpcjsontranscoder-increasebufferlimit.yaml
```

步骤三：部署模型示例

创建存储类StorageClass。更多信息，请参见使用NAS动态存储卷。
1. 登录容器服务管理控制台，在左侧导航栏选择集群。
2. 在集群列表页面，单击目标集群名称，然后在左侧导航栏，选择存储 > 存储类。
3. 在存储类页面右上角，单击创建，配置如下信息，然后创建。

创建存储声明PVC。

使用以下内容，创建存储声明my-models-pvc.yaml。

apiVersion: v1
kind: PersistentVolumeClaim
metadata:
  name: my-models-pvc
  namespace: modelmesh-serving
spec:
  accessModes:
    - ReadWriteMany
  resources:
    requests:
      storage: 1Gi
  storageClassName: alibabacloud-cnfs-nas
  volumeMode: Filesystem

在ACK集群对应的KubeConfig环境下，执行以下命令，创建存储声明。
```
kubectl apply -f my-models-pvc.yaml
```

执行以下命令，查看modelmesh-serving命名空间下的PVC。

kubectl get pvc -n modelmesh-serving

预期输出：

NAME             STATUS   VOLUME                                     CAPACITY   ACCESS MODES   STORAGECLASS            AGE
my-models-pvc    Bound    nas-379c32e1-c0ef-43f3-8277-9eb4606b53f8   1Gi        RWX            alibabacloud-cnfs-nas   2h

创建Pod以访问PVC。

为了使用新的PVC，需要将其作为卷安装到Kubernetes Pod，然后使用该Pod将模型文件上传到持久卷。

使用以下内容，创建pvc-access.yaml。

以下YAML表示创建一个pvc-access Pod，并要求Kubernetes控制器通过指定“my-models-pvc”来声明之前请求的PVC。

apiVersion: v1
kind: Pod
metadata:
  name: "pvc-access"
spec:
  containers:
    - name: main
      image: ubuntu
      command: ["/bin/sh", "-ec", "sleep 10000"]
      volumeMounts:
        - name: "my-pvc"
          mountPath: "/mnt/models"
  volumes:
    - name: "my-pvc"
      persistentVolumeClaim:
        claimName: "my-models-pvc"

在ACK集群对应的KubeConfig环境下，执行以下命令，创建Pod。
```
kubectl apply  -n modelmesh-serving  -f pvc-access.yaml
```

确认pvc-access Pod处于运行状态。

kubectl get pods -n modelmesh-serving | grep pvc-access

预期输出：

pvc-access             1/1     Running   0          51m

将模型存储在持久卷上。
将AI模型添加到存储卷中。本文将使用scikit-learn训练的MNIST手写数字字符识别模型。您可以从kserve/modelmesh-minio-examples仓库下载mnist-svm.joblib模型文件的副本。
1. 在ACK集群对应的KubeConfig环境下，执行以下命令，将mnist-svm.joblib模型文件复制到pvc-access Pod的/mnt/models文件夹中。
```
kubectl -n modelmesh-serving cp mnist-svm.joblib pvc-access:/mnt/models/
```
2. 执行以下命令，确认Model已经加载成功。
```
kubectl -n modelmesh-serving exec -it pvc-access -- ls -alr /mnt/models/
```
  预期输出：
```
-rw-r--r-- 1  501 staff 344817 Oct 30 11:23 mnist-svm.joblib
```

部署推理服务。

使用以下内容，创建sklearn-mnist.yaml。

展开查看sklearn-mnist.yaml

apiVersion: serving.kserve.io/v1beta1
kind: InferenceService
metadata:
  name: sklearn-mnist
  namespace: modelmesh-serving
  annotations:
    serving.kserve.io/deploymentMode: ModelMesh
spec:
  predictor:
    model:
      modelFormat:
        name: sklearn
      storage:
        parameters:
          type: pvc
          name: my-models-pvc
        path: mnist-svm.joblib

在ACK集群对应的KubeConfig环境下，执行以下命令，部署sklearn-mnist推理服务。
```
kubectl apply -f sklearn-mnist.yaml
```

等待几十秒后（时间取决于镜像拉取速度），执行以下命令，查看sklearn-mnist推理服务是否部署成功。

kubectl get isvc -n modelmesh-serving

预期输出：

NAME            URL                                               READY
sklearn-mnist   grpc://modelmesh-serving.modelmesh-serving:8033   True

运行推理服务。

使用curl命令发送推理请求到sklearn-mnist模型。数据数组表示待分类的数字图像扫描中64个像素的灰度值。

MODEL_NAME="sklearn-mnist"
ASM_GW_IP="ASM网关IP地址"
curl -X POST -k "http://${ASM_GW_IP}:8008/v2/models/${MODEL_NAME}/infer" -d '{"inputs": [{"name": "predict", "shape": [1, 64], "datatype": "FP32", "contents": {"fp32_contents": [0.0, 0.0, 1.0, 11.0, 14.0, 15.0, 3.0, 0.0, 0.0, 1.0, 13.0, 16.0, 12.0, 16.0, 8.0, 0.0, 0.0, 8.0, 16.0, 4.0, 6.0, 16.0, 5.0, 0.0, 0.0, 5.0, 15.0, 11.0, 13.0, 14.0, 0.0, 0.0, 0.0, 0.0, 2.0, 12.0, 16.0, 13.0, 0.0, 0.0, 0.0, 0.0, 0.0, 13.0, 16.0, 16.0, 6.0, 0.0, 0.0, 0.0, 0.0, 16.0, 16.0, 16.0, 7.0, 0.0, 0.0, 0.0, 0.0, 11.0, 13.0, 12.0, 1.0, 0.0]}}]}'

JSON响应如下，表示推断扫描的数字是8。

{
 "modelName": "sklearn-mnist__isvc-3c10c62d34",
 "outputs": [
  {
   "name": "predict",
   "datatype": "INT64",
   "shape": [
    "1",
    "1"
   ],
   "contents": {
    "int64Contents": [
     "8"
    ]
   }
  }
 ]
}

服务网格 ASM：使用模型服务网格进行多模型推理服务

前提条件

功能介绍

步骤一：在ASM中开启ModelMesh功能

步骤二：配置ASM环境

步骤三：部署模型示例

相关文档

模型服务运行时	支持的模型框架
mlserver-1.x	sklearn、xgboost、lightgbm
ovms-1.x	openvino_ir、onnx
torchserve-0.x	pytorch-mar
triton-2.x	tensorflow、pytorch、onnx、tensorrt