用于Azure Cosmos的Mongo驱动程序-读取和速率限制

Question

以下配置出现问题，

public DatabaseQueryResult find(String collectionName, Map<String, Object> queryData) {

    Document toFind = new Document(queryData);
    MongoCollection<Document> collection = this.mongoDatabase.getCollection(collectionName);

    FindIterable<Document> findResults = collection.find(toFind);

    if (findResults != null) {
        Document dataFound = findResults.first();
        return new DatabaseQueryResult(dataFound.toJson(this.settings))     
    }

    // other stuff...
}

{
   "$err":"Message: {\"Errors\":[\"Request rate is large. More Request Units may be needed, so no changes were made. Please retry this request later. Learn more: http://aka.ms/cosmosdb-error-429\"]}\r\n s",
   "code":16500,
   "_t":"OKMongoResponse",
   "errmsg":"Message: {\"Errors\":[\"Request rate is large. More Request Units may be needed, so no changes were made. Please retry this request later. Learn more: http://aka.ms/cosmosdb-error-429\"]}\r\n",
   "ok":0
}

我预计这里会抛出一个异常--但后面的驱动程序似乎不是这样。正在发生的是，

• collection.find返回一个FindIterable，其JSON错误结果如上，作为第一个文档
• 我们最终返回一个带有JSON错误的DatabaseQueryResult作为查询负载

我不希望这种情况发生--如果查询操作返回的OKMongoResponse中“OK”为0，我更希望mongo驱动程序抛出MongoCommandException/MongoQueryException。这在写中似乎很好，它将使用一个CommandProtocol对象，响应正如我所期望的那样得到了验证--只是读似乎发生了变化。

Answer 1

我不知道蒙哥为什么换了这个司机。宇宙方面有一些东西可能会有所帮助。您可以提出支持票，并要求他们打开服务器端重试。这将改变Cosmos的行为，这样请求会排队，而不是在太多时抛出429个。

这更多地反映了Mongo在VM或Atlas（也在VM上运行）中运行时的行为，而不是像Cosmos DB这样的多租户服务。