尝试给上报到elasticsearch的文档加_id

core/candle.go

@@ -288,7 +288,7 @@ func (core *Core) SaveUniKey(period string, keyName string, extt time.Duration,
 	wg := WriteLog{
 		Content: cd,
 		Tag:     "sardine.log.candle." + cl.Period,
-		// Id:      hashString(did),
+		Id:      hashString(did),
 	}
 	// go func() {
 	core.WriteLogChan <- &wg

core/core.go

@@ -87,7 +87,7 @@ func WriteLogProcess(cr *Core) {
 	for {
 		wg := <-cr.WriteLogChan
 		go func(wg *WriteLog) {
-			fmt.Println("start writelog")
+			fmt.Println("start writelog: " + wg.Id)
 			wg.Process(cr)
 		}(wg)
 	}