弹性搜索不是x内容例外

Question

我一直在尝试使用以下代码通过java进行弹性搜索：

String url = "http://localhost:9200/testindex2/test/2";
    HttpClient client = new DefaultHttpClient();

    HttpPut put = new HttpPut(url);
    JSONObject json = new JSONObject();

    json.put("email", "[e-mail]");
    json.put("first_name", "abc");
    StringEntity se = new StringEntity("JSON: " + json.toString());
    se.setContentEncoding(new BasicHeader(HTTP.CONTENT_TYPE,"Text"));
    put.setEntity(se);

    HttpResponse response = client.execute(put);
    System.out.println("\nSending 'PUT' request to URL : " + url);
    System.out.println("Put parameters : " + put.getEntity());
    System.out.println("Response Code : " + response.getStatusLine().getStatusCode());

   BufferedReader rd = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));

    StringBuffer result = new StringBuffer();
    String line = "";
    while ((line = rd.readLine()) != null) {
        result.append(line);
    }

    System.out.println(result.toString());

我得到了以下错误：

发送'PUT'请求到URL：http://localhost:9200/testindex2/test/2放参数：[Content-Type： text/普通；charset=ISO-8859-1， Content-编码：Text， Content-Llong： 52，分块：false]响应代码： 400{"错误"：{"root_cause"：[{"type"："mapper_parsing_exception"，"原因"："解析失败}]， type："mapper_parsing_exception"，"原因"："解析失败"，"caused_by"：{type："not_x_content_exception"，"原因"："压缩器检测只能在某些x内容字节或压缩的x内容字节上调用"}}，"状态"： 400}

另外，当我从rest客户机尝试相同的代码时，它运行得很好，不知道为什么会出现这个问题。

Answer 1

我也遇到了同样的错误，但在我的例子中，我实际上是在一个初始化容器的Kubernetes配置中执行类似的操作：

- args:
        - -XPUT
        - -k
        - {{.Values.kibana.env.ELASTICSEARCH_URL}}/.logtrail/config/1?pretty
        - -H
        - 'Content-Type: application/json'
        - --data
        - /etc/logtrail/logtrail.json

这里的问题是，当您在curl POST/PUT中指定一个文件时，它需要附加“@”。所以下面的配置工作了！

- args:
        - -XPUT
        - -k
        - {{.Values.kibana.env.ELASTICSEARCH_URL}}/.logtrail/config/1?pretty
        - -H
        - 'Content-Type: application/json'
        - --data
        - '@/etc/logtrail/logtrail.json'

Answer 2

Elastic search有专门的客户机来与Java一起工作。而且不需要手动生成JSON。此外，您没有描述导入部分，所以有点难以理解您使用的库。

Answer 3

替换了

 StringEntity se = new StringEntity("JSON: " + json.toString());
se.setContentEncoding(new BasicHeader(HTTP.CONTENT_TYPE,"Text"));

有了这个：

StringEntity se = new StringEntity(json.toString(),ContentType.APPLICATION_JSON);

它现在可以工作了