Azure Cosmos DB基于优先级的执行失败问题求助

从你遇到的问题来看，核心是参数化查询的格式不符合Azure Cosmos DB的要求，以下是具体的修复步骤：

1. 修正SQL查询的参数写法 #

Azure Cosmos DB要求参数化查询用@作为参数前缀，参数需要单独传入，不能直接在SQL语句里硬编码带引号的值。
错误写法（大概率是你代码里的问题）：

# 错误：直接在查询里写死参数值，或参数格式不符合规范
query = "SELECT * FROM c WHERE c.priority_level = 'High'"

正确写法：

# 用@定义参数占位符
query = "SELECT * FROM c WHERE c.priority_level = @priority"
# 参数列表必须是包含name和value键的字典数组
parameters = [{"name": "@priority", "value": "High"}]

2. 完整可运行的查询代码示例 #

from azure.cosmos import CosmosClient

# 初始化Cosmos客户端
client = CosmosClient("你的Cosmos DB端点地址", "你的账户访问密钥")
# 获取目标容器
container = client.get_database_client("数据库名称").get_container_client("容器名称")

# 构造参数化查询
query = "SELECT * FROM c WHERE c.priority_level = @priority"
params = [{"name": "@priority", "value": "High"}]

# 执行查询（若容器有分区键，需开启跨分区查询或指定分区键过滤）
try:
    result_items = list(container.query_items(
        query=query,
        parameters=params,
        enable_cross_partition_query=True
    ))
    for item in result_items:
        print(item)
except Exception as e:
    print(f"查询执行错误: {str(e)}")

3. 额外排查点 #

• 确保azure-cosmos SDK为最新稳定版，旧版本可能存在参数解析bug：

  pip install --upgrade azure-cosmos
  

• 如果容器设置了分区键，要么在查询语句中添加分区键过滤条件，要么开启enable_cross_partition_query=True，否则会触发跨分区查询相关错误。

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