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 --- insertdata/insertDataToEs.go | 26 ++++++++++++++++++++++++-- 1 files changed, 24 insertions(+), 2 deletions(-) diff --git a/insertdata/insertDataToEs.go b/insertdata/insertDataToEs.go index 2e70d2a..d44ccec 100644 --- a/insertdata/insertDataToEs.go +++ b/insertdata/insertDataToEs.go @@ -2,11 +2,33 @@ import ( "plugin" + "ruleprocess/cache" + "basic.com/valib/logger.git" "ruleprocess/structure" + "strconv" ) - +var weedfsUrl, videoPersonUrl, personAction string +var serverIp string +var serverPort string 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)) + "/" + structure.EsInfo.EsIndex.AIOcean.IndexName + "/" + structure.EsInfo.EsIndex.AIOcean.IndexType+"?refresh=true" + serverIp = localConfig1.AlarmIp + serverPort = strconv.Itoa(int(localConfig1.AlarmPort)) + +} + +func handle (msg structure.ResultMsg,weedfsUrl,videoPersonUrl,serverIp,serverPort string) { p,err := plugin.Open("./algorithm/insertEs.so") if err != nil { panic(err) @@ -15,5 +37,5 @@ if err1 != nil { panic("娌℃湁鎵惧埌涓棿浠剁殑鏍煎紡鍖栨暟鎹嚱鏁�") } - f.(func(msg structure.ResultMsg))(msg) + f.(func(msg structure.ResultMsg,weedfsUrl,videoPersonUrl,serverIp,serverPort string))(msg,weedfsUrl,videoPersonUrl,serverIp,serverPort) } -- Gitblit v1.8.0