| | |
| | | ] |
| | | } |
| | | }` |
| | | fmt.Println(personUrl) |
| | | fmt.Println(personBody) |
| | | //fmt.Println(personUrl) |
| | | //fmt.Println(personBody) |
| | | source := make(map[string]interface{}) |
| | | queryStartTime := time.Now() |
| | | buf, err := EsReq("POST", personUrl, []byte(personBody)) |
| | |
| | | } |
| | | ` |
| | | //logPrint("url: ", url, videoUrlInfo) |
| | | fmt.Println(url, picUrlInfo) |
| | | //fmt.Println(url, picUrlInfo) |
| | | buf, err := EsReq("POST", url, []byte(picUrlInfo)) |
| | | if err != nil { |
| | | logPrint("http request videoUrlInfo info is err!") |
| | |
| | | } |
| | | wg.Wait() |
| | | |
| | | fmt.Println("lenth_all: ", len(dbinfos)) |
| | | //fmt.Println("lenth_all: ", len(dbinfos)) |
| | | |
| | | return dbinfos, nil |
| | | } |