Usar o Tablestore SDK for Go para consultar dados de séries temporais - Tablestore: Central de Documentação do Alibaba Cloud

Pré-requisitos

Os dados de séries temporais foram gravados na tabela de séries temporais. Para mais informações, consulte Gravar dados de séries temporais.
Uma instância do TimeseriesClient foi inicializada. Para mais informações, consulte Inicializar um cliente do Tablestore.

Parâmetros

Parâmetro	Obrigatório	Descrição
timeseriesKey	Sim	Identificadores da série temporal a ser consultada. Utilize os subparâmetros abaixo para especificar os identificadores: measurementName: nome da métrica da série temporal. dataSource: source dos dados da série temporal. Este parâmetro pode ficar em branco. tags: tags da série temporal. Os valores são pares chave-valor do tipo STRING. Importante Caso não tenha certeza sobre os identificadores da série temporal, como o nome da métrica ou o source dos dados, chame a operação QueryTimeseriesMeta para recuperar as séries temporais com base em condições de filtro. Para mais informações, consulte Recuperar séries temporais.
timeRange	Sim	Intervalo de tempo da consulta. O intervalo é fechado à esquerda e aberto à direita. Use os seguintes subparâmetros: beginTimeInUs: hora de início. endTimeInUs: hora de término.
backward	Não	Defina se os resultados devem ser retornados em ordem cronológica inversa. Utilize esta opção para obter primeiro os pontos de dados mais recentes. Valores válidos: true: retorna os resultados em ordem cronológica inversa. false: retorna os resultados em ordem cronológica. Este é o valor padrão.
fieldsToGet	Não	Colunas de dados a serem retornadas. Se nada for especificado, todas as colunas serão retornadas. Importante Ao definir fieldsToGet, é necessário fornecer tanto o nome quanto o tipo de dado de cada coluna. Se o tipo de dado não corresponder ao nome da coluna, ela não será retornada.
limit	Não	Número máximo de linhas a retornar por chamada. Nota Se o conjunto de resultados exceder o limite, ou se menos linhas forem retornadas devido a restrições no volume de dados verificados, utilize o parâmetro nextToken para recuperar as linhas restantes.
nextToken	Não	Token de paginação para recuperação de resultados adicionais. Caso uma consulta retorne apenas um conjunto parcial de resultados, a resposta incluirá nextToken. Passe este token na próxima solicitação para obter as linhas restantes. Importante Para persistir ou transferir nextToken para uma página frontend, codifique-o usando Base64. Não utilize `string(nextToken)` para converter o token — isso causa perda de dados do token.

Exemplos

O exemplo a seguir consulta dados em uma série temporal especificando timeseriesKey:

func GetTimeseriesDataSample(client *tablestore.TimeseriesClient , timeseriesTableName string) {
    fmt.Println("[Info]: Begin to get timeseries data !")

    // Construct the timeseriesKey for the time series in which you want to query the data. 
    timeseriesKey := tablestore.NewTimeseriesKey()
    timeseriesKey.SetMeasurementName("NETWORK")
    timeseriesKey.SetDataSource("127.0.0.1")
    timeseriesKey.AddTag("City" , "Hangzhou")
    timeseriesKey.AddTag("Region" , "Xihu")

    // Construct the query request. 
    getTimeseriesDataRequest := tablestore.NewGetTimeseriesDataRequest(timeseriesTableName)
    getTimeseriesDataRequest.SetTimeseriesKey(timeseriesKey)
    getTimeseriesDataRequest.SetTimeRange(0 , time.Now().UnixNano() / 1000) // Specify the time range for the query. 
    getTimeseriesDataRequest.SetLimit(-1)

    // Call the time series client-related API operation to query data in the time series. 
    getTimeseriesResp , err := client.GetTimeseriesData(getTimeseriesDataRequest)
    if err != nil {
        fmt.Println("[Error]: Get timeseries data Failed with error: " , err)
        return
    }
    fmt.Println("[Info]: Get timeseries data succeed ! TimeseriesRows: ")
    for i := 0; i < len(getTimeseriesResp.GetRows()); i++ {
        fmt.Println("[Info]: Row" , i , ": [" , getTimeseriesResp.GetRows()[i].GetTimeseriesKey().GetMeasurementName(),
            getTimeseriesResp.GetRows()[i].GetTimeseriesKey().GetDataSource(),
            getTimeseriesResp.GetRows()[i].GetTimeseriesKey().GetTags(), "]",
            getTimeseriesResp.GetRows()[i].GetTimeInus())
        rows := getTimeseriesResp.GetRows()[i].GetFieldsMap()
        for key, value := range rows {
            fmt.Println(key, value.Value)
        }
    }
    fmt.Println("[Info]: GetTimeseriesDataSample finished! RequestId: " , getTimeseriesResp.RequestId)
}

Perguntas frequentes

Referências

Para mais informações sobre a operação de API, consulte GetTimeseriesData.
Também é possível usar SQL para consultar dados de séries temporais. Para mais informações, consulte Usar SQL para consultar dados de séries temporais.
Para visualizar dados de séries temporais, conecte o Tablestore ao Grafana. Para mais informações, consulte Conectar ao Grafana.