| | |
| | | } |
| | | }, |
| | | "aggs":{ |
| | | "sdkId_status":{ |
| | | "sdkName_status":{ |
| | | "terms":{ |
| | | "field":"taskId" |
| | | "field":"sdkName.raw" |
| | | } |
| | | } |
| | | } |
| | |
| | | if !ok { |
| | | return nil, errors.New("first hits change error!") |
| | | } |
| | | sdkName_status, ok := middle["sdkId_status"].(map[string]interface{}) |
| | | sdkName_status, ok := middle["sdkName_status"].(map[string]interface{}) |
| | | if !ok { |
| | | return nil, errors.New("first hits change error!") |
| | | } |
| | |
| | | fmt.Println("change to source error!") |
| | | continue |
| | | } |
| | | sdkId := tmpbuf["key"].(string) |
| | | sdkName := tmpbuf["key"].(string) |
| | | count := int(tmpbuf["doc_count"].(float64)) |
| | | source["id"] = sdkId |
| | | source["name"] = sdkName |
| | | source["value"] = count |
| | | sources = append(sources, source) |
| | | } |