如何在Azure Functions JS v4中用HTTP请求userId配置Cosmos DB输入绑定？

可以通过绑定表达式传递HTTP请求中的userId值到CosmosDB输入绑定，但你之前的代码错误地使用了{request.user.id}这个无效的绑定表达式。以下是修正方案：

核心问题说明 #

{request.user.id}并非HTTP请求参数的正确绑定格式：

• 匿名认证模式下request.user不存在，这是针对已认证用户的主体对象
• HTTP请求的参数需要通过路由参数、查询参数或请求头的绑定表达式来获取

修正方案示例 #

方案1：使用路由参数传递userId #

将userId作为URL路由的一部分，绑定表达式直接引用路由参数名：

const { app, input } = require('@azure/functions');

// 绑定表达式{userId}对应路由中的参数
const cosmosInput = input.cosmosDB({
  databaseName: 'rcmapp',
  collectionName: 'users',
  id: '{userId}',
  partitionKey: '{userId}',
  connectionStringSetting: 'COSMOS_CONNECTION_STRING'
});

app.http('userDetails', {
  methods: ['GET'],
  authLevel: 'anonymous',
  route: 'userDetails/{userId}', // 定义路由参数
  extraInputs: [cosmosInput],
  handler: (request, context) => {
    const userId = context.bindingData.userId;
    context.log(`User details function triggered for userId: ${userId}`);
    
    const userDetails = context.extraInputs.get(cosmosInput);
    if (!userDetails) {
      return { 
        status: 404, 
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify({ message: '用户未找到' }) 
      };
    }

    return {
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify(userDetails)
    };
  }
});

方案2：使用查询参数传递userId #

如果userId通过URL查询参数（如?userId=xxx）传递，使用{query.userId}作为绑定表达式：

const { app, input } = require('@azure/functions');

// 绑定表达式{query.userId}对应查询参数
const cosmosInput = input.cosmosDB({
  databaseName: 'rcmapp',
  collectionName: 'users',
  id: '{query.userId}',
  partitionKey: '{query.userId}',
  connectionStringSetting: 'COSMOS_CONNECTION_STRING'
});

app.http('userDetails', {
  methods: ['GET'],
  authLevel: 'anonymous',
  extraInputs: [cosmosInput],
  handler: (request, context) => {
    const userId = context.bindingData.query?.userId;
    if (!userId) {
      return { 
        status: 400, 
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify({ message: '缺少userId参数' }) 
      };
    }
    
    context.log(`User details function triggered for userId: ${userId}`);
    const userDetails = context.extraInputs.get(cosmosInput);
    
    if (!userDetails) {
      return { 
        status: 404, 
        headers: { 'Content-Type': 'application/json' },
        body: JSON.stringify({ message: '用户未找到' }) 
      };
    }

    return {
      headers: { 'Content-Type': 'application/json' },
      body: JSON.stringify(userDetails)
    };
  }
});

关键注意事项 #

• 绑定表达式由Azure Functions运行时自动解析，无需在处理程序外部访问request对象
• context.extraInputs.get(cosmosInput)返回的已是解析后的JSON对象，无需再调用JSON.parse
• 需确保CosmosDB中用户文档的id和分区键值与传入的userId完全匹配

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