From 4431a8860d470ef02f0e402688b50c20703e6218 Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期三, 07 八月 2019 16:33:18 +0800
Subject: [PATCH] add GetVideoPersonFaceFeatureById

---
 EsApi.go |   31 ++++++++++++++++++++++++++++++-
 1 files changed, 30 insertions(+), 1 deletions(-)

diff --git a/EsApi.go b/EsApi.go
index 993d786..c8e9541 100644
--- a/EsApi.go
+++ b/EsApi.go
@@ -170,6 +170,34 @@
     println(dbperson)
     return dbperson,nil
 }
+//鏍规嵁鎶撴媿搴撲汉鍛榠d鏌ヨ鐗瑰緛鍊�
+func GetVideoPersonFaceFeatureById (id string, indexName string, serverIp string, serverPort string) (string, error) {
+    var jsonDSL = `
+            {
+            	"query": {
+            		"bool": {
+            			"filter": [{
+            				"term": {
+            					"id":"`+ id +`"
+            				}
+            			}]
+            		}
+            	},
+                "_source":["faceFeature"]
+            }
+        `
+    buf, err := EsReq("POST", "http://"+serverIp+":"+serverPort+"/"+indexName+"/_search",[]byte(jsonDSL))
+    if err != nil {
+        return "",  err
+    }
+
+    sources, err := Sourcelist(buf)
+    if err != nil {
+        return "" , err
+    }
+    faceFeature := sources[0]["faceFeature"].(string)
+    return faceFeature,nil
+}
 
 // 鏍规嵁tableid 鏌ヨtablename
 func Dbtablename(tableid string, indexName string, serverIp string, serverPort string) (tablename string, err error) {
@@ -221,7 +249,8 @@
             "term": {
               "id": "` +id+ `"
             }
-          }
+          },
+            "size":1000000
         }
         `
     buf, err := EsReq("POST", "http://"+serverIp+":"+serverPort+"/"+indexName+"/_update_by_query",[]byte(videoUrlInfo))

--
Gitblit v1.8.0