创建分析存储

更新时间:
复制 MD 格式

使用 Java SDK 为已有时序表创建分析存储,用于低成本、长期存储和分析时序数据。

前提条件

  • 安装Tablestore Java SDK并初始化时序模型客户端。分析存储功能需要使用 5.15.0 及以上版本,建议使用最新版本。

  • 已在支持分析存储的地域创建时序模型实例。支持地域及功能详情参见分析存储

功能说明

调用 createTimeseriesAnalyticalStore 方法为已有时序表创建分析存储。分析存储会自动同步时序表中的数据,其数据生命周期与时序表的数据生命周期相互独立,对分析存储执行查询不会影响时序表的读写性能。

public CreateTimeseriesAnalyticalStoreResponse createTimeseriesAnalyticalStore(CreateTimeseriesAnalyticalStoreRequest request) throws TableStoreException, ClientException

创建分析存储时,可以选择以下数据同步方式:

  • SYNC_TYPE_FULL:同步时序表中的存量数据和创建后写入的增量数据,默认使用该方式。

  • SYNC_TYPE_INCR:仅同步分析存储创建后写入的增量数据。

重要
  • 同步方式创建后不能修改,请根据是否需要分析存量数据谨慎选择。

  • 一个时序表只能创建 1 个分析存储。一个时序表的 Lastpoint 索引与分析存储总数不能超过 10 个。

以下示例为 example_timeseries_table 创建 example_analytical_store。分析存储中的数据永不过期,并采用全量同步方式。

TimeseriesClient timeseriesClient = client.asTimeseriesClient();

TimeseriesAnalyticalStore analyticalStore =
        new TimeseriesAnalyticalStore("example_analytical_store");
analyticalStore.setTimeToLive(-1);
analyticalStore.setSyncOption(AnalyticalStoreSyncType.SYNC_TYPE_FULL);

CreateTimeseriesAnalyticalStoreRequest request =
        new CreateTimeseriesAnalyticalStoreRequest(
                "example_timeseries_table", analyticalStore);

timeseriesClient.createTimeseriesAnalyticalStore(request);

创建后,数据同步在后台执行。可以调用 describeTimeseriesAnalyticalStore 方法查看同步状态,具体操作参见查询分析存储描述信息

参数说明

CreateTimeseriesAnalyticalStoreRequest 包含以下参数。

名称

类型

说明

timeseriesTableName(必选)

String

时序表名称。

analyticalStore(必选)

TimeseriesAnalyticalStore

分析存储配置。

分析存储配置

analyticalStore 的类型为 TimeseriesAnalyticalStore,包含以下参数。

名称

类型

说明

analyticalStoreName(必选)

String

分析存储名称。

timeToLive(可选)

int

分析存储的数据生命周期,单位为秒,默认值为 -1。取值为 -1 或不小于 2592000int32 整数;-1 表示数据永不过期。系统根据数据列的时间戳而不是数据写入时间判断数据是否过期,并自动清理过期数据。

syncOption(可选)

AnalyticalStoreSyncType

数据同步方式,默认值为 SYNC_TYPE_FULL。取值为 SYNC_TYPE_FULLSYNC_TYPE_INCR