结合使用场景介绍如何自定义 Istio Mixer Adapter

2024-02-22 23:42:22

自定义Istio Mixer Adapter

Mixer Adapter是一个用于收集和报告遥测数据的组件。它可以通过多种方式配置，以支持不同的用例。在本文中，我们将介绍如何自定义Mixer Adapter，以便它可以报告自定义遥测数据。我们将提供一个示例，说明如何使用Istio Mixer Adapter收集有关请求延迟的信息。

背景

Istio是一个服务网格，它可以帮助您管理和保护您的微服务。Istio可以提供各种功能，包括流量管理、服务发现、安全和遥测。

自定义Mixer Adapter

Mixer Adapter是一个用于收集和报告遥测数据的组件。它可以通过多种方式配置，以支持不同的用例。

例如，您可以使用Mixer Adapter来收集以下信息：

请求延迟
HTTP状态码
请求大小
响应大小

您还可以使用Mixer Adapter来报告自定义遥测数据。例如，您可以使用Mixer Adapter来报告以下信息：

用户ID
会话ID
应用名称
版本

创建一个自定义Mixer Adapter

要创建一个自定义Mixer Adapter，您需要遵循以下步骤：

创建一个新的Go项目。
在项目中创建一个新的目录，名为“adapter”。
在“adapter”目录中，创建一个名为“main.go”的文件。
在“main.go”文件中，添加以下代码：

package main

import (
	"context"
	"fmt"
	"io"

	"istio.io/istio/mixer/adapter/metadata"
	"istio.io/istio/mixer/adapter/model"
	"istio.io/istio/mixer/adapter/stdio"
)

func main() {
	s, err := stdio.New(context.Background(), io.Writer(nil))
	if err != nil {
		fmt.Printf("error creating stdio: %v", err)
		return
	}
	m := &metadata.Instance{
		Name:          "my-adapter",
		Config:         metadata.Config{},
		HandlerNames:   []string{"custom"},
		Templates:     []string{},
		AttributeNames: []string{},
	}
	a := &myAdapter{}
	if err := a.Init(m, s); err != nil {
		fmt.Printf("error initializing adapter: %v", err)
		return
	}
	if err := a.Close(); err != nil {
		fmt.Printf("error closing adapter: %v", err)
		return
	}
}

type myAdapter struct {
}

func (a *myAdapter) Init(cfg *metadata.Instance, env model.Environment) error {
	// Do something with the config and environment
	return nil
}

func (a *myAdapter) HandleCustom(ctx context.Context, req *model.Request) (*model.Response, error) {
	// Do something with the request
	return nil, nil
}

func (a *myAdapter) Close() error {
	// Do something to clean up the adapter
	return nil
}

将“main.go”文件保存到“adapter”目录中。
运行以下命令来编译自定义Mixer Adapter：

go build -o custom-adapter ./adapter

部署自定义Mixer Adapter

要部署自定义Mixer Adapter，您需要遵循以下步骤：

将自定义Mixer Adapter复制到Istio控制平面的“adapters”目录中。
在Istio控制平面的“config”目录中创建以下文件：

apiVersion: "config.istio.io/v1alpha2"
kind: Handler
metadata:
  name: my-adapter
  namespace: istio-system
spec:
  compiledAdapter:
    adapterFactory: custom-adapter.factory

保存文件。

使用自定义Mixer Adapter

要使用自定义Mixer Adapter，您需要遵循以下步骤：

在Istio中创建一个Mixer规则，该规则将自定义Mixer Adapter附加到您的服务。
在Istio中创建一个Mixer实例，该实例将自定义Mixer Adapter配置为报告您想要收集的信息。
启动您的服务。

验证自定义Mixer Adapter

要验证自定义Mixer Adapter是否正常工作，您可以使用以下命令来查看它收集的遥测数据：

kubectl logs -n istio-system mixer | grep my-adapter

您应该会看到类似以下内容的输出：

{"source_version":"2c74a59c5c12fb9083622d92237262f652d3441f","destination_service":"productpage","destination_version":"1.1.0","request_size":123,"request_timestamp":"2019-03-01T19:30:24.951Z","response_code":200,"response_size":42,"response_timestamp":"2019-03-01T19:30:24.953Z","request_duration":2}