c# - MongoDB-MongoRiver- Elasticsearch -NEST

Question

我已经使用 Enron 邮件收集设置了 MongoDB 数据库。 MongoRiver 用于连接 Mongo 和 ElasticSearch。我可以通过 ElasticSearch 上的 REST 访问 Mongo 数据。

在配置 MongoRiver 时，我已经创建了一个索引“MongoIndex”

问题:当我使用 NEST(.NET C#) 从 ES 连接/获取数据时，它返回 0 个文档，而相同的查询在 REST 上返回结果。

MongoDB 详细信息 -数据库:安然集合:消息

ES 详情-索引:MongoIndex类型:消息

集合中消息的单一文档格式 -

{
    "_id" : ObjectId("4f2ad4c4d1e2d3f15a000000"),
    "body" : "Here is our forecast\n\n ",
    "subFolder" : "allen-p/_sent_mail",
    "mailbox" : "maildir",
    "filename" : "1.",
    "headers" : {
        "X-cc" : "",
        "From" : "phillip.allen@enron.com",
        "Subject" : "",
        "X-Folder" : "\\Phillip_Allen_Jan2002_1\\Allen, Phillip K.\\'Sent Mail",
        "Content-Transfer-Encoding" : "7bit",
        "X-bcc" : "",
        "To" : "tim.belden@enron.com",
        "X-Origin" : "Allen-P",
        "X-FileName" : "pallen (Non-Privileged).pst",
        "X-From" : "Phillip K Allen",
        "Date" : "Mon, 14 May 2001 16:39:00 -0700 (PDT)",
        "X-To" : "Tim Belden ",
        "Message-ID" : "<18782981.1075855378110.JavaMail.evans@thyme>",
        "Content-Type" : "text/plain; charset=us-ascii",
        "Mime-Version" : "1.0"
    }
}

---

这是我的 NEST 连接 Elasticsearch 的 .Net 代码 -

    public class Message
    {
        public string id { get; set; }
        public string body { get; set; }
        public string mailbox { get; set; }
        public string filename { get; set; }

        [ElasticProperty(Type = FieldType.Nested)]
        public IList<HeadersComponent> headers { get; set; }
    }

    public class HeadersComponent
    {
        public string Cc { get; set; }
        public string Bcc { get; set; }
        public string From { get; set; }
        public string Subject { get; set; }
        public string To { get; set; }
        public string Date { get; set; }        
    }


    Uri node = new Uri("http://localhost:9200");
    ConnectionSettings settings = new ConnectionSettings(node, "MongoIndex");
    ElasticClient client = new ElasticClient(settings);

    ISearchResponse<Message> searchResponse = client.Search<Message>(s => s.Query(q => q.Term(p => p.body, "SearchMe"));

当我运行上述代码在电子邮件“正文”中搜索“SearchMe”文本时，它返回 0 个结果。

需要这方面的帮助。这让我发疯:)

Answer 1

我认为它可能是您的 Elasticsearch type。查看您在评论中提供的请求，表明您正在查询索引中的所有类型。

localhost:9200/mongoindex/_search?q=body:"SearchMe"

然而，NEST 默认会在请求中添加一个类型。这将导致以下请求字符串

localhost:9200/mongoindex/message/_search?q=body:"SearchMe"

但是这意味着您的查询将不会像您实际想要的那样匹配

localhost:9200/mongoindex/messages/_search?q=body:"SearchMe"

既然你说你的类型是Messages。

ES Details- Index: MongoIndex Type: Messages

但是，在您的查询中，您将类型的推断留给了 NEST。默认情况下，这将产生一种类型的 Message。有许多选项可以解决此问题，但要确认这一点，您可以尝试明确设置要使用的类型。

var searchResponse = client.Search<Message>(s => s
    .Type("Messages")
    .Query(q => q
        .Term(p => p.body, "SearchMe")
    )
);

您可以在 documentation 中看到有关如何影响 NEST 推断类型、索引名称、属性名称等方式的更多选项。 .