如何在 NIFI 中对 json 响应应用条件

Question

{


"alamrs": [
{ 
  "correlate": [
    " ", 
    " ", 
    " " 
  ], 
"event": " ", 
  "group": " ", 
  "history": [
    {
      "event": " ", 
      "href": " ", 
      "id": " ", 
      "resource": " abc ", 
      "status": " ", 
      "text": " ", 
      "type": " ", 
      "updateTime": " ", 
      "user": " ", 
      "value": "--"
    }
  ],

  "href": " ", 
  "id": "", 
  "rawData": null, 
  "receiveTime": " ", 
  "service": [
    " "
  ], 
"resource": "abc", 
  "status": " ", 
  "tags": [
    ""
  ], 
"text": " : ", 
  "timeout": , 
}, 
{ 
"correlate": [
    " ", 
    " ", 
    " " 
  ], 
"event": " ", 
  "group": " ", 
  "history": [
    {
      "event": " ", 
      "href": " ", 
      "id": " ", 
      "resource": " abc ", 
      "status": " ", 
      "text": " ", 
      "type": " ", 
      "updateTime": " ", 
      "user": " ", 
      "value": "--"
    }
  ],

  "href": " ", 
  "id": "", 
  "rawData": null, 
  "receiveTime": " ", 
  "service": [
    " "
  ],
"resource": "abc", 
  "status": " ", 
  "tags": [
    ""
  ], 
"text": " : ", 
  "timeout": , 
}, 
{ 
  "correlate": [
    " ", 
    " ", 
    " " 
  ], 
"event": " ", 
  "group": " ", 
  "history": [
    {
      "event": " ", 
      "href": " ", 
      "id": " ", 
      "resource": " abc ", 
      "status": " ", 
      "text": " ", 
      "type": " ", 
      "updateTime": " ", 
      "user": " ", 
      "value": "--"
    }
  ],
"href": " ", 
  "id": "", 
  "rawData": null, 
  "receiveTime": " ", 
  "service": [
    " "
  ], 
"resource": "abc", 
  "status": " ", 
  "tags": [
    ""
  ], 
  "text": " : ", 
  "timeout": , 
}

[这里我使用了从 web 应用程序获取警报的 http 调用处理器 ....此处理器的响应是 json 格式 ...实际上我希望此警报在资源 =abc ..i 的基础上获取过滤器意思是说具有存储在文本文件中的资源 = abc 的警报][routedonatrribute configration--property_name=condtion value=${alamrs.resource:equals('abc')}]1[evalutejsonpath--- (property=destination- value=flowfile-attribute) (propety_name=condition value=$.alamrs.resource)]1[完整数据流]1[1]: https://i.stack.imgur.com/f0pCF.png

Answer 1

我建议使用PartitionRecord 和JsonPathReader 将流文件中带有/*[./alarms/resource=abc] 的所有记录发送到一个关系，将其他记录发送到另一个关系。