尝试给上报到elasticsearch的文档加_id
This commit is contained in:
parent
1dee8c87a4
commit
d17526b50a
@ -285,14 +285,14 @@ func (core *Core) SaveUniKey(period string, keyName string, extt time.Duration,
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
did := cl.InstId + cl.Period + cl.Data[0].(string)
|
// did := cl.InstId + cl.Period + cl.Data[0].(string)
|
||||||
cl.Id = did
|
// cl.Id = did
|
||||||
cl.ToStruct(core)
|
cl.ToStruct(core)
|
||||||
cd, _ := json.Marshal(cl)
|
cd, _ := json.Marshal(cl)
|
||||||
wg := WriteLog{
|
wg := WriteLog{
|
||||||
Content: cd,
|
Content: cd,
|
||||||
Tag: "sardine.log.candle." + cl.Period,
|
Tag: "sardine.log.candle." + cl.Period,
|
||||||
Id: hashString(did),
|
// Id: hashString(did),
|
||||||
}
|
}
|
||||||
err = wg.Process(core)
|
err = wg.Process(core)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user