lxh/logger
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

🐛修复loki异步推送搞错了，弄成同步了. #3

Merged
coward merged 1 commits from coward into master 2024-11-29 10:34:15 +08:00
Conversation 0 Commits 1 Files Changed 1 +2 -5
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
loki.go
View File

@ -10,7 +10,6 @@ import (
"github.com/prometheus/common/model" "github.com/prometheus/common/model"
"go.uber.org/zap" "go.uber.org/zap"
"go.uber.org/zap/zapcore" "go.uber.org/zap/zapcore"
"sync"
"time" "time"
) )
@ -77,10 +76,7 @@ func (c lokiWriter) Write(p []byte) (int, error) {
label["caller"] = model.LabelValue(li.Caller) label["caller"] = model.LabelValue(li.Caller)
// 异步推送消息到服务器 // 异步推送消息到服务器
var wg sync.WaitGroup
wg.Add(1)
_ = ants.Submit(func() { _ = ants.Submit(func() {
defer wg.Done()
t, e := time.ParseInLocation("2006-01-02 15:04:05.000", li.Ts, time.Local) t, e := time.ParseInLocation("2006-01-02 15:04:05.000", li.Ts, time.Local)
if e != nil { if e != nil {
t = time.Now().Local() t = time.Now().Local()
@ -89,7 +85,8 @@ func (c lokiWriter) Write(p []byte) (int, error) {
fmt.Printf("日志推送到Loki失败: %v\n", err.Error()) fmt.Printf("日志推送到Loki失败: %v\n", err.Error())
} }
}) })
wg.Wait()
defer ants.Release()
return 0, nil return 0, nil
} }