main.go
@@ -71,14 +71,14 @@ arg := ruleserver.SdkDatas{} //paramFormat(msg, &arg) m := paramFormat(msg, &arg) logger.Info("解析出来的数据:", arg) // 进行规则处理判断(打上规则的标签) ruleserver.Judge(&arg,&m) // 把sdkMessage传进去,方便缓存数据时拼出一个resultMag // 把arg里的打的标签拿出来给m再封装一层 resultMsg := ruleserver.ResultMsg{SdkMessage: &m, RuleResult: arg.RuleResult} // 将打完标签的数据插入到ES insertdata.InsertToEs(resultMsg) //事件推送 //labelFilter.Judge(resultMsg) } } }