insertdata/insertDataToEs.go
@@ -25,7 +25,7 @@ videoPersonUrl = "http://" + localConfig1.AlarmIp + ":" + strconv.Itoa(int(localConfig1.AlarmPort)) + "/" + structure.EsInfo.EsIndex.AIOcean.IndexName + "/" + structure.EsInfo.EsIndex.AIOcean.IndexType+"?refresh=true" serverIp = localConfig1.AlarmIp serverPort = strconv.Itoa(int(localConfig1.AlarmPort)) handle(msg,weedfsUrl,videoPersonUrl,serverIp,serverPort) } func handle (msg structure.ResultMsg,weedfsUrl,videoPersonUrl,serverIp,serverPort string) {