elasticsearch - Apache NIFI-Putelasticsearch-格式错误的内容，在分析后发现了额外的数据:START_OBJECT

Question

我正在使用Putelasticsearch5处理器，但上游又有几个处理器。

上游处理器生成的json如下所示:
{“id”:“1234”，“名称”:“苹果”}
{“id”:“5678”，“名称”:“橙色”}

我期望这可以做一个大容量索引。但是它抛出错误，提示“原因:java.lang.IllegalArgumentException:格式错误的内容，在分析后发现了额外的数据:START_OBJECT”

我在这里做错了什么？

Answer 1

PutElasticsearch处理器会自动将单个文档 bundle 到Bulk API中。这意味着(除PutElasticsearchHttpRecord之外)他们希望每个流文件一个文档，并且您可以尝试通过设置Batch Size属性来对它们进行批处理。例如，如果将Batch Size(批次大小)设置为100，则处理器将最多获取下100个流文件(即，触发处理器时，队列中有很多流文件-最多100个)。

如果您有MergeContent处理器或将所有文档 bundle 在一起的方法，请尝试删除流程的这一部分。如果看到性能问题，请尝试减少对PutElasticsearch处理器的调度，或者将“运行持续时间”设置为25 ms或更长。