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

前提条件

安装Tablestore Python SDK并初始化客户端。
SQL 查询功能需要使用 5.4.2 及以上版本，建议使用最新版本。
已为待操作的数据表创建映射关系。

功能说明

调用 exe_sql_query 方法执行 SELECT 语句，查询映射表中的数据。

def exe_sql_query(self, query)

以下示例查询 example_table 中主键为 row1 的数据。

query = (
    "SELECT pk, long_value, double_value, string_value, bool_value "
    "FROM example_table WHERE pk = 'row1' LIMIT 20"
)
row_list, table_capacity_units, search_capacity_units = client.exe_sql_query(query)

for row in row_list:
    print(dict(row.attribute_columns))

参数说明

exe_sql_query 方法包含以下参数。

名称	类型	说明
query（必选）	String	要执行的 `SELECT` 语句，用于指定映射表、返回列、查询条件和返回行数等。

返回值

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

元素	类型	说明
`row_list`	List[Row]	查询结果行列表。每个 `Row` 对象的 `attribute_columns` 属性包含列名和值。
`table_capacity_units`	List[Tuple]	各数据表消耗的读写 CU。每个元组包含数据表名称和 `CapacityUnit` 对象。
`search_capacity_units`	List[Tuple]	各多元索引消耗的读写 CU。每个元组包含多元索引名称和 `CapacityUnit` 对象。