Nifi 将 FetchHBaseRow 的输出/追加输出回流文件

Question

我有一个包含 10 个字段的 csv 文件。我需要查找 hbase 以获取对应于 csv 字段之一的值。生成的 hbase 字段应附加到 csv 文件中。 使用 Nifi，我构建了以下流程。

GenerateFlowFile（创建 csv 记录）--> UpdateRecord（已配置 avro 模式名称以读取传入的 csv 文件）--> ConvertRecord （配置 CSV Reader & JSON writer）--> SplitJSON --> EvaluateJSONPath（为 hbase 查找获取行键）--> FetchHBaseRow（将输出作为流文件属性）

现在，挑战是读取 JSON 属性“hbase.row”的内容，选择 field-value 对中的一个，将其附加到流文件内容中

Answer 1

表达式语言有一个jsonPath函数：

https://nifi.apache.org/docs/nifi-docs/html/expression-language-guide.html#jsonpath

您应该能够使用 UpdateAttribute 创建一个包含提取字段的新属性，例如 firstName = ${myJson:jsonPath('$.firstName')} 会将 firstName 的值提取到名为 firstName 的属性中，从属性 myJson 开始。

之后，您应该能够使用 UpdateRecord 将值添加到流文件内容中，假设您的架构具有该值的字段。