Azure Function(TypeScript)自定义Cosmos DB SQL查询方案

你完全不需要搭建Durable Functions链路，这属于过度设计。最直接的方案是移除预设SQL的Cosmos DB输入绑定，直接在函数代码中通过Cosmos DB SDK自主获取连接、构造并执行查询，完全适配你的自定义查询构造需求。

具体实现步骤 #

• 保留你现有配置中存储在应用设置里的CosmosDbConnectionString，不需要额外调整密钥配置
• 为TypeScript Azure Function项目安装官方Cosmos DB SDK：执行命令npm install @azure/cosmos
• 移除function.json中固定配置sqlQuery的Cosmos DB输入绑定条目
• 在函数代码中按你的业务逻辑处理搜索参数、动态构造查询后执行，参考实现如下：

import { AzureFunction, Context, HttpRequest } from "@azure/functions";
import { CosmosClient, SqlQuerySpec } from "@azure/cosmos";

// 全局初始化Cosmos客户端做单例复用，避免每次函数调用重复建连
const cosmosClient = new CosmosClient(process.env.CosmosDbConnectionString);
const booksContainer = cosmosClient.database("books").container("books");

const httpTrigger: AzureFunction = async function (context: Context, req: HttpRequest): Promise<void> {
    // 读取原始搜索参数
    const rawSearchText = req.query.q ?? "";
    
    // 执行你的自定义查询预处理逻辑：转小写、分词、拼写纠错、过滤停用词、词干提取
    const processedKeywords = processSearchText(rawSearchText);

    // 构造参数化查询，避免SQL注入风险
    const querySpec: SqlQuerySpec = {
        query: `SELECT * FROM b WHERE ${processedKeywords.map((_, idx) => `ARRAY_CONTAINS(b.tokens, @kw${idx})`).join(" AND ")}`,
        parameters: processedKeywords.map((kw, idx) => ({
            name: `@kw${idx}`,
            value: kw
        }))
    };

    // 执行查询拿结果
    const { resources: searchResults } = await booksContainer.items.query(querySpec).fetchAll();

    context.res = {
        status: 200,
        body: searchResults
    };
};

/**
 * 自定义搜索文本处理逻辑
 */
function processSearchText(raw: string): string[] {
    // 在这里实现你的5步处理逻辑即可
    // 示例输入"teh Lord of the Ringgs"，输出["lord", "ring"]
    return [];
}

export default httpTrigger;

方案优势 #

• 架构简单无额外开销：不需要多函数编排，单函数内完成全流程，延迟更低
• 灵活度完全满足需求：查询构造逻辑100%由代码控制，不受绑定内置的简单参数替换规则限制
• 性能无损失：Cosmos DB输入绑定底层同样依赖@azure/cosmos实现，全局单例客户端的模式下连接复用效率更高
• 更安全：使用SDK自带的参数化查询能力，避免手动拼接SQL带来的注入风险

你猜测的Durable Functions方案不是必须选项，输入绑定本身是为固定查询、简单参数替换的轻量场景设计的，当你需要动态生成复杂查询时，直接在代码中使用SDK是官方推荐的标准用法。

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