From 3a454e86f28c0e5a50332c2d3760598d36d800da Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期一, 09 十二月 2019 17:43:54 +0800
Subject: [PATCH] es模块儿做成so
---
algorithm/insertEs/insertDataToEs.go | 9 +++++----
1 files changed, 5 insertions(+), 4 deletions(-)
diff --git a/algorithm/insertEs/insertDataToEs.go b/algorithm/insertEs/insertDataToEs.go
index 6515807..103b3d9 100644
--- a/algorithm/insertEs/insertDataToEs.go
+++ b/algorithm/insertEs/insertDataToEs.go
@@ -5,6 +5,7 @@
"encoding/json"
"errors"
"net"
+ "ruleprocess/insertdata"
"strconv"
"time"
@@ -226,7 +227,7 @@
}
if key == "track" && len(face.Liker) == 1{
esid := face.Liker[0].TargetId
- returnMsg, err1 := esutil.AppendTargetInfo(esid, string(requstbody),EsInfo.EsIndex.AIOcean.IndexName,serverIp,serverPort)
+ returnMsg, err1 := esutil.AppendTargetInfo(esid, string(requstbody),structure.EsInfo.EsIndex.AIOcean.IndexName,serverIp,serverPort)
if err1 != nil {
logger.Error("杩藉姞鏁版嵁鍑洪敊锛�---", err1)
} else {
@@ -235,7 +236,7 @@
ruleserver.AddLxMessage(&protomsg.VideotapeInfo{EsDataId: face.Uuid, CameraId: msg.Cid, TaskId: msg.Tasklab.Taskid, VideoUrl: msg.Push.VideoUrl, ImgId: i.Id, SdkIds: []string{"-1"}, Type: 1})
}
} else {
- resp1, err1 := EsReq("POST", videoPersonUrl, requstbody)
+ resp1, err1 := insertdata.EsReq("POST", videoPersonUrl, requstbody)
if err1 != nil {
logger.Error("涓婁紶ES鍑洪敊锛�---", err1)
} else {
@@ -445,7 +446,7 @@
logger.Info("json parse error ", err)
return
}
- resp1, err2 := EsReq("POST", videoPersonUrl, requstbody)
+ resp1, err2 := insertdata.EsReq("POST", videoPersonUrl, requstbody)
if err2 != nil {
logger.Error("寰�ES鎻掑叆鏁版嵁澶辫触", err)
} else {
@@ -605,7 +606,7 @@
logger.Info("json parse error ", err)
return
}
- resp1, err2 := EsReq("POST", videoPersonUrl, requstbody)
+ resp1, err2 := insertdata.EsReq("POST", videoPersonUrl, requstbody)
if err2 != nil {
logger.Error("寰�ES鎻掑叆鏁版嵁澶辫触", err)
} else {
--
Gitblit v1.8.0