插入List< object>用NEST导入Elasticsearch

本文关键字:NEST 导入 Elasticsearch List object 插入 | 更新日期: 2023-09-27 18:07:33

我在运行时生成了很多不同的值集合,并希望将它们发送给ElasticSearch。我可以把它们表示为List<object>或者如果真的不能用其他方法表示,就表示为List<string>。但我找不到任何例子。这里是一个代码的例子,它不工作。它可能有很多错误,所以任何额外的指针都是高度赞赏的。

  var client = new ElasticClient(new Uri("http://localhost:9200"));
            client.CreateIndex("testentry");
            var values = new List<object> {"StringValue", 123, DateTime.Now};
            var indexResponse = client.Index(values, descriptor => descriptor.Index("testentry"));
            Console.WriteLine(indexResponse.DebugInformation);

结果是:

Invalid NEST response built from a unsuccessful low level call on POST: /testentry/list%601
# Audit trail of this API call:
 - [1] BadResponse: Node: http://localhost:9200/ Took: 00:00:00.0600035
# ServerError: ServerError: 400Type: mapper_parsing_exception Reason: "failed to parse" CausedBy: "Type: not_x_content_exception Reason: "Compressor detection can only be called on some xcontent bytes or compressed xcontent bytes""

[2016-09-17 14:16:20,955][DEBUG][action.index             ] [Gin Genie] failed to execute [index {[t
estentry][list`1][AVc4E3HaPglqpoLcosDo], source[_na_]}] on [[testentry][1]]
MapperParsingException[failed to parse]; nested: NotXContentException[Compressor detection can only
be called on some xcontent bytes or compressed xcontent bytes];
        at org.elasticsearch.index.mapper.DocumentParser.parseDocument(DocumentParser.java:156)

我正在使用Elasticsearch。Net 2.4.3和NEST 2.4.3.

插入List< object>用NEST导入Elasticsearch

除了Henrik的答案,您还可以索引Dictionary<string, object>中的值

public class MyType
{
    public MyType()
    {
        Values = new Dictionary<string, object>();
    }
    public Dictionary<string, object> Values { get; private set; }
}
void Main()
{
    var pool = new SingleNodeConnectionPool(new Uri("http://localhost:9200"));
    var connectionSettings = new ConnectionSettings(pool);
    var client = new ElasticClient(connectionSettings);
    var myType = new MyType
    {
        Values =
        {
            { "value1", "StringValue" },
            { "value2", 123 },
            { "value3", DateTime.Now },
        }
    };
    client.Index(myType, i => i.Index("index-name"));
}

Dictionary<string,object>将被序列化为具有与字典键匹配的属性名称的json对象

{
  "values": {
    "value1": "StringValue",
    "value2": 123,
    "value3": "2016-09-18T18:41:48.7344837+10:00"
  }
}

在Elasticsearch中,映射将被推断为对象类型。

不支持混合数据类型的数组。

您可以将所有值转换为字符串:

client.CreateIndex("testentry");
var values = new List<string> { "StringValue", "123", DateTime.Now.ToString() };
var indexResponse = client.Index(new { Values = values}, descriptor => descriptor.Index("testentry").Type("test"));

或者指定值应该索引到的字段:

client.CreateIndex("testentry");
var values = new { Field1 = "StringValue", Field2 = 123, Field3 = DateTime.Now };
var indexResponse = client.Index(values, descriptor => descriptor.Index("testentry").Type("test"));

考虑使用IndexDescriptor指定文档的类型,或者为文档创建一个类。