查询时序数据-表格存储 Tablestore(Tablestore)-阿里云帮助中心

前提条件

已初始化客户端。详情请参见初始化Tablestore Client。

方法说明

public GetTimeseriesDataResponse getTimeseriesData(GetTimeseriesDataRequest request) throws TableStoreException, ClientException

GetTimeseriesDataRequest参数说明

timeseriesTableName（必选）String：时序表名称。

timeseriesKey（必选）TimeseriesKey：时间线标识，包含以下参数。

名称	类型	说明
measurementName（必选）	String	时间线的度量名称。
dataSource（必选）	String	时间线的数据源信息。
tags（必选）	SortedMap<String, String>	时间线的标签信息，由多个键值对（key-value）组成。

beginTimeInUs（必选）long：起始时间戳，单位为微秒，取值必须大于等于 0。查询范围包含该时间戳。
- 查询条件包含起始时间戳。
endTimeInUs（必选）long：结束时间戳，单位为微秒，取值必须大于 0。查询范围不包含该时间戳。
- 查询条件不包含结束时间戳。
limit（可选）int：单次请求的最大返回行数。默认值为 5000，取值范围为(0,5000]。
- 若符合条件的数据行数超过 limit，实际返回行数可能因扫描数据量等因素低于该限制。可通过 nextToken 继续获取剩余数据。
nextToken（可选）byte[]：分页查询凭证，用于获取下一页数据。默认值为空。
- 首次请求将nextToken设置为空。若响应未返回全部数据，返回结果中的nextToken不为空，传入后续请求即可翻页。
- 如需持久化或传输nextToken，使用 Base64 编码将nextToken转为字符串。nextToken为二进制数据，直接使用new String(nextToken)会导致 token 信息丢失。
backward（可选）boolean：是否按时间倒序读取数据。默认值为 false。
fieldsToGet（可选）List<Pair<String, ColumnType>>：指定查询的数据列。不设置则返回所有列。
- 在fieldsToGet中，需同时指定列名和数据类型。若指定类型与实际不符，该列数据将无法读取。

示例代码

以下示例查询 timeseries_table_sample 时序表中符合条件的时序数据。

private static void getTimeseriesData(TimeseriesClient client) {
    String tableName = "timeseries_table_sample";
    GetTimeseriesDataRequest getTimeseriesDataRequest = new GetTimeseriesDataRequest(tableName);
    
    // 指定时间线标识。度量名称为cpu，数据源标识为host_0，且标签为"region=hangzhou"和"os=Ubuntu16.04"。
    Map<String, String> tags = new HashMap<String, String>();
    tags.put("region", "hangzhou");
    tags.put("os", "Ubuntu16.04");
    TimeseriesKey timeseriesKey = new TimeseriesKey("cpu", "host_0", tags);
    getTimeseriesDataRequest.setTimeseriesKey(timeseriesKey);
    
    // 指定时间范围。
    getTimeseriesDataRequest.setTimeRange(0, (System.currentTimeMillis() + 60 * 1000) * 1000);
    getTimeseriesDataRequest.setLimit(20);
    
    // 查询时序数据。
    GetTimeseriesDataResponse getTimeseriesDataResponse = client.getTimeseriesData(getTimeseriesDataRequest);
    // 打印查询结果。
    getTimeseriesDataResponse.getRows().forEach(row -> {
        System.out.println("TimeseriesKey: " + row.getTimeseriesKey() + "; TimeInUs: " + row.getTimeInUs() + "; Fields: " + row.getFields());
    });
}

还可以在查询时配置以下可选项。

设置单次请求的最大返回行数
```
getTimeseriesDataRequest.setLimit(20);
```

按时间倒序读取数据

// 按照时间倒序读取数据，以便获取某条时间线的最新数据。
getTimeseriesDataRequest.setBackward(true);

指定返回的数据列

 getTimeseriesDataRequest.addFieldToGet("col_string", ColumnType.STRING);
 getTimeseriesDataRequest.addFieldToGet("col_long", ColumnType.INTEGER);
 getTimeseriesDataRequest.addFieldToGet("col_double", ColumnType.DOUBLE);

通过 nextToken 翻页查询

// 如果nextToken不为空，可以发起下一次请求。
if (getTimeseriesDataResponse.getNextToken() != null) {
    // 获取nextToken。
    byte[] nextToken = getTimeseriesDataResponse.getNextToken();
    
    /*
    // 如果需要持久化nextToken或者传输nextToken给前端页面，您可以使用Base64编码将nextToken编码为String进行保存和传输。
    String tokenAsString = Base64.toBase64String(nextToken);
    // 将String重新解码为byte类型的nextToken。
    byte[] tokenAsByte = Base64.fromBase64String(tokenAsString);
    */
    
    // 指定nextToken。
    getTimeseriesDataRequest.setNextToken(nextToken);
    // 查询时序数据。
    getTimeseriesDataResponse = client.getTimeseriesData(getTimeseriesDataRequest);
    // 打印查询结果。
    getTimeseriesDataResponse.getRows().forEach(row -> {
        System.out.println("TimeseriesKey: " + row.getTimeseriesKey() + "; TimeInUs: " + row.getTimeInUs() + "; Fields: " + row.getFields());
    });
}

前提条件

方法说明

示例代码

常见问题