如何通过在Nifi中引用传入流文件中的表和行ID动态获取行

Question

在我的用例中，我将有一个hbase表，在该表中我将使用getHbase读取增量记录，并且该记录中的值之一应用作FetchHBaseRow处理器的输入。因此，我如何才能从流文件访问文件内容并将其用作FetchHbaseRow的输入。

Answer 1

您可以拥有GetHBase并将其连接到EvaluateJsonPath（因为GetHBase以JSON格式输出结果）以获取行ID，然后FetchHBaseRow通过在FetchHBaseRow的Row Identifier属性中设置EvalueteJsonPath中使用的动态属性名称来使用行ID 。

在我的示例中，我已经提到EvaluateJsonPath用于读取行键，但是您可以使用有效的Json Path表达式从GetHBase输出读取任何值并使用它。

样品流量

读取行键

使用EvaluateJsonPath，我们从GetHBase处理器输出的JSON中读取行键。确保将Destination其设置为flowfile-attribute

使用解析的行键

我们读取行键并将其放在row.key属性中。在这里，我们Row Identifier在FetchHBaseRow