使用insertOneAsync插入MongoDB文档后，如何将元数据存入另一集合？

1. 基础同步执行方案 #

插入主文档后直接提取元数据写入目标集合，若需要数据强一致性，可结合MongoDB事务实现（需MongoDB 4.0+，且部署为副本集/分片集群）。

普通同步实现 #

// 插入主文档
await dbCollection.InsertOneAsync(entity);

// 提取元数据（假设entity自带Id、CreateBy、Timestamp属性）
var metadata = new 
{
    Id = entity.Id, // InsertOneAsync后MongoDB会自动填充自动生成的ObjectId
    CreateBy = entity.CreateBy,
    Timestamp = entity.Timestamp ?? DateTime.UtcNow // 可替换为业务侧或MongoDB侧的时间
};

// 写入元数据集合（示例集合名：原集合名+_Metadata）
var metadataCollection = db.GetCollection<dynamic>($"{dbCollection.CollectionName}_Metadata");
await metadataCollection.InsertOneAsync(metadata);

事务保障版 #

using var session = await db.Client.StartSessionAsync();
session.StartTransaction();

try
{
    // 事务内插入主文档
    await dbCollection.InsertOneAsync(session, entity);
    
    // 构造并插入元数据
    var metadata = new { Id = entity.Id, CreateBy = entity.CreateBy, Timestamp = DateTime.UtcNow };
    var metadataCollection = db.GetCollection<dynamic>($"{dbCollection.CollectionName}_Metadata");
    await metadataCollection.InsertOneAsync(session, metadata);
    
    await session.CommitTransactionAsync();
}
catch (Exception ex)
{
    await session.AbortTransactionAsync();
    throw; // 抛出异常让上层处理
}

2. 利用Change Streams解耦逻辑 #

如果不想在业务代码中耦合元数据写入逻辑，可以通过MongoDB的Change Streams监听主集合的插入事件，自动同步元数据到目标集合，适合非强实时的场景。

// 构造监听管道，仅监听插入操作
var pipeline = new EmptyPipelineDefinition<ChangeStreamDocument<YourEntity>>()
    .Match(c => c.OperationType == ChangeStreamOperationType.Insert);

// 启动监听（建议放在后台服务/守护进程中）
using var cursor = await dbCollection.WatchAsync(pipeline);
while (await cursor.MoveNextAsync())
{
    foreach (var change in cursor.Current)
    {
        var insertedDoc = change.FullDocument;
        var metadata = new 
        {
            Id = insertedDoc.Id,
            CreateBy = insertedDoc.CreateBy,
            Timestamp = insertedDoc.Timestamp
        };
        
        var metadataCollection = db.GetCollection<dynamic>($"{dbCollection.CollectionName}_Metadata");
        await metadataCollection.InsertOneAsync(metadata);
    }
}

注意：可通过ResumeToken实现断点续传，避免服务重启后丢失未处理的事件。

3. 封装通用方法复用 #

如果多个集合都需要该逻辑，可封装成扩展方法减少重复代码：

public static async Task InsertWithMetadataAsync<T>(this IMongoCollection<T> mainCollection, T entity, IMongoDatabase db)
{
    await mainCollection.InsertOneAsync(entity);
    
    // 反射提取元数据字段（需确保实体类包含对应属性）
    var metadata = new 
    {
        Id = typeof(T).GetProperty("Id").GetValue(entity),
        CreateBy = typeof(T).GetProperty("CreateBy").GetValue(entity),
        Timestamp = typeof(T).GetProperty("Timestamp").GetValue(entity) ?? DateTime.UtcNow
    };
    
    var metadataCollection = db.GetCollection<dynamic>($"{mainCollection.CollectionName}_Metadata");
    await metadataCollection.InsertOneAsync(metadata);
}

调用方式：

await dbCollection.InsertWithMetadataAsync(entity, db);

关键注意点 #

• 确保entity.Id在InsertOneAsync执行后已被MongoDB赋值（自动生成的ObjectId会自动填充到实体属性）。
• 若使用MongoDB内置时间，可在实体类的Timestamp属性上添加[BsonDateTimeOptions(Kind = DateTimeKind.Utc)]注解，保证时间一致性。
• 单节点MongoDB不支持事务，需采用副本集或分片集群部署才能使用事务方案。

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