Cosmos DB无分区键时如何基于查询条件批量删除文档？

我来帮你梳理几个针对这种跨分区批量删除场景的可行方案，毕竟用存储过程的时候没法指定分区键确实挺头疼的：

1. Azure Functions + Cosmos DB 批量操作（推荐） #

这是我个人比较推荐的方案，灵活性和容错性都很强：

• 先在函数里执行跨分区查询，筛选出所有需要删除的文档，重点收集它们的id和对应的分区键值（Cosmos DB删除文档必须要这两个信息，哪怕你是跨分区操作）。
• 用Cosmos DB SDK的TransactionalBatch（.NET）或者BulkOperations（Java）把删除请求打包成批量任务，分批次发送。SDK会自动处理重试、限流这些问题，不用你手动写逻辑。
• 如果文档量特别大，可以把查询到的文档标识先放到Azure Queue Storage里，再开多个函数实例异步处理，提升删除效率。

2. 遍历所有分区键，逐个调用存储过程 #

如果你的集合有分区键，只是不想在查询时指定，可以先拿到所有唯一的分区键值：

• 执行查询：SELECT DISTINCT c.yourPartitionKey FROM c，获取所有分区键的取值。
• 对每个分区键，单独调用你现有的bulkDelete存储过程，把分区键作为参数传入，这样存储过程就能在对应分区里执行删除了。
• 注意：如果你的分区键基数很大（比如几十万上百万个分区），这个方法效率会很低，适合分区数量可控的场景。

3. 客户端直接用SDK批量删除 #

不用依赖存储过程，直接在客户端代码里完成跨分区删除：

• 用SDK开启跨分区查询，拿到所有符合条件的文档的id和分区键。比如.NET里设置QueryRequestOptions.EnableCrossPartitionQuery = true。
• 把删除请求分成多个批次（每个批次最多100个操作或10MB数据，符合Cosmos DB的批量限制），用DeleteItemAsync批量执行，或者用批量操作API来减少请求次数。
• 这种方法的好处是不需要在Cosmos DB里部署存储过程，调试和修改都更方便。

4. 用Azure Data Factory (ADF) 低代码批量删除 #

如果不想写代码，ADF是个不错的选择：

• 方案一：用复制活动，源是你的Cosmos DB集合，设置查询条件只返回需要保留的文档；目标还是同一个集合，写入行为选择“替换”或“Upsert”，这样就间接删除了不符合条件的文档。
• 方案二：用ADF的删除活动（需要ADF的最新版本支持），直接指定查询条件来删除符合要求的文档，不需要写任何代码，还能设置定时触发，适合周期性的清理任务。

几个通用注意事项 #

• 不管用哪种方法，都要注意Cosmos DB的RU限制，设置合理的重试策略（SDK一般会内置重试），避免被限流导致任务失败。
• 删除前一定要先跑查询确认要删除的文档数量，最好做个备份，避免误删。
• 如果文档量极大，建议分阶段处理，比如每天删除一部分，避免一次性占用太多RU影响业务。

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