sunty
2019-11-21 0247b4944585e0d2472850ccf8dfbf2ee49de656
fix taskRate
1个文件已修改
10 ■■■■ 已修改文件
EsApi.go 10 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
EsApi.go
@@ -448,9 +448,9 @@
        }
    },
    "aggs":{
        "sdkId_status":{
        "sdkName_status":{
            "terms":{
                "field":"taskId"
                "field":"sdkName.raw"
            }
        }
    }
@@ -469,7 +469,7 @@
    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!")
    }
@@ -481,9 +481,9 @@
            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)
    }