如何在Spark SQL中修改Cosmos DB容器的TBLPROPERTIES？

核心限制 #

Spark SQL的Cosmos DB连接器目前不支持通过ALTER TABLE语句修改容器的吞吐量这类资源级属性，你遇到的UnsupportedOperationException正是因为这个限制——连接器的ALTER TABLE实现仅覆盖少数元数据修改，并未包含吞吐量调整这类操作。

Spark环境内的替代方案 #

如果想在Spark作业流程内完成吞吐量调整，不用切换到门户或CLI，可以直接在PySpark/Scala代码中调用Cosmos DB的原生SDK来修改容器吞吐量，步骤如下：

1. 安装依赖（PySpark环境）

先确保环境中安装了Azure Cosmos DB Python SDK：

pip install azure-cosmos

2. 编写PySpark代码修改吞吐量

在导入数据完成后，添加这段代码调整容器吞吐量：

from azure.cosmos import CosmosClient

# 替换为你的Cosmos DB账户信息
endpoint = "你的Cosmos DB账户端点"
key = "你的账户密钥"
database_name = "目标数据库名"
container_name = "目标容器名"

# 初始化客户端并修改吞吐量
client = CosmosClient(endpoint, key)
database = client.get_database_client(database_name)
container = database.get_container_client(container_name)

# 设置手动吞吐量为400
container.replace_throughput(throughput=400)

3. 说明

这种方式直接操作Cosmos DB的容器资源，完全在Spark作业流程内完成，不需要跳出到外部工具，同时能精准控制吞吐量调整时机。

补充说明 #

目前官方确实没有提供Spark SQL修改Cosmos DB表TBLPROPERTIES中吞吐量的文档，因为该功能本身未被连接器支持。如果后续需要依赖纯SQL方式调整，只能关注Cosmos DB Spark连接器的版本更新，看是否会新增该功能。

内容的提问来源于stack exchange，提问作者BeGreen