更新时间线元数据

前提条件

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

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

接口

public class UpdateTimeseriesMetaRequest implements Request {
    /** 时序表名称。*/
    private final String timeseriesTableName;
    /** 时间线元数据。*/
    private List<TimeseriesMeta> metas = new ArrayList<TimeseriesMeta>();
}

public class TimeseriesMeta {
    /** 时间线元数据标识。*/
    private TimeseriesKey timeseriesKey;
    /** 时间线元数据属性。*/
    private SortedMap<String, String> attributes = new TreeMap<String, String>();
    /** 时间线元数据生命周期。*/
    private long updateTimeInUs = -1;
}

public class TimeseriesKey implements Comparable<TimeseriesKey> {
    /** 度量名称。*/
    private final String measurementName;
    /** 数据源名称。*/
    private final String dataSource;
    /** 标签信息。*/
    private final SortedMap<String, String> tags = new TreeMap<String, String>();
    private String tagsString;
}

参数

timeseriesMeta表示一个时间线元数据，每个timeseriesMeta包括timeseriesKey和attributes。详细参数说明请参见下表，

示例

以下示例用于更新指定时序表中时间线的属性信息。

private static void updateTimeseriesMeta(TimeseriesClient client) {
    List<TimeseriesMeta> timeseriesMetaList = new ArrayList<TimeseriesMeta>();
    for (int i = 0; i < 10; i++) {
        Map<String, String> tags = new HashMap<String, String>();
        tags.put("region", "hangzhou");
        tags.put("os", "Ubuntu16.04");
        // 构造TimeseriesKey。
        TimeseriesKey timeseriesKey = new TimeseriesKey("cpu", "host_" + i, tags);
        TimeseriesMeta meta = new TimeseriesMeta(timeseriesKey);
        // 设置时间线的属性值（attributes）。
        Map<String, String> attrs = new HashMap<String, String>();
        attrs.put("status", "online");
        meta.setAttributes(attrs);
        timeseriesMetaList.add(meta);
    }
    // 填写时序表名称。
    String tableName = "<TIME_SERIES_TABLE>";
    UpdateTimeseriesMetaRequest updateTimeseriesMetaRequest = new UpdateTimeseriesMetaRequest(tableName);
    updateTimeseriesMetaRequest.setMetas(timeseriesMetaList);
    UpdateTimeseriesMetaResponse updateTimeseriesMetaResponse = client.updateTimeseriesMeta(updateTimeseriesMetaRequest);
    // 检查是否全部成功。
    if (!updateTimeseriesMetaResponse.isAllSuccess()) {
        for (UpdateTimeseriesMetaResponse.FailedRowResult failedRowResult : updateTimeseriesMetaResponse.getFailedRows()) {
            System.out.println(failedRowResult.getIndex());
            System.out.println(failedRowResult.getError());
        }
    }
}