如何使用C# AggregateFluent强类型方式实现指定MongoDB聚合查询并解决报错

我来帮你搞定这个问题！你遇到的FieldPath field names may not start with '$'报错，核心原因是在Lookup的Match阶段错误地直接用字符串引用let变量，MongoDB把它当成了字段名而非变量引用。下面我会一步步帮你修正代码，完全用强类型的AggregateFluent实现你的需求。

错误原因分析 #

你之前的代码里，在Lookup的Match条件中写了dp.OpaqueId == "$opaId1"，这会被MongoDB解析成字符串字面量比较，而非引用let中定义的变量。同时MongoDB不允许字段名以$开头，所以触发了这个报错。强类型查询中，引用let变量必须通过Expr和Variable来实现。

修正后的完整代码 #

下面是完全对应你MongoDB聚合管道的强类型实现，我会加上关键注释：

// 定义聚合管道的起始点
var pipeline = AggregateFluent<UserDocument>.Empty
    // 1. 对应$match阶段：筛选指定uid的用户
    .Match(u => u.UniversalId == uId)
    // 2. 对应第一个$project阶段：过滤aas数组，分别提取custId和loginId的aid
    .Project(user => new 
    {
        // 过滤aty为ABC的项，取aid
        CustId = user.aas.Where(a => a.aty == "ABC").Select(a => a.aid),
        // 过滤aty为XYZ的项，取aid
        LoginId = user.aas.Where(a => a.aty == "XYZ").Select(a => a.aid)
    })
    // 3. 对应$unwind阶段：展开CustId数组
    .Unwind(x => x.CustId)
    // 4. 对应$unwind阶段：展开LoginId数组
    .Unwind(x => x.LoginId)
    // 5. 对应第二个$project阶段：重命名为oid和lid
    .Project(x => new 
    {
        oid = x.CustId,
        lid = x.LoginId
    })
    // 6. 对应$lookup阶段：关联device集合，这里是核心修正部分
    .Lookup<UserDeviceDocument, DeviceDocument, dynamic>(
        foreignCollection: deviceCollection,
        // 定义let变量，用强类型表达式映射当前管道的字段
        let: new 
        {
            oid = x => x.oid,
            lid = x => x.lid
        },
        // Lookup内部的子管道
        pipeline: lookup => lookup
            .Match(Builders<DeviceDocument>.Filter.Expr(doc => 
                // 组合三个条件：id等于oid变量、loginId等于lid变量、trusted为true
                Builders<DeviceDocument>.Filter.And(
                    Builders<DeviceDocument>.Filter.Eq(d => d.Id, Variable<string>("oid")),
                    Builders<DeviceDocument>.Filter.Eq(d => d.LoginId, Variable<string>("lid")),
                    Builders<DeviceDocument>.Filter.Eq(d => d.Trusted, true)
                )
            )),
        // 指定结果映射到UserDeviceDocument的Devices属性
        @as: result => result.Devices
    )
    // 最后将结果转换为UserDeviceDocument类型
    .As<UserDeviceDocument>();

// 执行聚合查询并获取结果
var findResult = await pipeline.ToListAsync().ConfigureAwait(false);

关键修正点说明 #

1. 强类型Let变量：不再用BsonDocument定义let，而是用强类型表达式映射当前管道的字段，更符合AggregateFluent的强类型设计。
2. Expr引用变量：在Lookup的Match阶段，必须用Builders<DeviceDocument>.Filter.Expr包裹条件，并用Variable<T>来引用let中定义的变量（比如Variable<string>("oid")），这样MongoDB才会正确识别为变量引用而非字段名。
3. 字段名修正：修正了你原代码中oapId的拼写错误，和原聚合管道保持一致。
4. 类型转换：最后用As<UserDeviceDocument>将聚合结果转换为你需要的实体类型。

验证效果 #

这段代码会完全复现你给出的MongoDB聚合管道逻辑：

• 先筛选指定uid的用户
• 过滤并提取aas数组中对应aty的aid
• 展开数组字段
• 关联device集合，匹配指定条件的设备
• 最终返回包含Devices列表的UserDeviceDocument对象

备注：内容来源于stack exchange，提问作者Maruti Bhandari