EF Core对接CosmosDB：LINQ表达式无法翻译问题求助

问题说明 #

使用EF Core对接CosmosDB，执行查询玩家参与游戏的代码时，出现LINQ表达式无法翻译的错误，尝试过调用ToList等方法仍未解决。

报错信息 #

System.InvalidOperationException: LINQ表达式 'DbSet().Where(g => EF.Property<IReadOnlyCollection>(g, "Players").AsQueryable().Any(o => o.Id.Equals(__request_ProfileId_0)))' 无法被翻译。请将查询重写为可翻译的形式，或者通过插入对 'AsEnumerable'、'AsAsyncEnumerable'、'ToList' 或 'ToListAsync' 的调用显式切换到客户端评估。

相关代码 #

查询处理代码 #

public async Task<IReadOnlyCollection> Handle(GetMyUpcomingGamesQuery request, CancellationToken cancellationToken)
{
    var cutoffTime = DateTimeOffset.UtcNow.AddMinutes(-120);

    // var results = await _repository.GetAsync(o => o.Begins > cutoffTime);

    var playerResults = await _repository.GetAsync(o => o.Players.Any(p => 
        p.Id.Equals(request.ProfileId)));

    var response = _mapper.Map<IReadOnlyCollection<GameResponse>>(playerResults);

    return response;
}

仓储层GetAsync方法 #

public async Task<IReadOnlyCollection<GameReadModel>> GetAsync(Expression<Func<GameReadModel, bool>> predicate) 
{ 
    var results = _context.GameReadModels.Where(predicate); 
    return await results.ToListAsync(); 
}

模型定义 #

GameReadModel

namespace Common.Domain.ReadModels
{
    public class GameReadModel 
    {
        public string Id { get; set; }
        public VenueReadModel Venue { get; set; } 
        public string Notes { get; set; }
        public DateTimeOffset Begins { get; set; }
        public DateTimeOffset Ends { get; set; }
        public int NumberOfPlayers { get; set; }
        public decimal MinimumRating { get; set; }
        public decimal MaximumRating { get; set; }
        public bool OpenToLobby { get; set; }
        public string GameType { get; set; }
        public ProfileReadModel Host { get; set; } 
        public IReadOnlyCollection<ProfileReadModel> Players { get; set; }
        public IReadOnlyCollection<ListItemReadModel> Lists { get; set; }
        public DateTimeOffset Created { get; set; }
        public DateTimeOffset Modified { get; set; }
    }
}

ProfileReadModel

using Common.Domain.Abstracts;

namespace Common.Domain.ReadModels
{
    public class ProfileReadModel 
    {
        public string Id { get; set; }
        public string SocialId { get; set; }
        public string Handle { get; set; }
        public decimal Rating { get; set; }
    }
}

解决方案 #

方案1：调整LINQ查询写法适配CosmosDB翻译 #

CosmosDB的EF Core提供程序对嵌套集合的查询支持有特定要求，将Equals方法改为==运算符，让EF Core能正确转换为Cosmos SQL：

var playerResults = await _repository.GetAsync(o => o.Players.Any(p => p.Id == request.ProfileId));

若仍有问题，检查模型导航属性的配置，确保EF Core正确识别嵌套集合的映射关系。

方案2：显式客户端评估（注意性能） #

如果必须使用客户端评估，需先将数据加载到内存再过滤（仅适用于数据量较小的场景）。修改仓储层方法：

public async Task<IReadOnlyCollection<GameReadModel>> GetAsync(Expression<Func<GameReadModel, bool>> predicate) 
{ 
    // 先加载所有数据到内存
    var allGames = await _context.GameReadModels.ToListAsync(); 
    // 在客户端执行过滤
    return allGames.Where(predicate.Compile()).ToList(); 
}

方案3：直接使用Cosmos SQL查询 #

利用CosmosDB原生的ARRAY_CONTAINS函数，通过原生SQL查询实现需求：

// 构造Cosmos SQL查询语句
var sqlQuery = $"SELECT * FROM c WHERE ARRAY_CONTAINS(c.Players, {{\"Id\": \"{request.ProfileId}\"}}, true)";
// 通过EF Core执行原生SQL
var query = _context.GameReadModels.FromSqlRaw(sqlQuery);
var playerResults = await query.ToListAsync();

ARRAY_CONTAINS的第三个参数true表示进行部分匹配，仅检查对象的Id属性是否符合条件。

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