从Azure Functions写入Azure Cosmos DB未创建实体的问题排查

嘿，我来帮你排查这个问题！从你描述的情况来看，函数能正常执行、Cosmos DB也收到了请求甚至创建了集合，但就是没生成实体，大概率是绑定配置或者代码处理环节出了小问题，咱们一步步来捋：

首先去看你的function.json里的绑定设置，这是最容易踩坑的地方：

• 确认partitionKey参数和你要写入的实体字段匹配。比如绑定里写了partitionKey: "/userId"，那你要写入的对象必须包含非空的userId字段——Cosmos DB对分区键的要求很严格，缺失或为空都会导致写入失败，但这种失败有时候不会直接抛出明显错误，只会让请求“无声”失效。
• 检查绑定的direction是不是out，类型是不是cosmosDB（旧版本可能是documentDB，要和你用的Functions runtime版本匹配）。举个标准的输出绑定配置例子：

  {
    "type": "cosmosDB",
    "name": "testDocument",
    "databaseName": "YourTargetDB",
    "collectionName": "YourTargetCollection",
    "connectionStringSetting": "CosmosDBConnectionString",
    "direction": "out",
    "partitionKey": "/userId"
  }
  

你提到用了JSON.stringify()给context.bindings.testDocument赋值，这里可能有问题：

• 如果是单个文档的输出绑定，不需要手动序列化，直接给JavaScript对象就行！Functions runtime会自动帮你完成序列化操作。手动转成字符串反而可能让Cosmos DB无法正确解析成实体。
• 另外，一定要确保你的对象包含id字段（除非你配置了Cosmos自动生成id），这是Cosmos DB文档的必填项，缺失的话写入会静默失败。

修正后的代码可以改成这样：

module.exports = function (context, message) {
  // 直接赋值对象，无需JSON.stringify
  context.bindings.testDocument = {
    id: Date.now().toString(), // 生成唯一id，避免重复
    userId: "sampleUser001", // 对应绑定里的partitionKey字段
    content: message, // 你的业务数据
    createdAt: new Date().toISOString()
  };

  context.done(); // 别忘了调用这个方法，通知Functions执行完成
};

• 试试用Cosmos DB Explorer执行SELECT * FROM c查询，而不是依赖默认的文档列表视图。如果你的集合索引策略被自定义修改过，可能会导致文档无法被默认列表展示，但实际已经写入了。
• 确认你的Cosmos DB账户一致性级别不是强一致性（虽然概率低，但强一致性可能带来短暂的写入延迟），或者等待几分钟再查看文档。

打开Azure Portal里你的Function App的日志（或者本地用func logstream实时查看），找有没有隐藏的错误信息。比如分区键缺失、id重复、连接字符串权限不足这些问题，都会在日志里留下记录——有时候函数看起来执行正常，但实际写入时Cosmos已经返回了错误，只是你的代码没捕获处理。

确认你用的是Cosmos DB账户的主连接字符串，而不是只读连接字符串。只读权限无法写入数据，虽然这种情况连集合都应该创建不了，但还是排查下更稳妥。

如果以上步骤都试过还是不行，可以用Cosmos DB SDK直接写入测试，来区分是绑定的问题还是Cosmos本身的问题：

const { CosmosClient } = require("@azure/cosmos");

module.exports = async function (context, message) {
  const client = new CosmosClient(process.env.CosmosDBConnectionString);
  const database = client.database("YourTargetDB");
  const container = database.container("YourTargetCollection");
  
  try {
    const { resource } = await container.items.create({
      id: "testDoc001",
      userId: "user001",
      data: message
    });
    context.log("成功写入文档:", resource);
  } catch (err) {
    context.error("写入失败，错误信息:", err);
  }

  context.done();
};

如果SDK写入成功，那就是输出绑定的配置有问题；如果SDK也失败，那就要重点排查Cosmos的权限或账户配置了。

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