panlei
2019-12-09 759c5b9f8ef6c503f62da3b766a580a4dd6fa026
algorithm/insertEs/insertDataToEs.go
@@ -1,4 +1,4 @@
package insertdata
package main
import (
   "encoding/base64"
@@ -105,7 +105,11 @@
   rules []structure.Result
}
func InsertToEs(msg structure.ResultMsg){
func InsertToEs(msg structure.ResultMsg,weedfsUrl1,videoPersonUrl1,serverIp1,serverPort1 string){
   weedfsUrl = weedfsUrl1
   videoPersonUrl = videoPersonUrl1
   serverIp = serverIp1
   serverPort = serverPort1
   for k,results := range msg.RuleResult {
      if results != nil && len(results.([]structure.Result)) > 0{
         switch k {