Apache NiFi evaluatejsonpath处理器:连接2个属性的JSONPath表达式

我想你把这个词弄混了 attributes 有不同的背景。当我第一次拿起NiFi并开始使用JSON时,我就这么做了。为了澄清问题,在这种特殊情况下有两种属性:

1. 流文件属性 元数据 流文件的,比如 filename filesize , mime.type ,等等,当您使用如下处理器添加属性时 UpdateAttribute 不 流文件内容本身。
2. JSON属性 Name 是此处的属性-> { "Name" : "Smith, John"}

${projectName}, ${filename} 根据 FlowFile attributes 不会的 EvaluateJsonPath 采用JSON路径表达式,如 $.Name

例如,假设流文件内容中包含以下JSON文档:

{
    "attr1": "some value for attr1",
    "attr2": "some value for attr2"
}

在这种情况下,必须配置 EvaluateJsonPath

attribute1 : $.attr1
attribute2 : $.attr2

一旦完成,通过 EvaluateJsonPath 将以上两个属性添加到 flowfile attributes ${attribute1} . 然后连接 EvaluateJsonPath 处理器到 UpdateRecord 处理器,您可以在其帮助下添加组合组合键 NiFi Expression Language 流文件JSON内容。

有用的链接

• NiFi表达语言指南- https://nifi.apache.org/docs/nifi-docs/html/expression-language-guide.html
• https://community.hortonworks.com/questions/106210/how-to-use-evaluate-json-path-in-nifi.html
• 更新记录- https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.7.1/org.apache.nifi.processors.standard.UpdateRecord/additionalDetails.html

EvaluateJsonPath需要一个JSONPath语句,在本例中,您希望获取两个属性,并使用NiFi表达式语言从中创建一个属性。如果是这样,那么UpdateAttribute应该是您想要的。如果您希望将组合键插入到内容中,那么UpdateRecord应该是您想要的。