因此,我正在使用一个具有下列值的批处理JSON文件:

[
  {
    "eventType": "UPDATE",
    "eventTime": "2021-12-14T12:34:56.789012Z",
    "country": "ES",
    "resourceType": "Party"
  },
  {
    "eventType": "UPDATE",
    "eventTime": "2021-12-14T12:34:56.789012Z",
    "country": "ES",
    "resourceType": "Party"
  },
  {
    "eventType": "UPDATE",
    "eventTime": "2021-12-14T12:34:56.789012Z",
    "country": "FR",
    "resourceType": "Party"
  },
  {
    "eventType": "UPDATE",
    "eventTime": "2021-12-14T12:34:56.789012Z",
    "country": "FR",
    "resourceType": "Party"
  }
]

我能够使用100处理器从JSON中提取属性.

100是我要从中提取属性的处理器.请找到下面100个处理器的快照,当值为105

我希望获得如下json文件:

[
  {
    "eventType": "UPDATE",
    "eventTime": "2021-12-14T12:34:56.789012Z",
    "country": "ES",
    "resourceType": "Party"
  },
  {
    "eventType": "UPDATE",
    "eventTime": "2021-12-14T12:34:56.789012Z",
    "country": "ES",
    "resourceType": "Party"
  }
]

enter image description here enter image description here enter image description here

推荐答案

使用QueryRecord processor:

  • Record Reader:JsonTreeReader.
  • Record Writer:JsonRecordSetWriter.
  • filter(动态特性):SELECT * FROM FLOWFILE WHERE country='ES'

输入(JSON):

[
  {
    "eventType": "UPDATE",
    "eventTime": "2021-12-14T12:34:56.789012Z",
    "country": "ES",
    "resourceType": "Party"
  },
  {
    "eventType": "UPDATE",
    "eventTime": "2021-12-14T12:34:56.789012Z",
    "country": "ES",
    "resourceType": "Party"
  },
  {
    "eventType": "UPDATE",
    "eventTime": "2021-12-14T12:34:56.789012Z",
    "country": "FR",
    "resourceType": "Party"
  },
  {
    "eventType": "UPDATE",
    "eventTime": "2021-12-14T12:34:56.789012Z",
    "country": "FR",
    "resourceType": "Party"
  }
]

输出(JSON):

[
  {
    "eventType": "UPDATE",
    "eventTime": "2021-12-14T12:34:56.789012Z",
    "country": "ES",
    "resourceType": "Party"
  },
  {
    "eventType": "UPDATE",
    "eventTime": "2021-12-14T12:34:56.789012Z",
    "country": "ES",
    "resourceType": "Party"
  }
]

Json相关问答推荐

为什么terraform不缩小这个策略JSON?'

如何在数组抖动中按值分组

如何判断响应数组是否存在以及S是否有其他内容...?

使用jq过滤复杂json对象中的数据

使用 jq 重新格式化 JSON 输出

在 NX 工作区中跨多个应用共享 ngx-translate 翻译文件

如何从 json 中获取单个元素?

用powershell条件解析json文件的数组对象

Golang / Go - 如果 struct 没有字段,如何将其编组为空?

现代浏览器一次可以处理多少个 HTML 元素?

在 Apache Spark 中读取多行 JSON

.NET CORE 3 升级 CORS 和 Json(cycle) XMLHttpRequest 错误

[__NSCFNumber 长度]:发送到实例 UITableView 的无法识别的 Select 器

在 HTML 数据属性上添加 JSON 是不是很糟糕?

有 Json 标签但未导出

如何使用 Json.NET 反序列化可以是两种不同数据类型的 JSON 属性

从 JSON 中 Select 不同的值

如何从 jQuery ajax 调用将复杂对象传递给 ASP.NET WebApi GET?

我如何反序列化以杰克逊为单位的时间戳?

杰克逊自动将 Joda DateTime 格式化为 ISO 8601 格式