From 3cdf9117668a91f2fefcda89eb4263d7fb2f4434 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期五, 29 三月 2024 18:30:15 +0800
Subject: [PATCH] 精简代码
---
cache/compare.go | 237 ++---------------------------------------------------------
1 files changed, 9 insertions(+), 228 deletions(-)
diff --git a/cache/compare.go b/cache/compare.go
index 9275cce..4d45b87 100644
--- a/cache/compare.go
+++ b/cache/compare.go
@@ -2,7 +2,6 @@
import (
"encoding/base64"
- "errors"
"flag"
"fmt"
"sdkCompare/face"
@@ -11,14 +10,10 @@
"sync"
"time"
- "sdkCompare/cache/shardmap"
- "sdkCompare/config"
- "sdkCompare/util"
-
- libEs "basic.com/pubsub/esutil.git"
"basic.com/pubsub/protomsg.git"
"basic.com/valib/logger.git"
"github.com/golang/protobuf/proto"
+ "sdkCompare/cache/shardmap"
)
var querynum = flag.Int("querynum", 3000, "the query number from database")
@@ -27,7 +22,6 @@
var (
thresholdLimit = float32(50)
captureTable = "capturetable"
- cartable = "carTable_"
PRE_DBTABLE = "dbTable_"
PRE_CAPTURE_SERVER = "captureServer_"
)
@@ -39,138 +33,6 @@
var Cmap *CmapItem
var doOnce sync.Once
-
-// 璁＄畻姣忔鏌ヨ鐨勬暟鎹噺鏉℃暟
-func Querynum(totalnum int) int {
- qn := totalnum / *threadnum //qn=6551
- if *querynum < qn { //
-
- return *querynum
- }
- return qn
-}
-
-// 澧為噺鏌ヨ
-func IncreVideoPersonsCache(lastT time.Time, targetType string) {
- ticker := time.NewTicker(time.Minute * 3)
- for {
- select {
- case <-ticker.C:
- curTime := time.Now()
- Incrementquery(lastT, curTime, targetType)
- lastT = curTime
- }
- }
-}
-
-func Incrementquery(last time.Time, cur time.Time, targetType string) {
- laststring := last.Format("2006-01-02 15:04:05")
- curstring := cur.Format("2006-01-02 15:04:05")
- alarmIp := config.EsCompServerInfo.ESIP
- alarmPort := config.EsCompServerInfo.ESPort
- indexName := config.EsInfo.EsIndex.AiOcean.IndexName
-
- serverIp, _, e := util.GetLocalIP(config.Server.NetworkAdapter)
- if e != nil {
- return
- }
-
- shardStr, e := getShards(serverIp, alarmIp, alarmPort)
- if e != nil {
- return
- }
-
- // 璋冪敤澧為噺鐨勬帴鍙�
- captures, err := libEs.GetPeriodInfos(serverIp, alarmPort, laststring, curstring, indexName, shardStr, targetType)
- if err != nil {
- logger.Error(err)
- return
- }
- for _, ei := range captures {
- if ei.EsInfo.AnalyServerId != "" {
- cKey := PRE_CAPTURE_SERVER + ei.EsInfo.AnalyServerId
- ei.EsInfo.Tableid = captureTable
-
- if _, ok := Cmap.Cam[cKey]; !ok {
- Cmap.Cam[cKey] = shardmap.New(uint8(*threadnum))
- }
-
- Cmap.Cam[cKey].Set(ei.EsInfo.Id, ei.EsInfo)
- }
- }
-}
-
-func getShards(serverIp string, alarmIp string, alarmPort string) (string, error) {
- infos, e := libEs.GetShardsByIndex(alarmIp, alarmPort, config.EsInfo.EsIndex.AiOcean.IndexName)
- if e != nil || infos == nil {
- logger.Error("get es primary ips err")
- return "", errors.New("get es primary ips err")
- }
-
- var shards []string
- for _, shard := range infos {
- if (shard.ShardIp == serverIp || shard.ShardIp == "127.0.0.1") && shard.ShardRole == "primary" && shard.ShardState == "STARTED" {
- shards = append(shards, strconv.Itoa(shard.ShardNum))
- }
- }
- if len(shards) == 0 {
- return "", errors.New("current shards is empty")
- }
- return strings.Join(shards, ","), nil
-}
-
-// 1. 鎷垮埌鎬婚噺锛� 璁＄畻姣忎釜绾跨▼鐨勬煡璇㈤噺
-// 2. 鍒嗙嚎绋嬫煡璇�
-func Init(indexName string, targetType string) error {
- alarmIp := config.EsCompServerInfo.ESIP
- alarmPort := config.EsCompServerInfo.ESPort
-
- doOnce.Do(func() {
- flag.Parse()
-
- Cmap = &CmapItem{
- Cam: make(map[string]*shardmap.ShardMap),
- }
- })
-
- serverIp, _, e := util.GetLocalIP(config.Server.NetworkAdapter)
- if e != nil {
- return e
- }
-
- shardStr, e := getShards(serverIp, alarmIp, alarmPort)
- if e != nil {
- return e
- }
- // 杩欓噷闇�瑕佹彁渚涙�婚噺鐨勬帴鍙�
- estotalnum := libEs.GetTotal(serverIp, alarmPort, indexName, shardStr, targetType)
- *querynum = Querynum(estotalnum)
- temptime := time.Now()
-
- captures, err := libEs.GetOceanFeatures(serverIp, alarmPort, 1000, indexName, shardStr, targetType)
- if err != nil {
- logger.Error("libEs.GetOceanFeatures err:", err)
- return err
- }
- logger.Debug("len(captures):", len(captures))
- Cmap.Lock()
- for _, ei := range captures {
- if ei.EsInfo.AnalyServerId != "" {
- cKey := PRE_CAPTURE_SERVER + ei.EsInfo.AnalyServerId
- ei.EsInfo.Tableid = captureTable
- if _, ok := Cmap.Cam[cKey]; !ok {
- Cmap.Cam[cKey] = shardmap.New(uint8(*threadnum))
- }
-
- Cmap.Cam[cKey].Set(ei.EsInfo.Id, ei.EsInfo)
- }
- }
-
- Cmap.Unlock()
-
- logger.Debug(indexName, "缂撳瓨瀹屾垚鐢ㄦ椂:", time.Since(temptime))
- return nil
-}
func ReInitDbTablePersonsCache() {
Cmap.Lock()
@@ -447,87 +309,15 @@
}
} else { //web璇锋眰锛屾瘮瀵规寚瀹氱殑鎶撴媿搴撴垨鑰呭簳搴�
for _, tid := range compareArgs.TableIds {
- if tid == captureTable { //姣斿鎶撴媿搴�
- tStart := time.Now()
- serverIp, _, e := util.GetLocalIP(config.Server.NetworkAdapter)
- if e != nil {
- logger.Error("util.GetLocalIP err:", e)
- continue
- }
- alarmPort := config.EsCompServerInfo.ESPort
+ shardins, ok := Cmap.Cam[tid]
+ if !ok {
+ logger.Error("get shard error by tableId:", tid)
+ continue
+ }
- scopeIds := libEs.GetAllLocalVideopersonsId(compareArgs, config.EsInfo.EsIndex.AiOcean.IndexName, serverIp, alarmPort, compareArgs.AlarmLevel)
- logger.Debug("libEs.GetAllLocalVideopersonsId len(scopeIds):", len(scopeIds), " 鑰楁椂锛�", time.Since(tStart))
- if scopeIds != nil {
- tCompStart := time.Now()
- if compareArgs.AnalyServerId != "" { //鎸囧畾server
- for cKey, cacheMap := range Cmap.Cam {
- if cKey == PRE_CAPTURE_SERVER+compareArgs.AnalyServerId {
- for _, sId := range scopeIds {
- obj, ok := cacheMap.Get(sId)
- if ok {
- eInfo, ok := obj.(*protomsg.Esinfo)
- if !ok {
- continue
- }
- sec := DoSdkCompare(compareArgs.FaceFeature, eInfo.FaceFeature)
- if sec >= baseScore {
- scResult.CompareResult = append(scResult.CompareResult, &protomsg.SdkCompareEach{
- Id: eInfo.Id,
- CompareScore: sec,
- Tableid: eInfo.Tableid,
- })
- }
- }
- }
- }
- }
- } else { //绠＄悊骞冲彴璇锋眰姣斿鎵�鏈夋姄鎷�,涓嶆寚瀹歴erver
- for cKey, cacheMap := range Cmap.Cam {
- if len(compareArgs.ServerIds) > 0 {
- for _, termDevId := range compareArgs.ServerIds {
- if cKey == PRE_CAPTURE_SERVER+termDevId || !strings.HasPrefix(cKey, PRE_CAPTURE_SERVER) {
- targets := cacheMap.Walk(DoSdkCompare, compareArgs.FaceFeature, baseScore, compareArgs.Source, compareArgs.CompareTarget)
- if len(targets) > 0 {
- scResult.CompareResult = append(scResult.CompareResult, targets...)
- }
- }
- }
- } else {
- if strings.HasPrefix(cKey, PRE_CAPTURE_SERVER) {
- for _, sId := range scopeIds {
- if obj, ok := cacheMap.Get(sId); ok {
- eInfo, ok := obj.(*protomsg.Esinfo)
- if !ok {
- continue
- }
- sec := DoSdkCompare(compareArgs.FaceFeature, eInfo.FaceFeature)
- if sec >= baseScore {
- scResult.CompareResult = append(scResult.CompareResult, &protomsg.SdkCompareEach{
- Id: eInfo.Id,
- CompareScore: sec,
- Tableid: eInfo.Tableid,
- })
- }
- }
- }
- }
- }
- }
- }
- logger.Debug("鏍规嵁scopeIds姣斿鑰楁椂锛�", time.Since(tCompStart))
- }
- } else {
- shardins, ok := Cmap.Cam[tid]
- if !ok {
- logger.Error("get shard error by tableId:", tid)
- continue
- }
-
- targets := shardins.Walk(DoSdkCompare, compareArgs.FaceFeature, baseScore, compareArgs.Source, compareArgs.CompareTarget)
- if len(targets) > 0 {
- scResult.CompareResult = append(scResult.CompareResult, targets...)
- }
+ targets := shardins.Walk(DoSdkCompare, compareArgs.FaceFeature, baseScore, compareArgs.Source, compareArgs.CompareTarget)
+ if len(targets) > 0 {
+ scResult.CompareResult = append(scResult.CompareResult, targets...)
}
}
}
@@ -550,15 +340,6 @@
logger.Error("DoSdkCompare err:", err)
return -1
}
- //if len(co_d) != 2560 {
- // logger.Error("target fea.len !=2560")
- // return -1
- //}
- //
- //if len(ci) != 2560 {
- // logger.Error("source fea.len !=2560")
- // return -1
- //}
sec := face.DecCompare(ci, co_d)
//logger.Debug("姣斿寰楀垎涓猴細", sec)
--
Gitblit v1.8.0