5

我正在使用 NiFi 从 Oracle 数据库中获取数据并将其中一些数据放入 Kafka（使用处理器 PutKafka）。示例：如果属性“id”包含“aaabb”

这在 Apache NiFi 中可能吗？我该怎么做？

4

2 回答 2

11

这绝对应该是可能的，流程可能是这样的......

1）执行SQL或QueryDatabaseTable从数据库中获取数据，这些产生Avro

2) ConvertAvroToJson 处理器将 Avro 转换为 Json

3) EvaluateJsonPath 将 id 字段提取到属性中

4) RouteOnAttribute 用于路由 id 属性包含“aaabbb”的流文件

5) PutKafka 传递来自 RouteOnAttribute 的任何匹配结果

于 2016-05-04T13:26:40.413 回答
2

为了补充 Bryan 的示例流程，我想向您介绍一些有助于向您介绍 Apache NiFi 的优秀文档。

首先，我建议查看NiFi 文档。这非常好，应该有很大帮助。除了提供 Bryan 提到的每个处理器的详细信息外，它还为每种类型的用户提供了一般文档。

有关构建 NiFi 流程的基本介绍，请查看此视频。

例如模板查看这个repo。它的根级别有一个 excel 文件，其中包含每个模板的描述和处理器列表。

于 2016-05-04T13:38:32.217 回答