1. Tablestore概述：为什么选择表格存储
表格存储Tablestore是阿里云提供的一款全托管、Serverless化的NoSQL多模型数据库服务。它面向海量结构化数据，提供高性能、高可用的数据存储与实时查询能力，同时针对物联网场景深度优化，提供一站式的IoTstore解决方案。Tablestore广泛应用于海量账单、IM消息、物联网、车联网、风控和推荐等场景中的结构化数据存储，具备海量数据低成本存储、毫秒级在线数据查询和检索以及灵活的数据分析能力。单表支持PB级存储、千万级TPS，以及多种索引方式，包括全局二级索引、全文索引、倒排索引以及时空索引。
Tablestore的核心优势体现在几个方面。首先是Serverless架构，用户无需关心底层服务器的运维和扩容，系统根据数据量和访问量自动弹性伸缩。其次是多模型支持，一份数据可以同时以宽表、时序、消息三种模型进行组织和访问，满足不同业务场景的需求。第三是高性能与低成本兼得，表格存储提供毫秒级延迟的读写能力，同时通过存储分层和冷热数据分离等机制控制成本。最后是强大的索引与检索能力，多元索引支持全文检索、向量检索、模糊查询等多种复杂查询模式。
Tablestore提供了三种数据存储模型。宽表模型是最基础也最常用的模型，类似于Bigtable或HBase的数据模型，适用于大多数结构化数据存储场景。时序模型专门针对时间序列数据的特点进行设计，适用于物联网设备监控、设备采集数据、机器监控数据等场景，能提供高并发写入和查询以及PB级海量数据的低成本存储。消息模型（Timeline模型）针对消息类业务场景优化，适用于IM、Feed流等应用。开发者可以根据实际业务需求选择合适的数据模型。
需要先登录阿里云控制台，点击：阿里云控制台
2. 准备工作：开通服务与创建实例
在使用表格存储之前，需要进行一系列准备工作。首先需要开通Tablestore服务。如果尚未开通，可以登录阿里云控制台，在产品列表中找到表格存储Tablestore，按照页面提示完成开通操作。开通服务本身是免费的，后续按照实际使用的存储量、读写吞吐量和外网流量进行按量计费。
开通服务后，下一步是创建Tablestore实例。实例是表格存储中的资源管理单元，类似于数据库中的集群概念。创建实例时需要选择实例规格和计费模式。表格存储提供两种实例类型：VCU模式（预留模式）和CU模式（按量付费）。VCU模式适合业务负载相对稳定的场景，通过预留计算单元来保障性能；CU模式适合业务负载波动较大的场景，按实际使用的读写吞吐量计费，更加灵活。此外，创建实例时还需要选择地域、配置网络（如VPC或经典网络）和设置访问控制策略。
如果是时序模型的使用场景，需要在创建实例时选择时序模型实例类型。目前支持时序模型功能的地域包括华东1（杭州）、华东2（上海）、华北2（北京）、华北3（张家口）、华北6（乌兰察布）、华南1（深圳）、西南1（成都）、中国香港、日本（东京）、新加坡等。其中，Lastpoint索引、时序分析存储、自定义时间轴标识等功能仅在华东1、华东2、华北2和华北3地域可用。
创建完实例后，需要获取实例的访问地址（Endpoint）。Endpoint的格式通常为：https://..ots.aliyuncs.com。同时还需要准备AccessKey ID和AccessKey Secret，用于SDK调用时的身份认证。建议使用RAM子账号的AccessKey进行最小权限授权，避免主账号密钥泄露的风险。
3. 数据模型深度解析
3.1 宽表模型（WideColumn）
宽表模型是Tablestore最基础也最常用的数据模型，类似于Bigtable或HBase的数据模型。它通过数据表采用三维结构（行、列和时间）存储数据。数据表的每一行可以有不同的列，可以动态增加或者减少属性列，创建表时无需为表的属性列定义严格的Schema。宽表模型的核心组件包括表、主键和属性列。一个数据表支持最多4个主键列，其中第一列主键列默认为分区键。属性列在创建数据表时无需预先定义，每行可以有不同的属性列，属性列名称在写入数据时指定。宽表模型单表支持PB级数据和千万级QPS，适用于元数据存储和大数据场景。
3.2 时序模型（TimeSeries）
时序模型专门针对时间序列数据的特点进行设计。在时序模型中，采用一张二维的时序表来存储时序数据。每行代表一个时间轴在某个时间点的数据，该行的主键部分为时间轴标识和时间戳，该行的数据列部分为该时间轴在该时间戳下的数据点，可以有多列。主键结构和数据列的结构无须用户进行预先定义。时序模型适用于物联网设备监控、设备采集数据、机器监控数据等场景，支持自动构建时序元数据索引、丰富的时序查询能力等功能。时序模型通过时序表存储时间序列数据。
3.3 消息模型（Timeline）
消息模型（Timeline模型）是针对消息数据场景所设计的。它能够满足消息数据场景对消息保序、海量消息存储、实时同步的业务需求，同时支持全文检索与多维度组合查询。Timeline模型适用于IM、Feed流等消息场景。Tablestore自研的Timeline模型能够抽象出支撑海量Topic的轻量级消息队列，可以存储大量社交信息，包括IM聊天，以及评论、跟帖和点赞等Feed流信息。
4. SDK安装与客户端初始化
Tablestore为开发者提供了多种主流编程语言的SDK。以下是四种主流语言的SDK安装与客户端初始化方法。
4.1 Java SDK
在Maven项目中，添加以下依赖到pom.xml文件：
<dependency> <groupId>com.aliyun.openservices</groupId> <artifactId>tablestore</artifactId> <version>5.17.7</version> </dependency>
客户端初始化示例：
import com.alicloud.openservices.tablestore.SyncClient; import com.alicloud.openservices.tablestore.model.*; public class TablestoreClientExample { public static void main(String[] args) { String endpoint = "https://<instance>.<region>.ots.aliyuncs.com"; String accessKeyId = "<your-access-key-id>"; String accessKeySecret = "<your-access-key-secret>"; String instanceName = "<your-instance-name>"; SyncClient client = new SyncClient(endpoint, accessKeyId, accessKeySecret, instanceName); // 使用client进行操作 } }
4.2 Python SDK
使用pip安装：
pip install tablestore
或指定版本：
pip install "tablestore>=6.4.5"
客户端初始化示例：
from tablestore import OTSClient client = OTSClient( "https://<instance>.<region>.ots.aliyuncs.com", "<your-access-key-id>", "<your-access-key-secret>", "<your-instance-name>" )
4.3 Node.js SDK
使用npm安装：
npm install tablestore
客户端初始化示例：
const OTSClient = require('tablestore'); const client = new OTSClient({ accessKeyId: '<your-access-key-id>', secretAccessKey: '<your-access-key-secret>', endpoint: 'https://<instance>.<region>.ots.aliyuncs.com', instanceName: '<your-instance-name>' });
4.4 Go SDK
Go SDK支持宽表模型、时序模型和消息模型。安装要求Go 1.4及以上版本。使用go get安装：
go get github.com/aliyun/aliyun-tablestore-go-sdk
5. 核心数据操作
5.1 创建数据表
创建数据表是使用Tablestore的第一步。创建数据表时需要指定表名、主键 schema 和表选项。以下以Java SDK为例：
import com.alicloud.openservices.tablestore.model.*; import com.alicloud.openservices.tablestore.SyncClient; public class CreateTableExample { public static void main(String[] args) { SyncClient client = new SyncClient(endpoint, accessKeyId, accessKeySecret, instanceName); // 定义主键schema，支持1-4列 TableMeta tableMeta = new TableMeta("sample_table"); tableMeta.addPrimaryKeyColumn("pk1", PrimaryKeyType.STRING); tableMeta.addPrimaryKeyColumn("pk2", PrimaryKeyType.INTEGER); // 定义表选项 TableOptions tableOptions = new TableOptions(); tableOptions.setTimeToLive(-1); // 数据永不过期 tableOptions.setMaxVersions(1); // 保留1个版本 CreateTableRequest request = new CreateTableRequest(tableMeta, tableOptions); CreateTableResponse response = client.createTable(request); } }
5.2 写入数据
Tablestore提供了单行和批量的方式写入数据。单行写入使用PutRow接口，批量写入使用BatchWriteRow接口。以下以Java SDK为例：
// 单行写入 PrimaryKey primaryKey = PrimaryKeyBuilder.createPrimaryKeyBuilder() .addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("user001")) .addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromLong(1)) .build(); RowPutChange rowPutChange = new RowPutChange("sample_table", primaryKey); rowPutChange.addColumn("name", ColumnValue.fromString("张三")); rowPutChange.addColumn("age", ColumnValue.fromLong(25)); rowPutChange.addColumn("email", ColumnValue.fromString("zhangsan@example.com")); PutRowRequest request = new PutRowRequest(rowPutChange); PutRowResponse response = client.putRow(request); // 批量写入 BatchWriteRowRequest batchRequest = new BatchWriteRowRequest(); // 添加多行PutRowChange到batchRequest BatchWriteRowResponse batchResponse = client.batchWriteRow(batchRequest);
Python SDK写入示例：
# 单行写入 primary_key = [('pk1', 'user001'), ('pk2', 1)] attribute_columns = [('name', '张三'), ('age', 25), ('email', 'zhangsan@example.com')] client.put_row('sample_table', primary_key, attribute_columns) # 批量写入 rows = [ (('pk1', 'user001'), ('pk2', 1), [('name', '张三'), ('age', 25)]), (('pk1', 'user002'), ('pk2', 1), [('name', '李四'), ('age', 30)]) ] client.batch_write_row('sample_table', rows)
5.3 读取数据
Tablestore支持单行读取（GetRow）、范围读取（GetRange）和批量读取（BatchGetRow）。以下以Java SDK为例：
// 单行读取 PrimaryKey primaryKey = PrimaryKeyBuilder.createPrimaryKeyBuilder() .addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("user001")) .addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromLong(1)) .build(); GetRowRequest request = new GetRowRequest("sample_table", primaryKey); GetRowResponse response = client.getRow(request); Row row = response.getRow(); // 范围读取 RangeRowQueryCriteria criteria = new RangeRowQueryCriteria("sample_table"); PrimaryKey startKey = PrimaryKeyBuilder.createPrimaryKeyBuilder() .addPrimaryKeyColumn("pk1", PrimaryKeyValue.INF_MIN) .addPrimaryKeyColumn("pk2", PrimaryKeyValue.INF_MIN) .build(); PrimaryKey endKey = PrimaryKeyBuilder.createPrimaryKeyBuilder() .addPrimaryKeyColumn("pk1", PrimaryKeyValue.INF_MAX) .addPrimaryKeyColumn("pk2", PrimaryKeyValue.INF_MAX) .build(); criteria.setInclusiveStartPrimaryKey(startKey); criteria.setExclusiveEndPrimaryKey(endKey); criteria.setLimit(100); getRangeRequest = new GetRangeRequest(criteria); GetRangeResponse rangeResponse = client.getRange(getRangeRequest);
5.4 更新与删除数据
更新数据使用UpdateRow接口，删除数据使用DeleteRow接口。更新支持添加、更新或删除指定属性列：
// 更新数据 PrimaryKey primaryKey = PrimaryKeyBuilder.createPrimaryKeyBuilder() .addPrimaryKeyColumn("pk1", PrimaryKeyValue.fromString("user001")) .addPrimaryKeyColumn("pk2", PrimaryKeyValue.fromLong(1)) .build(); RowUpdateChange rowUpdateChange = new RowUpdateChange("sample_table", primaryKey); rowUpdateChange.put("age", ColumnValue.fromLong(26)); // 更新age列 rowUpdateChange.put("phone", ColumnValue.fromString("13800138000")); // 新增phone列 rowUpdateChange.delete("email"); // 删除email列 UpdateRowRequest request = new UpdateRowRequest(rowUpdateChange); UpdateRowResponse response = client.updateRow(request); // 删除数据 DeleteRowRequest deleteRequest = new DeleteRowRequest( new RowDeleteChange("sample_table", primaryKey) ); DeleteRowResponse deleteResponse = client.deleteRow(deleteRequest);
6. 高级功能
6.1 多元索引
多元索引是Tablestore提供的一种强大的查询能力。如果实际业务中要用到非主键列查询、多条件组合查询等多种查询功能，可以为数据表创建多元索引，然后使用多元索引查询数据。多元索引支持向量、标量、全文检索等各种类型的组合查询。查询时可自由组合这些字段，还支持多种逻辑关系查询，例如And、Or、Not。创建多元索引时，可以选择部分主键列作为路由字段，在索引数据写入时，Tablestore会根据路由字段的值计算索引数据的分布位置，路由字段值相同的记录会被索引到相同的数据分区中。
以下以Java SDK为例创建多元索引：
import com.alicloud.openservices.tablestore.model.search.*; import com.alicloud.openservices.tablestore.model.search.index.*; CreateSearchIndexRequest request = new CreateSearchIndexRequest(); request.setTableName("sample_table"); request.setIndexName("sample_index"); // 定义索引schema IndexSchema indexSchema = new IndexSchema(); indexSchema.addFieldSchema(new FieldSchema("name", FieldType.KEYWORD)); indexSchema.addFieldSchema(new FieldSchema("age", FieldType.LONG)); indexSchema.addFieldSchema(new FieldSchema("email", FieldType.KEYWORD)); request.setIndexSchema(indexSchema); CreateSearchIndexResponse response = client.createSearchIndex(request);
6.2 通道服务
通道服务是基于表格存储数据接口上的全增量一体化服务。在为数据表建立数据通道后，可以通过流式计算的方式对表中历史存量和新增数据进行消费处理。通道服务支持实时消费数据，使用前需要为数据表创建通道，然后通过通道消费表中数据。Tablestore的Java SDK提供了通道服务的多个接口封装，包括管控接口和自动化的数据消费框架两部分。通道服务同步到Lucene且索引建立完成，需要1秒以上的时间。
6.3 全局二级索引与局部事务
全局二级索引将主键查询的能力扩展到了其它的属性列，相当于给数据表提供另外一种排序方式。通过二级索引，可以使用非主键列作为查询条件来加速数据查询。局部事务则提供了在分区键范围内的原子性操作能力，适用于需要事务保证的场景。
7. 生态集成
7.1 实时计算Flink集成
表格存储中的数据表或时序表均可作为实时计算Flink的源表或结果表进行使用。实时计算Flink版内置了表格存储Tablestore连接器，用于Tablestore的数据读写与同步。利用Tablestore作为Flink作业的数据源，可以实现对海量结构化数据的实时采集与处理。实时计算Flink能够将通道服务的数据通道作为流式数据的输入，从而实现对表格存储数据的计算与分析。
7.2 数据迁移与同步
表格存储支持多种方式实现数据表间的数据迁移或同步。可通过通道服务、DataWorks、DataX或命令行工具等方式完成数据表到数据表的同步操作。DataX是一个异构数据源离线同步工具，支持包括MySQL、Oracle、HDFS、Hive和Tablestore等多种数据源之间的数据同步。通过DataX可以将Tablestore中的数据导出至本地CSV文件，表格存储中的数据表或时序表均可作为源表进行导出操作。
7.3 向量检索与AI场景
Tablestore的多元索引支持向量检索（KnnVectorQuery），使用数值向量进行近似最近邻查询。向量检索适用于检索增强生成（RAG）、推荐系统、相似性检测、自然语言处理与语义搜索等场景。Tablestore可作为高性能向量数据库，提供毫秒级查询响应，支持向量检索与全文检索混合的检索模式，单表可存储百亿级向量数据。基于Tablestore可以构建MCP服务，通过其向量、标量、全文检索的混合检索能力，为MCP工具提供高效的数据存储与检索解决方案。Tablestore的多元索引内部使用了向量检索功能。
8. 表设计最佳实践
表格存储按分区键范围自动将数据切分到多个服务节点。分区键选择不当会导致热点、数据倾斜或扩展瓶颈。主键设计的核心目标是让数据和访问压力均匀分散，避免热点。
8.1 数据散列与热点规避
在分布式数据系统中，数据分布不均匀会导致读写能力受限于单个分区、热点数据分布不均导致长尾效应、热点分区成为整个业务链路的瓶颈等问题。数据均匀分布在多个分区时，读写压力分散到各分区，每个请求仅覆盖局部数据，可通过增加机器资源实现水平扩展。
以监控场景为例，如果主键设计为Timestamp作为分区键、MachineIp作为第二列，每次写入都追加到表的末尾，产生尾部热点。解决方法有三种。方法一：调整分区键顺序，将MachineIp放到主键第一列，Timestamp放到第二列，写入压力按机器维度分散到不同分区。方法二：拼接MD5前缀，对MachineIp计算MD5取前4位拼接到IP前面作为分区键，打散IP段的顺序性。方法三：对于有全局有序需求的场景，可采用局部有序、分桶写入或多元索引等替代方案。
8.2 主键列长度与数据量约束
同一分区键值下的数据量建议控制在10GB以内，因为相同分区键值的行无法进一步切分。主键列长度限制为1KB。如果业务负载较低（TPS/QPS在1000以下、数据量在10GB以内且不会大幅增长），热点问题的影响较小。但如果属性列中需要存储超过2MB的数据（如图片、音乐和文件），建议使用OSS来存储数据。
9. 常见问题与解答
问1：Tablestore与OSS有什么区别？如何选择？
答：Tablestore是NoSQL数据库服务，面向结构化数据，支持主键查询、二级索引、多元索引等丰富的数据操作能力；OSS是对象存储服务，面向非结构化数据（图片、视频、文件等）。如果属性列中需要存储超过2MB的大型文件，建议使用OSS存储文件，在Tablestore中仅存储文件引用。
问2：Tablestore支持SQL查询吗？
答：Tablestore原生不支持SQL，但可以通过PrestoDB对接后使用SQL查询与分析Tablestore中的数据。此外，也可以通过MaxCompute等大数据分析工具访问Tablestore。
问3：出现Signature mismatch异常如何解决？
答：该异常通常是由于初始化Tablestore Client时设置的AccessKey ID或AccessKey Secret不匹配导致的。请在初始化客户端时填写正确的AccessKey。建议使用RAM子账号的AccessKey，并确保该账号具有操作Tablestore的相应权限。
问4：Tablestore如何保证数据安全？
答：Tablestore通过对称签名的方法验证请求来源。用户需要在AccessKey控制台上创建AccessKey，AccessKey ID用于标识用户，AccessKey Secret用于对请求和响应进行签名和验证。此外，表格存储支持VPC网络访问、RAM权限管理、数据加密等多种安全机制。
问5：Tablestore的计费方式有哪些？
答：表格存储提供两种计费模式：VCU模式（预留模式）和CU模式（按量付费）。VCU模式适合业务负载相对稳定的场景，通过预留计算单元来保障性能；CU模式适合业务负载波动较大的场景，按实际使用的读写吞吐量计费。此外，存储费用按数据总量按小时计费。
问6：Tablestore单表能支持多大容量？
答：表格存储单表支持PB级存储和千万级TPS。通过合理的分区键设计，数据可以自动分散到多个服务节点，实现水平扩展。建议同一分区键值下的数据量控制在10GB以内。
