twitter - 如何使用 Elasticsearch + Kibana 计算自定义指标？

Question

这似乎是一个很简单的问题，但出于某种原因我仍然无法理解如何解决同样的问题。我有一个 Elasticsearch 集群，它使用 twitter river 下载推文。我想实现一个情绪分析模块，它获取每条推文并计算一个分数(+ve/-ve)等。我希望为每个现有推文以及新推文计算分数，然后使用可视化基巴纳。

但是，我不确定我应该在 Elasticsearch 管道中的什么地方调用这个情绪分析模块。

我已经考虑过修改 twitter river 插件的选项，但是这将无法追溯。

基本上，我需要回答两个问题:-1) 如何在索引文档时调用 python/java 代码，以便我可以相应地修改 json。2) 如何使用相同的代码修改ES中所有已有的文档。

Answer 1

如果您不希望外部应用程序在为 Elasticsearch 中的文档编制索引之前进行分析，我想最好的方法是编写一个插件来执行此操作。您可以编写一个插件来实现执行情绪分析的自定义分析器。然后在映射中定义要运行分析器的字段。

查看分析插件示例 - https://github.com/barminator/elasticsearch-analysis-annotation https://github.com/yakaz/elasticsearch-analysis-combo/

要对所有现有文档运行分析，您需要在定义正确的映射后重新索引它们。