如何使用Azure Cloud Function从CosmosDB中删除文档？

嘿，我来帮你搞定Azure Functions里CosmosDB文档删除的问题！你已经搞定了增、查、改，就差最后这一步删除，其实有两种实用的方法，我给你拆解清楚：

方法1：用输出绑定删除单个文档 #

这种方法适合你明确知道要删除文档的id和对应分区键的场景，是最直接高效的方式。

步骤1：配置函数绑定 #

在function.json里添加一个CosmosDB输出绑定，指定operationType为Delete：

{
  "type": "cosmosDB",
  "direction": "out",
  "name": "outputDocument",
  "databaseName": "YourDBName",
  "collectionName": "YourCollectionName",
  "connectionStringSetting": "CosmosDBConnection",
  "operationType": "Delete"
}

步骤2：编写删除逻辑 #

在函数代码里，只需要传入要删除文档的id和分区键值，绑定就会自动执行删除操作。这里以C#为例：

public static async Task Run(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = null)] HttpRequest req,
    [CosmosDB(
        databaseName: "YourDBName",
        collectionName: "YourCollectionName",
        ConnectionStringSetting = "CosmosDBConnection",
        OperationType = OperationType.Delete)] IAsyncCollector<dynamic> outputDocument)
{
    // 从请求体获取要删除的文档id和分区键
    var requestBody = await new StreamReader(req.Body).ReadToEndAsync();
    var deleteItem = JsonConvert.DeserializeObject<dynamic>(requestBody);
    
    // 仅需提供id和分区键，绑定会自动完成删除
    await outputDocument.AddAsync(new { id = deleteItem.id, partitionKey = deleteItem.partitionKey });
}

注意：如果你的容器分区键字段不是partitionKey，记得替换成你实际的字段名（比如userId、categoryId等）。

方法2：通过CosmosDB SDK批量删除多个文档 #

如果你需要筛选一批文档删除（比如你之前尝试的从整个集合中筛选后删除），直接用输入绑定获取集合再“移除”项的方式是行不通的——因为输入绑定是只读的，输出绑定也无法直接删除集合中的现有项。这时候用CosmosDB SDK来实现更靠谱：

步骤1：初始化Cosmos客户端 #

首先确保你的函数项目安装了Microsoft.Azure.Cosmos NuGet包，然后初始化客户端：

private static readonly CosmosClient cosmosClient = new CosmosClient(Environment.GetEnvironmentVariable("CosmosDBConnection"));

步骤2：编写批量删除逻辑 #

先查询出符合条件的文档，再逐个执行删除操作：

public static async Task Run(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = null)] HttpRequest req)
{
    var database = cosmosClient.GetDatabase("YourDBName");
    var container = database.GetContainer("YourCollectionName");
    
    // 编写查询条件，比如删除所有状态为"过期"的文档
    var query = new QueryDefinition("SELECT * FROM c WHERE c.status = @status")
        .WithParameter("@status", "过期");
    
    var iterator = container.GetItemQueryIterator<dynamic>(query);
    var deleteTasks = new List<Task>();
    
    while (iterator.HasMoreResults)
    {
        var results = await iterator.ReadNextAsync();
        foreach (var item in results)
        {
            // 删除文档必须提供id和对应的分区键
            deleteTasks.Add(container.DeleteItemAsync<dynamic>(item.id, new PartitionKey(item.partitionKey)));
        }
    }
    
    // 等待所有删除任务完成
    await Task.WhenAll(deleteTasks);
}

小提示：如果要删除的文档数量很大，建议分批次处理，避免触发CosmosDB的速率限制；也可以考虑使用CosmosDB存储过程来提升批量删除的效率。

关键注意事项 #

• 不管用哪种方法，删除文档必须同时提供id和对应的分区键，这是CosmosDB的硬性要求，因为只有这样才能精准定位到要删除的文档。
• 你之前尝试的“通过输入绑定获取整个集合，筛选后设置输出”的思路是错误的，因为输出绑定的作用是创建或更新文档，无法直接删除现有文档。

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