elasticsearch - FIWARE Cygnus 下沉到 Elasticsearch/Kibana ？

Question

我目前有一个工作流程:

Fiware Orion -> Fiware Cygnus -> Kafka -> Logstash -> Elasticsearch -> Kibana

我想直接将数据从 Cygnus 推送到 Elasticsearch，是否已经有可用的接收器？

Apache Flume/Elasticsearch 接收器已存在:https://flume.apache.org/releases/content/1.3.0/apidocs/org/apache/flume/sink/elasticsearch/ElasticSearchSink.html

我想知道在 Cygnus 上使用它是否容易？

Answer 1

在 Cygnus 1.5.0(包括)之前，这样的水槽可以完美地在 Cygnus 代理配置中使用(与任何其他 Flume 水槽一样)。

从 1.6.0(包括在内，这是最后一个版本)您将无法使用，因为我们在内部替换了原生 Event 的使用自定义对象 NGSIEvent那些。为什么？:

一个 Event是一组 header 和正文的原始字节数组。

NGSIEvent继承自 Event并且是一组 header 、已解析的主体版本(作为对象)和指向 null 的主体的原始字节数组(最后一部分是避免与原生 Flume 接收器兼容的部分)。

无论如何，这很“容易”修复:新版本 a NGSIEvent将包含正文的解析版本和正文本身作为原始字节。