Azure Cosmos DB输入绑定-无法将OFFSET和LIMIT值作为参数传递?

p5cysglq  于 2023-03-31  发布在  其他
关注(0)|答案(2)|浏览(97)

我在尝试将OFFSETLIMIT的值作为查询参数动态传递给CosmosDB触发器时遇到了一个问题。
如果我将这两个值硬编码到查询中,它将按预期工作。
但是,使用此代码:

{
      "authLevel": "function",
      "type": "httpTrigger",
      "direction": "in",
      "name": "req",
      "route": "v1/query/properties",
      "methods": [
        "post"
      ]
    },
    {
      "name": "propertiesInquiryInput",
      "type": "cosmosDB",
      "databaseName": "property",
      "collectionName": "discovery",
      "connectionStringSetting": "CosmosDBConnectionString",
      "direction": "in",
      "leaseCollectionName": "leases",
      "sqlQuery": "SELECT * FROM c WHERE c.country={country} OFFSET {pageNo} LIMIT {perPage}"
    },

执行时出现以下故障:

System.Private.CoreLib: Exception while executing function: Functions.queryProperties. Microsoft.Azure.DocumentDB.Core: Message: {"errors":[{"severity":"Error","location":

{"start":48,"end":55},"code":"SC2062","message":"The OFFSET count value exceeds the maximum allowed value."},
{"severity":"Error","location":{"start":62,"end":70},"code":"SC2061","message":"The LIMIT count value exceeds the maximum allowed value."}]}

我对Azure服务及其模式相对较新,所以可能我错过了一些明显的东西。我尝试通过POST将这些值作为JSON对象发送,并通过GET请求作为查询参数发送。似乎没有任何效果。
我也不知道有什么方法可以查看SQL查询被触发的内容,所以也许可以从这个Angular 调试它。
更新:
为清晰起见,添加函数体:

module.exports = async function (context, req) {
    const results = context.bindings.propertiesInquiryInput;
    !results.length && context.done(null, { status: 404, body: "[]", });

    const body = JSON.stringify(results.map(data => reshapeResponse(data));

    return context.done(null, { status: 200, body });
}
nvbavucw

nvbavucw1#

  • 除了原来的问题:*

使用python的参数化查询和azure.cosmos=4.2.0 pypi包得到了相同的异常消息。
重现病例:

query = f"""
SELECT *
FROM c
WHERE ...
AND c.run.submittedBy = @author
OFFSET 0 LIMIT @exp_limit
"""

items = list(cdb_container.query_items(
    query=query,
    parameters=[
        {"name":"@exp_limit", "value": f"{num_of_experiments}"}, # can't pass as param due to `The LIMIT count value exceeds the maximum allowed value.`
        {"name":"@author", "value": f"{submitter}"},
    ],
    enable_cross_partition_query=True
))

解决方法(使用格式化字符串进行查询):

num_of_experiments = 10
query = f"""
SELECT *
FROM c
WHERE ...
AND c.run.submittedBy = @author
OFFSET 0 LIMIT {num_of_experiments}
"""

省略了WHERE语句中不相关的参数,用于示例目的。可能对正在处理类似情况的人有帮助。

6vl6ewon

6vl6ewon2#

这有点晚,但我有同样的问题,在我的情况下,这个错误是因为我作为offet传递的值是一个String。在我将其解析为Int之后,查询就像预期的那样工作了!

相关问题