使用 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(必选) |
| 时序表名称。 |
analyticalStore(必选) |
| 分析存储配置。 |
分析存储配置
analyticalStore 的类型为 TimeseriesAnalyticalStore,包含以下参数。
名称 | 类型 | 说明 |
analyticalStoreName(必选) |
| 分析存储名称。 |
timeToLive(可选) |
| 分析存储的数据生命周期,单位为秒,默认值为 |
syncOption(可选) |
| 数据同步方式,默认值为 |