如何向Azure Function传递多值GET参数并用于CosmosDB查询

我完全理解你的需求——必须在CosmosDB端完成过滤，绝不能把1500万条数据拉到Function里处理，这个思路非常正确。你遇到的问题核心在于：CosmosDB的输入绑定无法自动将多值参数（比如documentIDs=1&documentIDs=2）转换为IN子句所需的格式，直接用{documentIDs}会导致SQL语法错误或者匹配不到目标数据。

下面是具体的解决方案，推荐用CosmosDB SDK动态构建参数化查询，既安全又灵活：

步骤1：更新Function绑定配置 #

先修改你的function.json，移除预定义的sqlQuery，并配置注入CosmosClient实例（这样我们可以在代码中直接操作CosmosDB）：

{
  "bindings": [
    {
      "authLevel": "function",
      "type": "httpTrigger",
      "direction": "in",
      "name": "req"
    },
    {
      "type": "http",
      "direction": "out",
      "name": "res"
    },
    {
      "type": "documentDB",
      "name": "cosmosClient",
      "databaseName": "dp-db-04",
      "collectionName": "lastDataPointsCollection",
      "connection": "ldpdbconnectionstring",
      "direction": "in",
      "client": true // 注入CosmosClient实例
    }
  ],
  "disabled": false
}

步骤2：编写Function代码（以JavaScript为例） #

在代码中解析多值的documentIDs参数，构建参数化的IN查询（重点：避免SQL注入，同时保证语法正确）：

module.exports = async function (context, req) {
    // 获取URL中的documentIDs参数，兼容单个/多个值的情况
    const documentIDs = req.query.documentIDs || [];
    const idsArray = Array.isArray(documentIDs) ? documentIDs : [documentIDs];

    if (idsArray.length === 0) {
        context.res = {
            status: 400,
            body: "请提供documentIDs参数，例如：?documentIDs=1&documentIDs=2"
        };
        return;
    }

    // 构建参数化查询，彻底避免SQL注入风险
    const parameters = idsArray.map((id, index) => ({
        name: `@id${index}`,
        value: id // 注意：如果你的id是字符串类型，直接传字符串即可
    }));
    const inClause = parameters.map(p => p.name).join(', ');
    const sqlQuery = `SELECT * FROM c WHERE c.id IN (${inClause})`;

    try {
        // 获取CosmosDB容器实例
        const container = context.bindings.cosmosClient
            .database("dp-db-04")
            .container("lastDataPointsCollection");
        
        // 执行查询并返回结果
        const { resources } = await container.items.query({
            query: sqlQuery,
            parameters: parameters
        }).fetchAll();

        context.res = {
            body: resources
        };
    } catch (err) {
        context.res = {
            status: 500,
            body: `查询失败：${err.message}`
        };
    }
};

如果是C#版本，核心逻辑一致，代码示例如下：

using Microsoft.Azure.Functions.Worker;
using Microsoft.Azure.Functions.Worker.Http;
using Microsoft.Azure.Cosmos;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

public class MyFunc
{
    private readonly CosmosClient _cosmosClient;

    public MyFunc(CosmosClient cosmosClient)
    {
        _cosmosClient = cosmosClient;
    }

    [Function("myFunc")]
    public async Task<HttpResponseData> Run([HttpTrigger(AuthorizationLevel.Function, "get")] HttpRequestData req)
    {
        // 获取documentIDs参数
        if (!req.Query.TryGetValues("documentIDs", out var documentIDs))
        {
            var badRequest = req.CreateResponse(System.Net.HttpStatusCode.BadRequest);
            await badRequest.WriteStringAsync("请提供documentIDs参数，例如：?documentIDs=1&documentIDs=2");
            return badRequest;
        }

        var idsList = documentIDs.ToList();
        if (idsList.Count == 0)
        {
            var badRequest = req.CreateResponse(System.Net.HttpStatusCode.BadRequest);
            await badRequest.WriteStringAsync("documentIDs不能为空");
            return badRequest;
        }

        // 构建参数化查询
        var parameters = new List<QueryDefinitionParameter>();
        var inClauseParts = new List<string>();
        for (int i = 0; i < idsList.Count; i++)
        {
            var paramName = $"@id{i}";
            parameters.Add(new QueryDefinitionParameter(paramName, idsList[i]));
            inClauseParts.Add(paramName);
        }

        var query = new QueryDefinition($"SELECT * FROM c WHERE c.id IN ({string.Join(", ", inClauseParts)})")
            .WithParameters(parameters);

        var container = _cosmosClient.GetContainer("dp-db-04", "lastDataPointsCollection");
        var iterator = container.GetItemQueryIterator<dynamic>(query);
        var results = new List<dynamic>();

        while (iterator.HasMoreResults)
        {
            var response = await iterator.ReadNextAsync();
            results.AddRange(response.Resource);
        }

        var okResponse = req.CreateResponse(System.Net.HttpStatusCode.OK);
        await okResponse.WriteAsJsonAsync(results);
        return okResponse;
    }
}

关键注意事项 #

1. SQL注入防护：绝对不要直接拼接用户输入的ID到SQL字符串中，必须使用参数化查询，上面的代码已经做了严格处理。
2. ID类型匹配：确保代码中传递的ID类型和CosmosDB中c.id的类型一致（比如字符串/数字），否则会出现查询无结果的情况。
3. 批量查询限制：CosmosDB的IN子句支持的参数数量有上限（建议单次不超过100个ID），如果需要查询更多ID，可以分批执行查询再合并结果。

这样修改后，你就可以通过blub.azure.net/API/myFunc?documentIDs=1&documentIDs=2这样的URL正常获取多个ID的文档，而且所有过滤逻辑都在CosmosDB端完成，不会拉取多余数据。

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