应用性能监控全链路版
应用性能监控全链路版
文档指南
请输入
- 文档首页
应用性能监控全链路版用户指南应用性能监控接入指南Go 应用接入日志监控
复制全文
下载 pdfGo 应用接入日志监控
文档反馈
问问助手应用性能监控全链路版支持日志监控，针对收集的日志提供日志列表、日志检索以及单链路日志查询功能。本文为您介绍如何通过 Opentelemetry 方式将使用 Go 语言的应用接入 APMPlus 日志监控。
前提条件
已经获取服务相关配置信息，例如：服务名称、appkey、endpoint。
变量 | 说明 |
{apmplus_endpoint} | 应用性能监控接入点，不同上报方式的配置存在差异，根据实际情况选择合适的方式进行配置。
 |
{apmplus_appkey} | 应用性能监控认证信息，适用于上报到 Apmplus 服务端的场景。
|
服务名称，可前往服务列表查看。  |
操作步骤
- 下载依赖包。
go get go.opentelemetry.io/otel/exporters/otlp/otlplog/otlploggrpc
go get go.opentelemetry.io/contrib/bridges/otelzap
go get go.uber.org/zap
- 配置 LoggerProvider。
说明
变量值的获取和配置说明，参见前提条件中的介绍。
import (
"context"
"time"
"go.opentelemetry.io/otel/exporters/otlp/otlplog/otlploggrpc"
"go.opentelemetry.io/otel/log/global"
"go.opentelemetry.io/otel/sdk/log"
)
func InitOtlLog() *log.LoggerProvider {
ctx := context.Background()
// 使用 grpc 协议上报。
exporter, err := otlploggrpc.New(ctx,
otlploggrpc.WithEndpoint("{{apmplus_endpoint}}"), // 指定上报的 endpoint。
otlploggrpc.WithInsecure(),
otlploggrpc.WithHeaders(map[string]string{"x-byteapm-appkey": "{{apmplus_appkey}}"}), // appkey，应用性能监控认证信息。若上报到 Otel Collector，无需配置，删除此行配置；若上报到 Apmplus 服务端，需要填写 appkey。
otlploggrpc.WithTimeout(10*time.Second),
)
if err != nil {
panic(err)
}
hostname, _ := os.Hostname()
loggerProvider := log.NewLoggerProvider(
log.WithProcessor(log.NewBatchProcessor(exporter)),
log.WithResource(resource.NewWithAttributes(
semconv.SchemaURL,
semconv.ServiceNameKey.String("{{service_name}}"), // 服务名称。
semconv.HostNameKey.String(hostname)),
),
)
global.SetLoggerProvider(loggerProvider)
// 正确处理关闭过程，确保无任何泄漏。
return loggerProvider
}
// 放到初始化路径里面，保证执行到下面的逻辑。
loggerProvider := initOtlLog()
defer loggerProvider.Shutdown(context.Background())
- 初始化 zap 并使用 zap 打印日志。
package zap_demo
import (
"context"
"go.opentelemetry.io/contrib/bridges/otelzap"
"go.opentelemetry.io/otel"
"go.opentelemetry.io/otel/baggage"
"go.opentelemetry.io/otel/log/global"
"go.uber.org/zap"
)
var (
tracer = otel.Tracer("otel-demo-tracer")
// AddCaller 保证打印文件名和文件行号。
logger = zap.New(otelzap.NewCore("my/demo/pkg", otelzap.WithLoggerProvider(global.GetLoggerProvider())), zap.AddCaller())
)
// 调用 Call 方法并打印日志。
func Call(ctx context.Context) {
// 基于 ctx 生成一个新的 span。
ctx, span := tracer.Start(ctx, "otelLogCall")
defer span.End()
ctx = context.WithValue(ctx, "key", "value")
// 附带 ctx 会上报 traceId 和 spanId，另外，Fields 里面的 key 和 value 也会上报到 Attribute。
logger.Info("this is zap info demo", zap.Any("context", ctx), zap.String("method", "zapCall"))
logger.Info("this is zap info demo without context")
}
- 下载依赖包。
go get go.opentelemetry.io/otel/exporters/otlp/otlplog/otlploggrpc
go get go.opentelemetry.io/contrib/bridges/otellogrus
go get github.com/sirupsen/logrus
- 配置 LoggerProvider。
说明
变量值的获取和配置说明，参见前提条件中的介绍。
import (
"context"
"time"
"go.opentelemetry.io/otel/exporters/otlp/otlplog/otlploggrpc"
"go.opentelemetry.io/otel/log/global"
"go.opentelemetry.io/otel/sdk/log"
)
func InitOtlLog() *log.LoggerProvider {
ctx := context.Background()
// 使用 grpc 协议上报。
exporter, err := otlploggrpc.New(ctx,
otlploggrpc.WithEndpoint("{{apmplus_endpoint}}"), // 指定上报的 endpoint。
otlploggrpc.WithInsecure(),
otlploggrpc.WithHeaders(map[string]string{"x-byteapm-appkey": "{{apmplus_appkey}}"}), // appkey，应用性能监控认证信息。若上报到 Otel Collector，无需配置，删除此行配置；若上报到 Apmplus 服务端，需要填写 appkey。
otlploggrpc.WithTimeout(10*time.Second),
)
if err != nil {
panic(err)
}
hostname, _ := os.Hostname()
loggerProvider := log.NewLoggerProvider(
log.WithProcessor(log.NewBatchProcessor(exporter)),
log.WithResource(resource.NewWithAttributes(
semconv.SchemaURL,
semconv.ServiceNameKey.String("{{service_name}}"), // 必须指定服务名。
semconv.HostNameKey.String(hostname)),
),
)
global.SetLoggerProvider(loggerProvider)
// 正确处理关闭过程，确保无任何泄漏。
return loggerProvider
}
// 放到初始化路径里面，保证执行到下面的逻辑。
loggerProvider := initOtlLog()
defer loggerProvider.Shutdown(context.Background())
- 初始化 logrus 并使用 logrus 打印日志。
package logrus_demo
import (
"context"
"github.com/sirupsen/logrus"
"go.opentelemetry.io/contrib/bridges/otellogrus"
"go.opentelemetry.io/otel"
"go.opentelemetry.io/otel/baggage"
"go.opentelemetry.io/otel/log/global"
)
var (
tracer = otel.Tracer("otel-demo-tracer")
logger = logrus.New()
)
func init() {
// 创建 *otellogrus.Hook 并在应用中使用.
hook := otellogrus.NewHook("my/demo/pkg", otellogrus.WithLoggerProvider(global.GetLoggerProvider()))
logger.AddHook(hook)
logger.SetReportCaller(true)
}
// 调用 Call 方法并打印日志。
func Call(ctx context.Context) {
// 基于 ctx 生成一个新的 span。
ctx, span := tracer.Start(ctx, "otelLogCall")
defer span.End()
// 附带 ctx 会上报 traceId 和 spanId，另外，Fields 里面的 key 和 value 也会上报到 Attribute。
logger.WithContext(ctx).WithFields(logrus.Fields{"user_id": 10010, "ip": "192.168.32.15"}).Info("this is logrus info demo with context")
logger.Warn("this is logrus warn demo without context")
logger.Error("this is logrus error demo without context")
}
- 下载依赖包。
go get go.opentelemetry.io/otel/exporters/otlp/otlplog/otlploggrpc
go get go.opentelemetry.io/contrib/bridges/otelslog
- 配置 LoggerProvider。
说明
变量值的获取和配置说明，参见前提条件中的介绍。
import (
"context"
"time"
"go.opentelemetry.io/otel/exporters/otlp/otlplog/otlploggrpc"
"go.opentelemetry.io/otel/log/global"
"go.opentelemetry.io/otel/sdk/log"
)
func InitOtlLog() *log.LoggerProvider {
ctx := context.Background()
// 使用 grpc 协议上报。
exporter, err := otlploggrpc.New(ctx,
otlploggrpc.WithEndpoint("{{apmplus_endpoint}}"), // 指定上报的 endpoint。
otlploggrpc.WithInsecure(),
otlploggrpc.WithHeaders(map[string]string{"x-byteapm-appkey": "{{apmplus_appkey}}"}), // appkey，应用性能监控认证信息。若上报到 Otel Collector，无需配置，删除此行配置；若上报到 Apmplus 服务端，需要填写 appkey。
otlploggrpc.WithTimeout(10*time.Second),
)
if err != nil {
panic(err)
}
hostname, _ := os.Hostname()
loggerProvider := log.NewLoggerProvider(
log.WithProcessor(log.NewBatchProcessor(exporter)),
log.WithResource(resource.NewWithAttributes(
semconv.SchemaURL,
semconv.ServiceNameKey.String("{{service_name}}"), // 必须指定服务名。
semconv.HostNameKey.String(hostname)),
),
)
global.SetLoggerProvider(loggerProvider)
// 正确处理关闭过程，确保无任何泄漏。
return loggerProvider
}
// 放到初始化路径里面，保证执行到下面的逻辑。
loggerProvider := initOtlLog()
defer loggerProvider.Shutdown(context.Background())
- 初始化 slog 并使用 slog 打印日志。
package slog_demo
import (
"context"
"go.opentelemetry.io/contrib/bridges/otelslog"
"go.opentelemetry.io/otel"
"go.opentelemetry.io/otel/baggage"
)
var (
logger = otelslog.NewLogger("my/demo/pkg", otelslog.WithSource(true))
tracer = otel.Tracer("otel-log-tracer")
)
func init() {
}
// 调用 Call 方法并打印日志。
func Call(ctx context.Context) {
// 基于 ctx 生成一个新的 span。
ctx, span := tracer.Start(ctx, "otelLogCall")
defer span.End()
logger.Info("this is slog info demo without context")
// 打印日志时，附带 context，会上报 traceId 和 spanId。
logger.InfoContext(ctx, "this is slog info demo with context")
logger.ErrorContext(ctx, "this is slog error demo with context")
// 打印日志时，附带 context，会上报 traceId 和 spanId，另外，attr 里面的 key 和 value 也会上报到 Attribute。
logger.LogAttrs(ctx, slog.LevelInfo, "this is slog info logAttrs demo with context", slog.String("k1", "v1"))
}
后续操作
Go 应用接入日志监控后，打印日志时可通过 Opentelemetry SDK 将日志上报到 APMPlus。此时，可前往应用性能监控页面，进行日志查询，支持日志查询、单链路日志详情查询等功能。更多详细说明参见：日志监控。
- 日志查询示例
- 单链路日志详情示例
最近更新时间：2026.02.10 19:56:33
这个页面对您有帮助吗？
有用
有用
无用
无用