完善 otel 配置

web/web.go

@@ -89,6 +89,7 @@ func RunTask(ctx context.Context) error {
 		ErrorHandler: asynq.ErrorHandlerFunc(func(ctx context.Context, task *asynq.Task, err error) {
 			slog.Error("任务执行失败", "task", task.Type(), "error", err)
 		}),
+		Logger: &AppAsynqLogger{},
 	})
 
 	var mux = asynq.NewServeMux()
@@ -114,6 +115,7 @@ func RunTask(ctx context.Context) error {
 func RunCron(ctx context.Context) error {
 	server := asynq.NewSchedulerFromRedisClient(deps.Redis, &asynq.SchedulerOpts{
 		Location: time.Local,
+		Logger:   &AppAsynqLogger{},
 	})
 
 	// 每小时清理一次一小时之前的过期通道
@@ -133,3 +135,33 @@ func RunCron(ctx context.Context) error {
 
 	return nil
 }
+
+type AppAsynqLogger struct{}
+
+func (l *AppAsynqLogger) Debug(args ...any) {
+	slog.Debug("Asynq", anyToAttrs(args)...)
+}
+
+func (l *AppAsynqLogger) Info(args ...any) {
+	slog.Info("Asynq", anyToAttrs(args)...)
+}
+
+func (l *AppAsynqLogger) Warn(args ...any) {
+	slog.Warn("Asynq", anyToAttrs(args)...)
+}
+
+func (l *AppAsynqLogger) Error(args ...any) {
+	slog.Error("Asynq", anyToAttrs(args)...)
+}
+
+func (l *AppAsynqLogger) Fatal(args ...any) {
+	slog.Error("Asynq[Fatal]", anyToAttrs(args)...)
+}
+
+func anyToAttrs(args ...any) []any {
+	attrs := make([]any, len(args))
+	for i, arg := range args {
+		attrs[i] = slog.Any(fmt.Sprintf("arg%d", i), arg)
+	}
+	return attrs
+}