dt3999 2018-08-18 04:08
浏览 92

goavro无法使用架构验证json数据

I'm new to go and avro and struggling with validating data.I have this avro schema

{
  "namespace": "com.input",
  "name": "parent",
  "type": "record",
  "fields": [
{
  "name": "field1",
  "type": [
    "null",
    {
      "type": "record",
      "name": "child",
      "fields": [
        {
          "name": "child1",
          "type": "string"
        },
        {
          "name": "child2",
          "type": "string"
        }
      ]
    }
  ]
}
]
}

Data to be validated:

{
 "field1": {
 "child1": "1",
 "child2": "abc"
}
}

This is the code which i'm using to validate using goavro library:

func loadMockData() (stringFormatData string) {
    mockData, err := ioutil.ReadFile("sample.json")
    if err != nil {
        log.Println(err)
    }
    return string(mockData)
}

func loadSchema() (stringFormatData string) {
    mockSchema, err := ioutil.ReadFile("schema.avsc")
    if err != nil {
        log.Println(err)
    }
    return string(mockSchema)
}

avroSchema := loadSchema()
jsonString := loadMockData()

codec, err := goavro.NewCodec(avroSchema)
decoded, _, err := codec.NativeFromTextual([]byte(jsonString))

This gives me following error: NativeFromTextual error: cannot decode textual record "com.input.parent": cannot decode textual union: cannot decode textual map: cannot determine codec: "parentid"

I tried debugging the goavro library, seems that fieldcodec remains nil for parentid in map.go. With simple fields this setting works fine. Problem is with nested data its not able to get codec for parentid.

Any help is much appreciated.

  • 写回答

0条回答 默认 最新

    报告相同问题?

    悬赏问题

    • ¥15 微信会员卡接入微信支付商户号收款
    • ¥15 如何获取烟草零售终端数据
    • ¥15 数学建模招标中位数问题
    • ¥15 phython路径名过长报错 不知道什么问题
    • ¥15 深度学习中模型转换该怎么实现
    • ¥15 HLs设计手写数字识别程序编译通不过
    • ¥15 Stata外部命令安装问题求帮助!
    • ¥15 从键盘随机输入A-H中的一串字符串,用七段数码管方法进行绘制。提交代码及运行截图。
    • ¥15 TYPCE母转母,插入认方向
    • ¥15 如何用python向钉钉机器人发送可以放大的图片?