限制cosmosdb分区中的文档数

问题描述

我有一个cosmosdb集合，每个分区包含一组文档。我希望维护该集合，以使逻辑分区（在这种情况下为'id'）不会超过5个文档的限制。在下面的示例中，当添加第六个条目（例如，2020年8月11日）时，我要删除在2020年7月13日创建的文档，因为该文档最早进行了更新。 基本上，我要确保ID为12345的商品只有5个最新条目，并且没有更多条目。这是为了减少数据库中的数据，从而避免查询比所需更多的数据。

{
"id": 12345,"lastUpdated":  8/10/2020
},{
"id": 12345,"lastUpdated":  8/3/2020
},"lastUpdated":  7/27/2020
},"lastUpdated":  7/20/2020
},"lastUpdated":  7/13/2020
}

我可以做这样的事情：

1. 获取所有ID为12345的文档
2. 如果文档数> = 5，则获取最后一个文档（实例5）并将其删除。
3. 插入新文档

但是，这是一个正在运行的3个查询，用于插入单个文档。

有没有更优雅的方式做到这一点？

谢谢！

解决方法

您可以使用OFFSET 1 LIMIT 5获取5个最新条目。有关更多详细信息，您可以阅读有关OFFSET LIMIT clause in Azure Cosmos DB的官方文档。

您可以获取数据的数量（假设为100）并设置ttl，或直接删除。我们可以像下面这样查询。

SELECT f.id,f.lastUpdated FROM yourcosmosdb f ORDER BY f.lastUpdated OFFSET 6 LIMIT 100

Foreach

List<Task> concurrentDeleteTasks = new List<Task>();
while (feedIterator.HasMoreResults)
{
    FeedResponse<response> res = await feedIterator.ReadNextAsync();
    foreach (var item in res)
    {                        
        concurrentDeleteTasks.Add(container.DeleteItemAsync<response>(item.id,new PartitionKey(item.deviceid)));
    }
}
await Task.WhenAll(concurrentDeleteTasks.Take(3));

您也可以为每个集合进行设置并设置ttl=10，这些数据将在10s后删除。

您可以获得最新的5条数据：

SELECT f.id,f.lastUpdated FROM yourcosmosdb f ORDER BY f.lastUpdated OFFSET 1 LIMIT 5