Nifi：嵌套的 JSON 记录模式验证答案

【问题标题】：Nifi : Nested JSON records schema validationNifi：嵌套的 JSON 记录模式验证
【发布时间】：2019-07-26 14:37:56
【问题描述】：

我正在尝试使用 SplitRecord 处理器拆分包含嵌套记录的 JSON 文件。

因此，我总是得到一个空值而不是预期的记录数组：

{"userid":"xxx","bookmarks":null}

以下是 JSON 示例

{
  "userid": "Ib6gZ8ZPwRBbAL0KRSSKS",
  "bookmarks": [
    {
      "id": "10000XXXXXXW0007760",
      "creator": "player",
      "position": 42.96
    },
    {
      "id": "41ANSMARIEEW0075484",
      "creator": "player",
      "position": 51.87
    },
    {
      "id": "ALBATORCORSW0088197",
      "creator": "player",
      "position": 93.47
    },
    {
      "id": "ALIGXXXXXXXW0007944",
      "creator": "player",
      "position": 95.06
    }
  ]
}

这是我的 avro 架构：

{
    "namespace": "nifi",
    "name": "bookmark",
    "type": "record",
    "fields": [
        { "name": "userid", "type": "string" },
        { "name": "bookmarks", "type": {
            "type": "record",
            "name": "bookmarks",
                "fields": [
                    { "name": "id", "type": "string" },
                    { "name": "creator", "type": "string" },
                    { "name": "position", "type": "float" }
                ]
            }
        }
    ]
}

任何帮助将不胜感激！

【问题讨论】：

标签： apache-nifi avro

【解决方案1】：

我必须实现一个特定的 groovy 处理器来克服 nifi 的限制，这花了我很多时间。 avro 方案的管理仅限于最简单的情况，不适用于高级治疗。

【讨论】：