检索时间线

前提条件

• 已写入时序数据。具体操作，请参见写入时序数据。

• 已初始化TimeseriesClient。具体操作，请参见初始化OTSClient。

接口

public class QueryTimeseriesMetaRequest implements Request {
    /** 时序表名称。*/
    private final String timeseriesTableName;
    /** 检索条件.*/
    private MetaQueryCondition condition;
    /** 是否返回命中的总行数。*/
    private boolean getTotalHits = false;
    /** 一次返回的时间线个数。*/
    private int limit = -1;
    /** 使用此返回值作为下一次操作的起始点继续读取时间线。*/
    private byte[] nextToken;
}

其中检索条件的接口定义说明如下：

public class CompositeMetaQueryCondition implements MetaQueryCondition {
    /** 逻辑运算符。*/
    private final MetaQueryCompositeOperator operator;
    /** 子条件列表。*/
    private List<MetaQueryCondition> subConditions = new ArrayList<MetaQueryCondition>();
}

public class MeasurementMetaQueryCondition implements MetaQueryCondition {
    /** 关系运算符。*/
    private final MetaQuerySingleOperator operator;
    /** 要匹配的度量名称。*/
    private final String value;
}

public class DataSourceMetaQueryCondition implements MetaQueryCondition {
    /** 关系运算符。*/
    private final MetaQuerySingleOperator operator;
     /** 要匹配的数据源名称。*/
    private final String value;
}

public class TagMetaQueryCondition implements MetaQueryCondition {
    /** 关系运算符。*/
    private final MetaQuerySingleOperator operator;
    /** 标签名称。*/
    private final String tagName;
    /** 标签值。*/
    private final String value;
}

public class AttributeMetaQueryCondition implements MetaQueryCondition {
    /** 关系运算符。*/
    private final MetaQuerySingleOperator operator;
    /** 属性名称。*/
    private final String attributeName;
    /** 属性值。*/
    private final String value;
}

public class UpdateTimeMetaQueryCondition implements MetaQueryCondition {
    /** 关系运算符。*/
    private final MetaQuerySingleOperator operator;
    /** 时间线元数据更新时间的时间戳。*/
    private final long timeInUs;
}

参数

检索时间线时，您必须配置timeseriesTableName（时序表名称）和condition（检索条件）。其中condition包括compositeMetaQueryCondition（组合条件）、measurementMetaQueryCondition（度量名称条件）、dataSourceMetaQueryCondition（数据源条件）、tagMetaQueryCondition（标签条件）、attributeMetaQueryCondition（属性条件）和updateTimeMetaQueryCondition（更新时间条件）。检索条件的详细说明请参见下表。

示例

以下示例用于查询指定时序表中度量名称为cpu，标签中含有os标签且标签前缀为Ubuntu的所有时间线。

private static void queryTimeseriesMeta(TimeseriesClient client) {
    // 填写时序表名称。
    String tableName = "<TIME_SERIES_TABLE>";
    QueryTimeseriesMetaRequest queryTimeseriesMetaRequest = new QueryTimeseriesMetaRequest(tableName);
    // 查询度量名称为cpu，标签中含有os标签且前缀为"Ubuntu"的所有时间线。即measurement_name="cpu" and have_prefix(os, "Ubuntu")。
    CompositeMetaQueryCondition compositeMetaQueryCondition = new CompositeMetaQueryCondition(MetaQueryCompositeOperator.OP_AND);
    compositeMetaQueryCondition.addSubCondition(new MeasurementMetaQueryCondition(MetaQuerySingleOperator.OP_EQUAL, "cpu"));
    compositeMetaQueryCondition.addSubCondition(new TagMetaQueryCondition(MetaQuerySingleOperator.OP_PREFIX, "os", "Ubuntu"));
    queryTimeseriesMetaRequest.setCondition(compositeMetaQueryCondition);
    queryTimeseriesMetaRequest.setGetTotalHits(true);
    // 限制单次请求返回的时间线元数据条数。
    queryTimeseriesMetaRequest.setLimit(100);
    // 发起查询。
    QueryTimeseriesMetaResponse queryTimeseriesMetaResponse = client.queryTimeseriesMeta(queryTimeseriesMetaRequest);
    // 打印符合条件的时间线的总条数。
    System.out.println(queryTimeseriesMetaResponse.getTotalHits());

    // 保存请求结果。
    List<TimeseriesMeta> timeseriesMetas = new ArrayList<TimeseriesMeta>();
    timeseriesMetas.addAll(queryTimeseriesMetaResponse.getTimeseriesMetas());

    // 如果有NextToken，可以继续发起请求获取。
    while (queryTimeseriesMetaResponse.getNextToken() != null) {
        queryTimeseriesMetaRequest.setNextToken(queryTimeseriesMetaResponse.getNextToken());
        queryTimeseriesMetaResponse = client.queryTimeseriesMeta(queryTimeseriesMetaRequest);
        timeseriesMetas.addAll(queryTimeseriesMetaResponse.getTimeseriesMetas());
        // 限制总共获取的条数。
        if (timeseriesMetas.size() >= 1000) {
            break;
        }
    }

    System.out.println(timeseriesMetas.size());
    for (TimeseriesMeta timeseriesMeta : timeseriesMetas) {
        System.out.println(timeseriesMeta.getTimeseriesKey().getMeasurementName());
        System.out.println(timeseriesMeta.getTimeseriesKey().getDataSource());
        System.out.println(timeseriesMeta.getTimeseriesKey().getTags());
        System.out.println(timeseriesMeta.getAttributes());
        System.out.println(timeseriesMeta.getUpdateTimeInUs());
    }
}

相关文档

确定到时间线后，您可以执行如下操作：

• 查询时间线中满足指定条件的时序数据。具体操作，请参见查询时序数据。

• 更新时间线元数据的属性。具体操作，请参见更新时间线元数据。

• 删除不需要的时间线元数据。具体操作，请参见删除时间线元数据。