如何在Avro模式中嵌套记录？
我正在尝试让Python解析如下的Avro模式…
from avro import schema
mySchema = """
{
"name": "person",
"type": "record",
"fields": [
{"name": "firstname", "type": "string"},
{"name": "lastname", "type": "string"},
{
"name": "address",
"type": "record",
"fields": [
{"name": "streetaddress", "type": "string"},
{"name": "city", "type": "string"}
]
}
]
}"""
parsedSchema = schema.parse(mySchema)
…并且出现以下异常：
avro.schema.SchemaParseException: Type property "record" not a valid Avro schema: Could not make an Avro Schema object from record.
我究竟做错了什么？
问题答案：
根据网络上的其他消息来源，我将重写您的第二个地址定义：
mySchema = """
{
"name": "person",
"type": "record",
"fields": [
{"name": "firstname", "type": "string"},
{"name": "lastname", "type": "string"},
{
"name": "address",
"type": {
"type" : "record",
"name" : "AddressUSRecord",
"fields" : [
{"name": "streetaddress", "type": "string"},
{"name": "city", "type": "string"}
]
}
}
]
}"""
-
我确实有这样的身体- 有人能帮我为这种类型的主体创建一个有效的Avro模式吗。我找到了一个创建类似这样的嵌套模式的示例- }] 当我提供这种模式时，它在下面的行中为我提供了错误- GenericRecord avroRecord=新的GenericData。记录（模式）； 错误是-org。阿帕奇。阿夫罗。AvroRuntimeException:不是记录架构：
-
我正在根据模式验证记录数据。以下是具有联合类型的模式： 我的记录是： 现在，我想验证此特定字段是否具有正确的类型。以下是我的 Java 代码 如何检查该值是否属于模式中定义的类型之一。
-
我为简单的类层次结构自动生成了Avro模式： 看起来是这样的: 此模式适用于使用普通Avro API将数据从JSON读取到。我尝试实现的下一件事是使用将所有此类对象存储到单个拼花文件中： 此代码在第一行失败 难怪AvroSchemaConverter包含以下代码行: 我的模式类型是UNION。非常感谢将此UNION模式映射（合并）到RECORD模式或任何其他建议的任何想法/帮助。 解决方案 1)使
-
我收到Kafka主题中的二进制Avro文件，我必须对它们进行反序列化。在Kafka收到的消息中，我可以在每条消息的开头看到一个模式。我知道不嵌入模式并将其与实际的Avro文件分离是一种更好的做法，但我无法控制生产者，也无法更改。 我的代码在Apache Storm上运行。首先，我创建一个读卡器： 然后，我尝试反序列化消息，但不声明架构： 但当消息到达时，我会收到一个错误： 我看到的所有答案都是关于
-
我需要使我的输出像预期的输出一样。我试图添加符号，但输出不像预期的输出 这是我的代码：