如何使用批量 API elasticsearch.net btye 数组将 json 文件导入 elasticsearc

Question

我有一些json文件需要导入到elasticsearch。

我使用 curl api。下面是示例，它对我来说效果很好。

curl -XPOST http://localhost:9200/index_local/_doc/_bulk -H "Content-Type: application/json" --data-binary @sample.json

我使用HttpWebRequest进行模拟，它对我来说也很好用。

public void Post(string fileName)
{
try
{
// get the byte array 
var data = File.ReadAllBytes(fileName);
// create HttpRequest
var httpRequest = (HttpWebRequest)WebRequest.Create(@"http://localhost:9200/index_local/_doc/_bulk");
httpRequest.Method = "POST";
httpRequest.ContentType = "application/json";
httpRequest.ContentLength = data.Length;
// set the file byte array to the stream
using (var requestStream = httpRequest.GetRequestStream())
{
requestStream.Write(data, 0, data.Length);
}
// get the response
using (var response = httpRequest.GetResponse() as HttpWebResponse)
{
using (var responseStream = new StreamReader(response.GetResponseStream()))
{
// read the result
Console.WriteLine(responseStream.ReadToEnd());
}
}
}
catch (Exception e)
{
Console.WriteLine(e.Message);
}
}

但是我找不到带有导入 json 文件的批量 api elasticsearch.net。

是否有一些等于HttpWebRequest的函数可以将 json 文件发布到 elasticsearch ？

elasticsearch.net 库 ElasticLowLevelClient 或 ElasticClient 是否支持使用 btye 数组导入 json 文件？

Answer 1

假设sample.json是一个具有批量 API 有效结构的 JSON 文件，您可以使用

var client = new ElasticClient();
var bytes = File.ReadAllBytes("sample.json");
var bulkResponse = client.LowLevel.Bulk<BulkResponse>(
bytes,
new BulkRequestParameters
{
RequestConfiguration = new RequestConfiguration
{
RequestTimeout = TimeSpan.FromMinutes(3)
}
});
if (!bulkResponse.IsValid)
{
// handle failure
}

这将为此请求设置特定的请求超时，如果批量请求大于正常请求(通常是正常请求(，则可以将其设置为大于正常值。如果sample.json大于 5MB 左右，则可以考虑批量读取行对(批量操作和文档(中的文件，并作为多个批量请求发送。