This commit is contained in:
zhangkun9038@dingtalk.com 2024-12-26 10:23:06 +08:00
parent 66072fc47f
commit 1b8eb76495

View File

@ -39,6 +39,7 @@ func (cd *MyCandle) Process(cr *core.Core) {
} }
} }
// 对于软candle推到elasticSearch // 对于软candle推到elasticSearch
logrus.Info("cd.from in MyCandle Process:", cd.From)
if strings.HasPrefix(cd.From, "soft") { if strings.HasPrefix(cd.From, "soft") {
cd.PushToWriteLogChan(cr) cd.PushToWriteLogChan(cr)
} }