-1

GetTwitter 处理器返回最后带有 \r\n (\0D\0A) 的流文件。我正在构建 Elasticsearch 批量插入文件(使用 MergeContent 处理器),需要将 \r\n 替换为 \n (\0A)。否则我会从 ES 收到错误消息。我正在考虑使用 ReplaceText 处理器,但不确定将什么用作搜索和替换参数。

提前致谢。

4

1 回答 1

2

看来elasticsearch可以摄取JSON。从 Apache NiFi GetTwitter 处理器返回的数据是有效的 JSON。将 JSON 文档发布到 ElasticSearch 时返回的错误是什么?您使用什么技术发布到 ElasticSearch?

谢谢乔

于 2015-12-14T12:10:00.090 回答