把插入es的so放进中间件

panlei

2019-12-11 4243a710f702b601b1d5a7dc2c765191c191201d

 insertdata/insertDataToEs.go

@@ -8,9 +8,9 @@
   "strconv"
)

var weedfsUrl, videoPersonUrl, personAction string
var serverIp string
var serverPort string
//var weedfsUrl, videoPersonUrl, personAction string
//var serverIp string
//var serverPort string
func InsertToEs(msg structure.ResultMsg) {
   defer func() {
      if err := recover(); err != nil {
@@ -21,15 +21,15 @@
   if err != nil {
      panic("配置文件不合法")
   }
   weedfsUrl = "http://" + localConfig1.WebPicIp + ":" + strconv.Itoa(int(localConfig1.WebPicPort)) + "/submit"
   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))
   weedfsUrl := "http://" + localConfig1.WebPicIp + ":" + strconv.Itoa(int(localConfig1.WebPicPort)) + "/submit"
   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) {
   p,err :=  plugin.Open("./algorithm/insertEs.so")
   p,err :=  plugin.Open("./algorithm/middleware.so")
   if err != nil {
      panic(err)
   }