我使用 import avro 等在 python 中编译 avro 模式。有时，我的 avro 架构将如下所示:
{ name: "Message1" ..... }
{ name: "Message2", "fields": [ { "type": "Message1", "name": "previous_avro_schema" } ] } ...
请忽略错别字。我只是想传达信息。要点是我有两个 avro 模式。其中一个 avro 模式使用第二个 avro 模式作为其字段之一。如何为此类 avro 消息调用 avro.schema.parse(....) 以便正确编译它们？
请您参考如下方法:
Avro 的 Python 支持非常可怜，但您可以同时使用一些东西，包括多个模式。您只需要将模式文件合并到一个文件中，您需要确保它们以正确的顺序合并，以便依赖项排在第一位，并且您需要用实际模式替换名称这是我使用的脚本合并它们:
def resolve(path):
"fully resolve a schema that includes other schemas"
data = open(path).read()
# fill in any while they remain
while True:
beg = data.find('`')
end = data.find('`', beg + 1)
if beg < 0:
break
path = os.path.join(os.path.dirname(path), data[beg+1:end] + '.avsc')
data = data[:beg] + resolve(path) + data[end+1:]
return data
