insertdata/insertDataToEs.go
@@ -6,6 +6,7 @@ "fmt" "io/ioutil" "net" "os" "ruleprocess/cache" "ruleprocess/logger" "strings" @@ -360,8 +361,9 @@ logger.Warn("__________________________________________往ES插入yolo数据成功") //os.Exit(1) } logger.Debug("============瞅瞅缓存数据:",msg.RuleResult["cacheData"].(ruleserver.ResultMsg)) logger.Debug("============瞅瞅缓存数据:",msg.RuleResult["cacheData"].(ruleserver.ResultMsg).RuleResult) InsertYolo(msg.RuleResult["cacheData"].(ruleserver.ResultMsg)) os.Exit(1) } } func ChangeStatusYolo(msg ruleserver.ResultMsg) {