表格存储 Python SDK 通过 SQL 写入数据-表格存储 Tablestore(Tablestore)-阿里云帮助中心

通过 Python SDK 执行 INSERT 语句，向未开启局部事务功能的数据表写入一行或多行数据。

前提条件

安装Tablestore Python SDK并初始化客户端。
SQL 查询功能需要使用 5.4.2 及以上版本，建议使用最新版本。
已为待操作的数据表创建映射关系，且数据表未开启局部事务功能。
使用 RAM 用户时，已授予 SQL_DML 权限。

功能说明

调用 exe_sql_query 方法执行 INSERT 语句，写入一行数据。如果指定的主键已存在，请求会失败。

def exe_sql_query(self, query)

以下示例向 example_table 写入一行数据。

query = (
    "INSERT INTO example_table (tenant_id, pk, name, score) "
    "VALUES (1, 'row1', 'example', 10)"
)
row_list, table_capacity_units, _ = client.exe_sql_query(query)

参数说明

exe_sql_query 方法包含以下参数。

名称	类型	说明
query（必选）	String	要执行的 `INSERT` 语句，用于指定映射表名称、待写入的列和列值。

返回值

exe_sql_query 方法返回一个三元组，包含以下元素。

元素	类型	说明
`row_list`	List[Row]	SQL 写入不返回数据行，因此该元素为空列表。
`table_capacity_units`	List[Tuple]	各数据表消耗的读写 CU。每个元组包含数据表名称和 `CapacityUnit` 对象。
`search_capacity_units`	List[Tuple]	各多元索引消耗的读写 CU。每个元组包含多元索引名称和 `CapacityUnit` 对象。

场景示例

批量写入数据

一条 INSERT 语句最多写入 200 行。多行数据必须具有相同的分区键，并作为原子操作执行：全部写入成功或全部写入失败。

query = (
    "INSERT INTO example_table (tenant_id, pk, name, score) VALUES "
    "(1, 'row1', 'example-a', 10), "
    "(1, 'row2', 'example-b', 20), "
    "(1, 'row3', 'example-c', 30)"
)
client.exe_sql_query(query)