嘿，这个需求在时序数据采集场景里太常见了！根据你使用的存储系统，我整理了几种实用的方案：

方案1：写入后实时清理（通用思路） #

每次成功写入新文档后，立刻检查当前文档总数。如果超过100条，就删除最旧的一批（总数-100条）。这种方式能保证存储始终不超过100条，延迟最低。

举个伪代码例子（假设用时间戳created_at排序）：

# 写入新文档
insert_new_data(new_doc)

# 获取当前文档总数
total_docs = get_docs_count()

if total_docs > 100:
    # 计算需要删除的数量
    docs_to_delete = total_docs - 100
    # 查询最旧的N条文档的ID
    old_docs_ids = query_docs_ids(sort_by="created_at", order="asc", limit=docs_to_delete)
    # 删除这些文档
    delete_docs_by_ids(old_docs_ids)

方案2：利用存储系统自带的生命周期管理（以Elasticsearch为例） #

如果用Elasticsearch，可以直接用**索引生命周期管理（ILM）**来自动控制文档数量：

1. 创建一个ILM策略，设置max_docs: 100，超过后触发删除旧文档的动作
2. 将你的数据索引关联到这个策略

创建策略的示例请求：

PUT _ilm/policy/keep-last-100-docs
{
  "policy": {
    "phases": {
      "hot": {
        "actions": {
          "rollover": {
            "max_docs": 100
          }
        }
      },
      "delete": {
        "min_age": "0ms",
        "actions": {
          "delete": {}
        }
      }
    }
  }
}

之后把这个策略绑定到你的索引模板或直接关联到目标索引即可。

方案3：定时清理任务（适合低频率写入场景） #

如果写入频率不高，也可以设置定时任务（比如用Cron、系统定时任务或者数据库自带的定时触发器），每隔一段时间执行一次清理逻辑：

• 查询当前文档总数
• 若超过100，删除最旧的（总数-100）条文档

比如MongoDB里用定时触发器的伪逻辑：

const totalDocs = db.your_collection.countDocuments();
if (totalDocs > 100) {
  const docsToDelete = totalDocs - 100;
  const oldDocs = db.your_collection.find().sort({created_at: 1}).limit(docsToDelete);
  oldDocs.forEach(doc => {
    db.your_collection.deleteOne({_id: doc._id});
  });
}

注意事项 #

• 一定要用准确的排序字段（比如创建时间戳、自增ID）来区分新旧文档，避免误删最新数据
• 如果是高并发写入场景，建议用存储系统的原子操作或者加锁机制，防止出现计数不准确的情况

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