Apache NiFi 中的 Json 字段匹配

Question

我有一个 json 作为来自 InvokeHTTP 的响应，如下所示:

{
   "id": "1234567890",
   "status": "completed",
   "others": "abc",
   "field": "1"
}

我想使用一个处理器(也许是 RouteOnAttribute？？)来检查响应的状态是否完成，如果不匹配，它会返回到 invokeHttp 再次检查状态。

我尝试过这个事情: EvaluateJsonPath(从json中提取id) -> InvokeHTTP(获取状态) -> RouteOnAttribute(检查状态是否完成)

• -> 匹配进入漏斗
• -> 不匹配再次转到 EvaluateJsonPath(以创建循环)

对于 InvokeHTTP，我需要原始 json 文件，因为我必须获取请求 id。

我使用了具有以下属性的路由到属性名称:status - ${status:equals('completed')}

不幸的是，即使状态已完成，我总是收到不匹配的消息。

问题出在哪里？

Answer 1

我已经构建了虚拟流程，以检查您的情况，没有看到任何问题。流程如下: 要点如下:

1. 在顶部 EvaluateJsonPath 我使用 flowfile-attribute 作为目标并添加新属性 - status
2. 在 RouteOnAttribute 中，我检查状态值
3. 在底部的 EvaluateJsonPath 中，我提取 id，并使用 flowfile-content 作为目标。