From 42e6fe67c0c8cb51bf8ac13460f562672fd20c3e Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期一, 09 十二月 2019 17:09:54 +0800
Subject: [PATCH] es做成so
---
algorithm/insertEs/insertDataToEs.go | 16 +---------------
1 files changed, 1 insertions(+), 15 deletions(-)
diff --git a/algorithm/insertEs/insertDataToEs.go b/algorithm/insertEs/insertDataToEs.go
index 1d06682..6515807 100644
--- a/algorithm/insertEs/insertDataToEs.go
+++ b/algorithm/insertEs/insertDataToEs.go
@@ -104,20 +104,7 @@
rules []structure.Result
}
-func InsertToEs(msg structure.ResultMsg) {
- defer func() {
- if err := recover(); err != nil {
- logger.Error("es妯″潡鍎跨殑寮傚父鎹曡幏锛�", err)
- }
- }()
- localConfig1, err := cache.GetServerInfo()
- if err != nil {
- panic("閰嶇疆鏂囦欢涓嶅悎娉�")
- }
- weedfsUrl = "http://" + localConfig1.WebPicIp + ":" + strconv.Itoa(int(localConfig1.WebPicPort)) + "/submit"
- videoPersonUrl = "http://" + localConfig1.AlarmIp + ":" + strconv.Itoa(int(localConfig1.AlarmPort)) + "/" + EsInfo.EsIndex.AIOcean.IndexName + "/" + EsInfo.EsIndex.AIOcean.IndexType+"?refresh=true"
- serverIp = localConfig1.AlarmIp
- serverPort = strconv.Itoa(int(localConfig1.AlarmPort))
+func InsertToEs(msg structure.ResultMsg){
for k,results := range msg.RuleResult {
if results != nil && len(results.([]structure.Result)) > 0{
switch k {
@@ -135,7 +122,6 @@
}
}
}
-
// 寰�es涓彃鍏ヤ汉鑴哥被鍨嬫暟鎹�
func InsertFace(msg structure.ResultMsg,key string, results interface{}) {
logger.Info("寰�es鎻掑叆鎶撴媿鏁版嵁")
--
Gitblit v1.8.0