使用 Nifi 更新 Solr

Question

我有一个 Nifi 工作流，它从 Solr 检索 URL 并计算这个 URL 在不同社交媒体上的分享数，我需要在 Solr 上更新这个分享数，这两个flowfile 中的属性是 url 和相应的共享计数，我怎样才能使用 Nifi 更新回 solr。

Answer 1

您可以使用 PutSolrContentStream 处理器将新文档插入 Solr，或覆盖现有文档。目前不支持部分更新，所以如果您尝试更新已经存在的文档，那么您需要在 NiFi 中拥有整个原始文档 + 更新，这样您就可以将整个文档发回。

PutSolrContentStream 基本上可以执行此处描述的任何更新：

https://lucene.apache.org/solr/guide/6_6/uploading-data-with-index-handlers.html

默认方法是在 NiFi 中创建一个 JSON 文档并将其发送到 JSON 更新处理程序。