ASP.NET使用MongoDB Search Index报$search未知运算符错误

• MongoDB集合存储10000条文档，总大小约6MB，使用普通find拉取全量数据耗时超1分钟，已创建名为searchProd的MongoDB Search Index优化查询
• 官方参考查询语法为聚合管道格式，代码如下：

new BsonArray {
  new BsonDocument("$search", new BsonDocument {
    {
      "index",
      "searchProd"
    },
    {
      "text",
      new BsonDocument {
        {
          "query",
          application // 动态传入的查询参数
        },
        {
          "path",
          new BsonDocument("wildcard", "*")
        }
      }
    }
  })
}

• 初始实现错误地将$search阶段传入Find()方法，代码如下：

public async Task<List<Produit>> ListAllProducts(string application)
{
    var sw   = Stopwatch.StartNew();
    var allProducts =  await _produits.Find(new BsonDocument("$search", new BsonDocument
    {
        {
            "index",
            "searchProd"
        },
        {
            "text",
            new BsonDocument
            {
                {
                    "query",
                    application
                },
                {
                    "path",
                    new BsonDocument("wildcard", "*")
                }
            }
        }
    })).ToList();
    return  allProducts;

}

• 运行后抛出异常：

MongoDB.Driver.MongoCommandException: Command find failed: unknown top level operator: $search. If you have a field name that starts with a '$' symbol, consider using $getField or $setField..

核心修正点 #

$search是MongoDB聚合管道专属的阶段操作符，不支持直接传入Find()方法作为查询条件，必须作为聚合管道的第一个阶段执行，需要调用MongoDB C#驱动的Aggregate()方法实现。

可直接运行的正确代码 #

public async Task<List<Produit>> ListAllProducts(string application)
{
    // 构建聚合管道，$search必须放在第一个阶段
    var pipeline = new BsonDocument[]
    {
        new BsonDocument("$search", new BsonDocument
        {
            { "index", "searchProd" },
            {
                "text", new BsonDocument
                {
                    { "query", application },
                    { "path", new BsonDocument("wildcard", "*") }
                }
            }
            // 如需返回匹配得分，可追加配置：{ "score", new BsonDocument("returnStoredSource", true) }
        })
        // 后续如需追加过滤、投影、分页逻辑，可在此处新增对应聚合阶段
    };

    // 执行聚合查询
    var allProducts = await _produits.Aggregate<Produit>(pipeline).ToListAsync();
    return allProducts;
}

额外注意事项 #

• 确保使用的MongoDB实例支持Search索引能力：MongoDB Atlas全版本支持，自建MongoDB需升级到6.0及以上版本
• 10000条总大小6MB的数据查询耗时超1分钟属于异常表现，除了使用Search索引，也可以检查普通查询是否命中集合索引、实例连接是否存在跨区域高延迟问题
• 若需要组合多条件查询，建议使用$search阶段内置的compound操作符实现，性能远高于在$search后追加$match阶段过滤

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