使用 java 客户端 6.5 插入对象

Question

我想使用 java 高级别的客户端插入一个对象。

我的映射如下：

"images":{
           "type":"nested",
           "properties":{
              "name":{
                  "type":"text"
              },
              "url":{
                 "type":"text"
              }
           }
        }

和java代码：

//productDb.getImages() 返回Image类型的ArrayList：带有属性“name”和“url”

productToIndex.put("images", new Gson().toJson(productDb.getImages()));
      IndexRequest indexRequest = new IndexRequest(ProductIndex.PRODUCT_INDEX, ProductIndex.TYPE)
                    .source(productToIndex, XContentType.JSON);
            try {              
                restHighLevelClient.index(indexRequest, RequestOptions.DEFAULT);              
            } catch (Exception e) {
                logger.error("Data access error occured the entity persistence...", e);
                throw new Exception(e);
            }

错误是：

ElasticsearchStatusException[Elasticsearch 异常 [type=mapper_parsing_exception, reason=object mapping for [images] 试图将字段 [images] 解析为对象，但找到了具体值]]

具体值：

images -> [{"name":"Capture.PNG","url":"/api/trader/files/2132132/Capture.PNG"},{"name":"payement.jpg","url":"/api/trader/files/31231321/payement.jpg"}]

==> 对我来说似乎还可以，如果我将 productDb.getImages() 替换为 new Arraylist(); ，我不明白为什么它会返回异常；它工作正常（索引值为：“图像”：[]）

我找不到如何使用 java 索引数组对象的示例，有解决方案吗？

谢谢。

Answer 1

如果您发现 ES 期望您的 JSON 格式与您发送有效负载的格式有所不同。

索引嵌套文档的正确格式

{
    "images": [ --> note image array
        {
            "name": "opster.PNG",
            "url": "/api/trader/files/2132132/Capture.PNG"
        },
        {
            "name": "data.jpg",
            "url": "/api/trader/files/31231321/payement.jpg"
        }
    ]
}

java代码生成的JSON，注意没有images键

{
  "name": "Capture.PNG",
  "url": "/api/trader/files/2132132/Capture.PNG"
},
{
  "name": "payement.jpg",
  "url": "/api/trader/files/31231321/payement.jpg"
}

由于 Elasticsearch 无法找到 images 键并且您的不是有效的 JSON 数组，因此 Elasticsearch 会抛出错误：

解决方案：

请发送开头提到的 JSON，然后使用下面的代码将其转换为适当的格式。

public void saveToEs(NestedImages nestedImages) throws IOException {
        ObjectMapper Obj = new ObjectMapper();
        final String images = Obj.writeValueAsString(nestedImages);
        final IndexRequest indexRequest = new IndexRequest("nestedimage")
                .source(images, XContentType.JSON);
        IndexResponse indexResponse = client.index(indexRequest, RequestOptions.DEFAULT);

    }

nested data type index def and indexing example 和 REST high-level indexing java code 的重要链接。