Elasticsearch - MapperParsingException [格式错误的内容，必须以对象开始]

Question

我想批量索引文件到ES中使用BulkDescriptor在C＃中。我正在使用V1.7 ES。以下是我的一段代码，

public IBulkResponse IndexBulk(string index, string type, List<string> documents) 
     { 

       BulkDescriptor descriptor = new BulkDescriptor(); 
       foreach (var doc in documents) 
       { 
        JObject data = JObject.Parse(documents); 

        descriptor.Index<object>(i => i 
         .Index(index) 
         .Type(type) 
         .Id(data["Id"].toString()) 
         .Document(doc)); 
       } 
       return _Client.Bulk(descriptor); 

     } 

但它不是插入的文件，当我验证了回应，我看到下面的消息MapperParsingException[Malformed content, must start with an object]

样品JSON文件

{ 
"a" : "abc", 
"b": { "c": ["1","2"]} 
} 

出了什么问题在里面？

Answer 1

这里的问题是通过强类型流体批量方法传递原始json。

什么你实际上是发送给elasticsearch是

{"index":{"_index":"test1","_type":"string"}} 
"{"a" : "abc","b": { "c": ["1","2"]}}" 

这是不正确的。

一些想法，你可以做这个：

1. 使用JObject发送正确序列化对象elasticsearch使用.Raw客户端发送原始JSON

   的

   descriptor.Index<JObject>(i => i 
       .Index(index) 
       .Type(type) 
       .Id(data["Id"].toString()) 
       .Document(JObject.Parse(doc))); 
   

2. 乘虚而入

   var json = new StringBuilder(); 
   json.AppendLine(@"{""index"":{""_index"":""indexName"",""_type"":""typeName""}}"); 
   json.AppendLine(@"{""a"" : ""abc"",""b"": { ""c"": [""1"",""2""]}}"); 
   
   _Client.Raw.Bulk(json2.ToString()); 
   

希望它有帮助。