如何为复杂的 json 文档定义 avro 架构



我有一个 JSON 文档,我想将其转换为 Avro,并且需要为此目的指定一个模式。以下是我想为其定义 avro 架构的 JSON 文档:

{
 "uid": 29153333,
 "somefield": "somevalue",
 "options": [
   {
     "item1_lvl2": "a",
     "item2_lvl2": [
       {
         "item1_lvl3": "x1",
         "item2_lvl3": "y1"
       },
       {
         "item1_lvl3": "x2",
         "item2_lvl3": "y2"
       }
     ]
   }
 ]
}

我能够为非复杂类型定义架构,但不能为复杂的"选项"字段定义架构:

{
  "namespace" : "my.com.ns",
  "type" :  "record",
  "fields" : [
     {"name": "uid", "type": "int"},
     {"name": "somefield", "type": "string"}
     {"name": "options", "type": .....}
  ]
}

感谢您的帮助!

您需要使用 Avro 复杂类型,特别是数组和记录。然后将它们嵌套在一起:

{
  "namespace" : "my.com.ns",
  "name": "myrecord",
  "type" :  "record",
  "fields" : [
     {"name": "uid", "type": "int"},
     {"name": "somefield", "type": "string"},
     {"name": "options", "type": {
        "type": "array",
        "items": {
            "type": "record",
            "name": "lvl2_record",
            "fields": [
                {"name": "item1_lvl2", "type": "string"},
                {"name": "item2_lvl2", "type": {
                    "type": "array",
                    "items": {
                        "type": "record",
                        "name": "lvl3_record",
                        "fields": [
                            {"name": "item1_lvl3", "type": "string"},
                            {"name": "item2_lvl3", "type": "string"}
                        ]
                    }
                }}
            ]
        }
     }}
  ]
}

此外,为了提高准备性,您可以将架构拆分为多个文件。

这个在线工具(http://avro4s-ui.landoop.com/)非常实用,您可以通过给定的有效 json 生成 AVRO 架构。

相关内容

  • 没有找到相关文章

最新更新