我已经使用安然邮件收集设置了 MongoDB 数据库。MongoRiver 用于连接 Mongo 和 ElasticSearch。我可以通过 ElasticSearch 上的 REST 访问 Mongo 数据。
在配置 MongoRiver 时,我已经创建了一个索引“MongoIndex”
问题:当我使用 NEST(.NET C#) 从 ES 连接/获取数据时,它返回 0 文档,而相同的查询在 REST 上返回结果。
MongoDB 详细信息 - DB:安然集合:消息
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 个结果。
在这方面需要帮助。它让我发疯:)