尝试在Ingest-attachment字段中插入null时，ElasticSearch返回错误

Question

我已经安装了摄取附件处理器，并且正在使用Java代码从一个索引读取文件路径，documents并在另一个索引中索引文件内容documents_attachment。

在此过程中，如果文件可用，它将解码为base64并将这些内容附加到json字段fileContent并在另一个index中将这些字段索引documents_attachment。

如果文件不可用，则尝试将null值附加到json字段，fileContent并尝试对这些字段进行索引。在此过程中，当我尝试插入nulljson字段时遇到以下错误fileContent。

请在下面找到错误。

ElasticsearchStatusException[Elasticsearch exception [type=exception, reason=java.lang.IllegalArgumentException: java.lang.IllegalArgumentException: field [fileContent] is null, cannot parse.]]; nested: ElasticsearchException[Elasticsearch exception [type=illegal_argument_exception, reason=java.lang.IllegalArgumentException: field [fileContent] is null, cannot parse.]]; nested: ElasticsearchException[Elasticsearch exception [type=illegal_argument_exception, reason=field [fileContent] is null, cannot parse.]];

    at org.elasticsearch.rest.BytesRestResponse.errorFromXContent(BytesRestResponse.java:177)

    at org.elasticsearch.client.RestHighLevelClient.parseEntity(RestHighLevelClient.java:573)

    at org.elasticsearch.client.RestHighLevelClient.parseResponseException(RestHighLevelClient.java:549)

    at org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:456)

    at org.elasticsearch.client.RestHighLevelClient.performRequestAndParseEntity(RestHighLevelClient.java:429)

    at org.elasticsearch.client.RestHighLevelClient.index(RestHighLevelClient.java:312)

    at com.es.utility.DocumentIndex.main(DocumentIndex.java:193)

    Suppressed: org.elasticsearch.client.ResponseException: method [PUT], host [http://localhost:9200], URI [/document_attachment_dev/doc/129439?pipeline=document_attachment_dev&timeout=1m], status line [HTTP/1.1 500 Internal Server Error]

请找到我的Java代码。

Answer 1

我正在为摄取附件处理器使用以下映射配置，并且在文件内容不可用（空）时它正在工作。PUT _ingest/pipeline/document_attachment    {  "description" : "my first pipeline with handled exceptions",  "processors" : [    {      "attachment" : {        "field" : "fileContent",        "on_failure" : [          {            "set" : {              "field" : "error",              "value" : "{{ _ingest.on_failure_message }}"            }          }        ]      }    }  ]}