Azure Function Javascript (NodeJS) CosmosDB 查询

Question

非常直接的问题。我的 index.js 文件中有以下函数。

const databaseId = config.database.id;
const collectionId = config.collection.id;
const client = new CosmosClient({ endpoint: CosmosDBName, auth: { masterKey: CosmosDBKey } });
const query = `SELECT c.message.id FROM ${collectionId} c WHERE c.message.timestampFormatted > '${start}' AND c.message.timestampFormatted < '${end}'`;

queryCosmosDB(client, databaseId, collectionId, query)

async function queryCosmosDB(client, databaseId, collectionId, query, context) {
    const querySpec = {
        query: query,
        parameters: []
    };

    const { result: results } = await client.database(databaseId).container(collectionId).items.query(querySpec).toArray();

    for (var queryResult of results) {
        let resultString = JSON.stringify(queryResult);
        context.log(`\tQuery returned ${resultString}\n`);
    }
}

如果我执行这个函数，响应是以下错误（我省略了一些无用的信息）

ERROR: {"code":400,"body":"{\"code\":\"BadRequest\",\"message\":\"Cross partition query is required but disabled. Please set x-ms-documentdb-query-enablecrosspartition to true, specify x-ms-documentdb-partitionkey, or revise your query to avoid this exception. ...}

现在，我得到了 CosmosDB 使用的分区架构，但就我而言，最好的做法是什么？我应该以某种方式更改查询吗？如果可以，如何更改？如果我必须插入某种跨分区查询字符串，我应该怎么做？

我发现的唯一其他问题是this SO's question，但我不像他那样管理数据，因为我认为 SDK 与一年半前相比发生了很大变化。我目前使用this tutorial 作为基线。

非常感谢您的帮助！

Answer 1

您可以简单地使用 NodeJS sdk 启用跨分区查询，方法是将其作为query 函数级别的选项的一部分提供。

async function queryCosmosDB(client, databaseId, collectionId, query, context) {
    const querySpec = {
        query: query,
        parameters: []
    };

    const options = {
        enableCrossPartitionQuery: true
      };

    const { result: results } = await client.database(databaseId).container(collectionId).items.query(querySpec, options).toArray();

    for (var queryResult of results) {
        let resultString = JSON.stringify(queryResult);
        context.log(`\tQuery returned ${resultString}\n`);
    }
}