package main

import (
    "fmt"

    "github.com/baidubce/bce-sdk-go/bce"
)

const AK = "your Access Key"
const SK = "your Secret Key"
const ENDPOINT = "https://cdn.baidubce.com"

func main() {
    method := "POST"
    path := "/v2/dsa/stat/query"

    headers := map[string]string{"Content-Type":"application/json","Accept":"application/json"}
    params := map[string]string{}
    payload, _ := bce.NewBodyFromString("{\"metric\":\"pv\",\"startTime\":\"2019-03-20T06:00:00Z\",\"endTime\":\"2019-03-20T06:10:00Z\",\"period\":300,\"key_type\":0,\"key\":[\"cdaa.wonter.net\"],\"groupBy\":\"key\",\"level\":\"all\"}")

    req := &bce.BceRequest{}
    req.SetUri(path)
    req.SetMethod(method)
    req.SetParams(params)
    req.SetHeaders(headers)
    req.SetBody(payload)

    client, err := bce.NewBceClientWithAkSk(AK, SK, ENDPOINT)
    if err != nil {
        // client 初始化失败终止启动
        panic(err)
    }
    resp := &bce.BceResponse{}
    if err := client.SendRequest(req, resp); err != nil {
        fmt.Println("err: ", err)
    } else {
        fmt.Println("http code: ", resp.StatusCode())
        respBody := make(map[string]any)
        if err := resp.ParseJsonBody(&respBody); err == nil {
            fmt.Println("resp:", respBody)
        } else {
            fmt.Println("data is null: ", err)
        }
    }
}

{
    "status": "ok",
    "details": [
        {"pv": 2145,"qps": 7,"timestamp": "2019-03-20T06:00:00Z","key": "cdaa.wonter.net"},
        {"pv": 2950,"qps": 9,"timestamp": "2019-03-20T06:05:00Z","key": "cdaa.wonter.net"}
    ],
    "count": 2
}