Cosmos DB中的MaxItemCount提要选项属性不起作用

2022-03-11 00:00:00 javascript azure-cosmosdb

我正在尝试编写一个运行SQL查询的简单存储过程,并且希望通过使用MaxItemCount属性来限制结果。查询生成3个文档,但我只想返回1个文档。我正在使用MaxItemCount属性强制此限制,但这似乎不起作用。

function uspGetDetailsByEmailId(EmailId) {
  var collection = getContext().getCollection();
  var collectionLink = collection.getSelfLink();
  var response = getContext().getResponse();
  var recordcount = 0;
  if (!EmailId) throw new Error("Please provide the EmailId for which     Details need to be retrieved");     

  retrieveDetails();     

  function retrieveDetails() {
    var requestOptions = {MaxItemCount: "1"};
    var dbquery = {query: "SELECT * FROM c"};
    var isAccepted = collection.queryDocuments(collectionLink, dbquery, requestOptions,function (err, results) {
      console.log(results.length)  
      response.setBody(results)
      if (err) throw err;                   
    });

    if (!isAccepted) {
      response.setBody(null);
    }
  }
}

解决方案

MaxItemCount不是对整个查询将返回的文档量的限制。

Cosmos DB始终返回分页数据。这意味着如果您取回100个文档,那么这些文档是从许多请求中返回的,每个请求的文档量相同或几乎相同,这是一个很好的变化。然后将它们相加并返回。

MaxItemCount是单次Cosmos DB的最大文档帐号,但是如果您使用queryDocuments方法查询数据,那么您将获得相同的数据量,但是您将限制每次Cosmos DB最多携带1个文档。

在这种情况下,您要做的是使用查询迭代器,并在拥有第一个文档后转义迭代器的循环。

更深入地了解这一点(主要使用我能找到的唯一文档https://azure.github.io/azure-cosmosdb-js-server),看起来存储过程使用的js-server完全是一个不同的SDK。

进一步深入研究后,我发现RequestOptions对象中没有MaxItemCount属性(即使有,也会是一个整数)。但是,有一个名为pageSize的属性,您可以在https://azure.github.io/azure-cosmosdb-js-server/DocDbWrapperScript.js.html的第554行看到。

测试后,似乎将pageSize设置为1将成功将结果限制为所需数量。

以下是更新后的代码:

function uspGetDetailsByEmailId(EmailId) {
  var collection = getContext().getCollection();
  var collectionLink = collection.getSelfLink();
  var response = getContext().getResponse();
  var recordcount = 0;
  if (!EmailId) throw new Error("Please provide the EmailId for which     Details need to be retrieved");     

  retrieveDetails();     

  function retrieveDetails() {
    var requestOptions = { pageSize: 1};
    var dbquery = {query: "SELECT * FROM c"};
    var isAccepted = collection.queryDocuments(collectionLink, dbquery, requestOptions,function (err, results) {
      console.log(results.length)  
      response.setBody(results)
      if (err) throw err;                   
    });

    if (!isAccepted) {
      response.setBody(null);
    }
  }
}

相关文章