| | |
| | | return feature, nil |
| | | } |
| | | |
| | | //根据目标id查询已追加条数 |
| | | func GetLinkTagInfoSize(id string, indexName string, serverIp string, serverPort string) (size int,err error){ |
| | | url := "http://" + serverIp + ":" + serverPort + "/" + indexName + "/_search" |
| | | queryDSL := `{ |
| | | "query": { |
| | | "term":{ |
| | | "id":"` + id + `" |
| | | } |
| | | } |
| | | }` |
| | | buf, err := EsReq("POST",url,[]byte(queryDSL)) |
| | | if err != nil { |
| | | return -1,err |
| | | } |
| | | source, err := Sourcelist(buf) |
| | | if err != nil { |
| | | return -1,err |
| | | } |
| | | if source[0]["linkTagInfo"] != nil { |
| | | size = len(source[0]["linkTagInfo"].([]interface{})) |
| | | } else { |
| | | return -1,errors.New("该数组不存在") |
| | | } |
| | | return size,nil |
| | | } |
| | | |
| | | //根据目标id追加跟踪信息 |
| | | func AppendTargetInfo(id string, targetInfo string, indexName string, serverIp string, serverPort string) (string, error) { |
| | | if targetInfo == "" { |