使用InMemoryConnection测试ElasticSearch
使用InMemoryConnection测试ElasticSearch
提问于 2016-07-05 15:20:17
我试图在使用ElasticSearch (在C#中使用Nest1.4.2)的过程中添加测试，并希望使用InMemoryConnection，但我遗漏了一些东西(我认为)，但没有成功。
我创建了这个简单的Nunit测试用例，作为我问题的简化示例
using System;
using Elasticsearch.Net.Connection;
using FluentAssertions;
using Nest;
using NUnit.Framework;
namespace NestTest
{
public class InMemoryConnections
{
public class TestThing
{
public string Stuff { get; }
public TestThing(string stuff)
{
Stuff = stuff;
}
}
[Test]
public void CanBeQueried()
{
var connectionSettings = new ConnectionSettings(new Uri("http://foo.test"), "default_index");
var c = new ElasticClient(connectionSettings, new InMemoryConnection(connectionSettings));
c.Index(new TestThing("peter rabbit"));
var result = c.Search<TestThing>(sd => sd);
result.ConnectionStatus.Success.Should().BeTrue();
}
}
}查询是成功的，但找不到我刚刚索引的文档.
如果我更新到NEST版本2.3.3和新语法
[Test]
public void CanBeQueried()
{
var connectionPool = new SingleNodeConnectionPool(new Uri("http://localhost:9200"));
var settings = new ConnectionSettings(connectionPool, new InMemoryConnection());
settings.DefaultIndex("default");
var c = new ElasticClient(settings);
c.Index(new TestThing("peter rabbit"));
var result = c.Search<TestThing>(sd => sd);
result.CallDetails.Success.Should().BeTrue();
result.Documents.Single().Stuff.Should().Be("peter rabbit");
}以同样的方式失败..。也就是说，查询被报告为成功，但返回0份文档
回答 1
Stack Overflow用户
回答已采纳
发布于 2016-07-06 02:36:49
InMemoryConnection 实际上不发送任何请求或接收来自Elasticsearch的任何响应；在连接设置(或NEST 2.x+中的.OnRequestCompleted() )中与.SetConnectionStatusHandler()一起使用，这是查看序列化请求形式的一种方便方法。
如果不使用InMemoryConnection，但仍然设置.SetConnectionStatusHandler()或.OnRequestCompleted() (取决于NEST版本)，则可以方便地查看响应，因为NEST 1.x中也设置了.ExposeRawResponse(true)，NEST 2.x+中也设置了.DisableDirectStreaming()。
NEST 1.x的一个例子
void Main()
{
var settings = new ConnectionSettings(new Uri("http://localhost:9200"))
.ExposeRawResponse(true)
.PrettyJson()
.SetDefaultIndex("myIndexName")
.MapDefaultTypeNames(d => d.Add(typeof(myPoco), string.Empty))
.SetConnectionStatusHandler(r =>
{
// log out the requests
if (r.Request != null)
{
Console.WriteLine("{0} {1} \n{2}\n", r.RequestMethod.ToUpperInvariant(), r.RequestUrl,
Encoding.UTF8.GetString(r.Request));
}
else
{
Console.WriteLine("{0} {1}\n", r.RequestMethod.ToUpperInvariant(), r.RequestUrl);
}
Console.WriteLine();
if (r.ResponseRaw != null)
{
Console.WriteLine("Status: {0}\n{1}\n\n{2}\n", r.HttpStatusCode, Encoding.UTF8.GetString(r.ResponseRaw), new String('-', 30));
}
else
{
Console.WriteLine("Status: {0}\n\n{1}\n", r.HttpStatusCode, new String('-', 30));
}
});
var client = new ElasticClient(settings, new InMemoryConnection());
int skipCount = 0;
int takeSize = 100;
var searchResults = client.Search<myPoco>(x => x
.Query(q => q
.Bool(b => b
.Must(m =>
m.Match(mt1 => mt1.OnField(f1 => f1.status).Query("New")))))
.Skip(skipCount)
.Take(takeSize)
);
}
public class myPoco
{
public string status { get; set;}
}收益率
POST http://localhost:9200/myIndexName/_search?pretty=true
{
"from": 0,
"size": 100,
"query": {
"bool": {
"must": [
{
"match": {
"status": {
"query": "New"
}
}
}
]
}
}
}
Status: 0
{ "USING NEST IN MEMORY CONNECTION" : null }
------------------------------巢2.x
void Main()
{
var pool = new SingleNodeConnectionPool(new Uri("http://localhost:9200"));
var defaultIndex = "default-index";
var connectionSettings = new ConnectionSettings(pool, new InMemoryConnection())
.DefaultIndex(defaultIndex)
.PrettyJson()
.DisableDirectStreaming()
.OnRequestCompleted(response =>
{
// log out the request
if (response.RequestBodyInBytes != null)
{
Console.WriteLine(
$"{response.HttpMethod} {response.Uri} \n" +
$"{Encoding.UTF8.GetString(response.RequestBodyInBytes)}");
}
else
{
Console.WriteLine($"{response.HttpMethod} {response.Uri}");
}
Console.WriteLine();
// log out the response
if (response.ResponseBodyInBytes != null)
{
Console.WriteLine($"Status: {response.HttpStatusCode}\n" +
$"{Encoding.UTF8.GetString(response.ResponseBodyInBytes)}\n" +
$"{new string('-', 30)}\n");
}
else
{
Console.WriteLine($"Status: {response.HttpStatusCode}\n" +
$"{new string('-', 30)}\n");
}
});
var client = new ElasticClient(connectionSettings);
int skipCount = 0;
int takeSize = 100;
var searchResults = client.Search<myPoco>(x => x
.Query(q => q
.Bool(b => b
.Must(m =>
m.Match(mt1 => mt1.Field(f1 => f1.status).Query("New")))))
.Skip(skipCount)
.Take(takeSize)
);
}You can of course mock/stub responses from the client using your favourite mocking framework和依赖于客户端接口IElasticClient，如果这是您想要采取的路线，尽管断言请求的序列化形式符合您在SUT中的期望可能就足够了。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/38207159
复制相关文章
相似问题
腾讯云开发者
