Query time series metadata - Tablestore SDK for Java - Tablestore: Central de Documentação do Alibaba Cloud

Use o Tablestore SDK for Java para consultar metadados de séries temporais por nome da medição, fonte de dados, tag, atributo ou horário de atualização. Combine condições e pagine os resultados.

Pré-requisitos

Instale o Tablestore SDK for Java e inicialize um cliente de séries temporais.

Descrição

Chame queryTimeseriesMeta para consultar metadados em uma tabela de séries temporais. Sem a especificação de condições, o sistema retorna todos os metadados. Ao definir uma condição, a filtragem ocorre com base em uma ou mais características da série temporal.

public QueryTimeseriesMetaResponse queryTimeseriesMeta(QueryTimeseriesMetaRequest request) throws TableStoreException, ClientException

Nota

O servidor cria índices de metadados de forma assíncrona para novas séries temporais. Após gravar uma nova série temporal, aguarde a criação do índice antes de consultar seus metadados.

O exemplo a seguir consulta metadados de séries temporais na tabela example_timeseries_table cujo nome da medição é cpu e o valor da tag os começa com Ubuntu.

CompositeMetaQueryCondition condition =
        new CompositeMetaQueryCondition(MetaQueryCompositeOperator.OP_AND);
condition.addSubCondition(new MeasurementMetaQueryCondition(
        MetaQuerySingleOperator.OP_EQUAL, "cpu"));
condition.addSubCondition(new TagMetaQueryCondition(
        MetaQuerySingleOperator.OP_PREFIX, "os", "Ubuntu"));

QueryTimeseriesMetaRequest request =
        new QueryTimeseriesMetaRequest("example_timeseries_table");
request.setCondition(condition);
request.setGetTotalHits(true);
request.setLimit(100);

QueryTimeseriesMetaResponse response =
        timeseriesClient.queryTimeseriesMeta(request);
System.out.println(response.getTotalHits());
for (TimeseriesMeta meta : response.getTimeseriesMetas()) {
    System.out.println(meta);
}

Parâmetros

QueryTimeseriesMetaRequest contém os seguintes parâmetros:

Nome	Tipo	Descrição
timeseriesTableName (obrigatório)	`String`	Nome da tabela de séries temporais.
condition (opcional)	`MetaQueryCondition`	Condição para consultar metadados de séries temporais. Sem este parâmetro, o sistema retorna todos os metadados.
getTotalHits (opcional)	`boolean`	Defina se o sistema deve retornar o número total de entradas de metadados correspondentes. Padrão: `false`.
limit (opcional)	`int`	Número máximo de entradas de metadados a retornar por requisição. Apenas valores positivos têm efeito. A quantidade real de entradas retornadas pode ser inferior a este valor.
nextToken (opcional)	`byte[]`	Token de paginação. Não especifique este parâmetro na primeira requisição. Se `nextToken` na resposta não for `null`, passe-o para a próxima requisição. Não considere a consulta concluída apenas porque uma página está vazia ou contém menos entradas que `limit`. Para persistir ou transferir o token binário, codifique-o em Base64.

Defina condition como um dos seguintes tipos de condição. Condições de string aceitam OP_EQUAL, OP_GREATER_THAN, OP_GREATER_EQUAL, OP_LESS_THAN, OP_LESS_EQUAL e OP_PREFIX. Condições de tempo de atualização não aceitam OP_PREFIX.

Condição composta

Se condition for do tipo CompositeMetaQueryCondition, ela conterá os seguintes parâmetros:

Nome	Tipo	Descrição
operator (obrigatório)	`MetaQueryCompositeOperator`	Operador lógico. Valores válidos: `OP_AND`, `OP_OR` e `OP_NOT`.
subConditions (obrigatório)	`List<MetaQueryCondition>`	Lista não vazia de condições a combinar. Uma subcondição também pode ser uma condição composta.

Condição de nome da medição

Se condition for do tipo MeasurementMetaQueryCondition, ela conterá os seguintes parâmetros:

Nome	Tipo	Descrição
operator (obrigatório)	`MetaQuerySingleOperator`	Operador de consulta.
value (obrigatório)	`String`	Nome da medição a corresponder.

Condição de fonte de dados

Se condition for do tipo DataSourceMetaQueryCondition, ela conterá os seguintes parâmetros:

Nome	Tipo	Descrição
operator (obrigatório)	`MetaQuerySingleOperator`	Operador de consulta.
value (obrigatório)	`String`	Identificador da fonte de dados a corresponder.

Condição de tag

Se condition for do tipo TagMetaQueryCondition, ela conterá os seguintes parâmetros:

Nome	Tipo	Descrição
operator (obrigatório)	`MetaQuerySingleOperator`	Operador de consulta.
tagName (obrigatório)	`String`	Nome da tag não vazio a corresponder.
value (obrigatório)	`String`	Valor da tag a corresponder.

Condição de atributo

Se condition for do tipo AttributeMetaQueryCondition, ela conterá os seguintes parâmetros:

Nome	Tipo	Descrição
operator (obrigatório)	`MetaQuerySingleOperator`	Operador de consulta.
attributeName (obrigatório)	`String`	Nome do atributo não vazio a corresponder.
value (obrigatório)	`String`	Valor do atributo a corresponder.

Condição de tempo de atualização

Se condition for do tipo UpdateTimeMetaQueryCondition, ela conterá os seguintes parâmetros:

Nome	Tipo	Descrição
operator (obrigatório)	`MetaQuerySingleOperator`	Operador de consulta. Valores válidos: `OP_EQUAL`, `OP_GREATER_THAN`, `OP_GREATER_EQUAL`, `OP_LESS_THAN` e `OP_LESS_EQUAL`.
timeInUs (obrigatório)	`long`	Última atualização dos metadados, em microssegundos desde 1970-01-01 00:00:00 UTC.

Resposta

QueryTimeseriesMetaResponse inclui os seguintes campos específicos da operação:

Campo	Tipo	Descrição
`timeseriesMetas`	`List<TimeseriesMeta>`	Chame `getTimeseriesMetas()` para obter os metadados de séries temporais retornados pela requisição atual.
`totalHits`	`long`	Chame `getTotalHits()` para obter o número total de entradas de metadados correspondentes. Este campo é válido somente se `getTotalHits` estiver definido como `true` na requisição. Caso contrário, o valor será `-1`.
`nextToken`	`byte[]`	Chame `getNextToken()` para obter o token da próxima página. O valor `null` indica que o sistema retornou todos os resultados.

Metadados de séries temporais

Cada elemento em timeseriesMetas[] é do tipo TimeseriesMeta e contém os seguintes campos:

Campo	Tipo	Descrição
`timeseriesKey`	`TimeseriesKey`	Chame `getTimeseriesKey()` para obter os identificadores da série temporal.
`attributes`	`SortedMap<String, String>`	Chame `getAttributes()` para obter os atributos de metadados.
`updateTimeInUs`	`long`	Chame `getUpdateTimeInUs()` para obter a última atualização dos metadados em microssegundos.

Identificadores de séries temporais

timeseriesMetas[].timeseriesKey é do tipo TimeseriesKey e contém os seguintes campos:

Campo	Tipo	Descrição
`measurementName`	`String`	Chame `getMeasurementName()` para obter o nome da medição.
`dataSource`	`String`	Chame `getDataSource()` para obter o identificador da fonte de dados.
`tags`	`SortedMap<String, String>`	Chame `getTags()` para obter as tags.

Exemplos

Paginar todos os metadados

Se nextToken na resposta não for null, passe o token repetidamente até obter todos os resultados.

List<TimeseriesMeta> allMetas = new ArrayList<>();
byte[] nextToken = null;
do {
    request.setNextToken(nextToken);
    QueryTimeseriesMetaResponse response =
            timeseriesClient.queryTimeseriesMeta(request);

    allMetas.addAll(response.getTimeseriesMetas());
    nextToken = response.getNextToken();
} while (nextToken != null);