| | |
| | | "basic.com/valib/deliver.git" |
| | | "ruleprocess/insertdata" |
| | | "ruleprocess/util" |
| | | "runtime" |
| | | "time" |
| | | |
| | | //"bufio" |
| | |
| | | continue |
| | | } else { |
| | | //runtime.GOMAXPROCS(runtime.NumCPU()) |
| | | logger.Debug("使用的cpu个数:",runtime.NumCPU()) |
| | | go func(msg []byte) { |
| | | //logger.Debug("使用的cpu个数:",runtime.NumCPU()) |
| | | //go func(msg []byte) { |
| | | logger.Debug("当前时间戳:", time.Now().Unix()) |
| | | arg := ruleserver.SdkDatas{} |
| | | //paramFormat(msg, &arg) |
| | |
| | | logger.Debug("插入完Es所用时间:", time.Since(start)) |
| | | //事件推送 |
| | | //go labelFilter.Judge(resultMsg) |
| | | }(msg) |
| | | //}(msg) |
| | | } |
| | | } |
| | | } |
| | |
| | | } |
| | | |
| | | // 先进行一下追踪 |
| | | //ruleserver.FaceIsSame(&m) |
| | | ruleserver.FaceIsSame(&m) |
| | | args.CameraId = m.Cid |
| | | args.TaskId = m.Tasklab.Taskid |
| | | // 把图片的二进制解压缩进行画框在压缩回去 |