當消息包含多條消息時編譯avro模式（python）

Question

我使用import avro等來編譯python中的avro模式。有時，我的avro模式將如下所示：

{ name: "Message1" ..... } 

{ name: "Message2", "fields": [ { "type": "Message1", "name": "previous_avro_schema" } ] } ... 

請忽略拼寫錯誤。我只是想傳達信息。要點是我有兩個avro模式。其中一個avro模式使用第二個avro模式作爲其字段之一。我如何爲這樣的avro消息調用avro.schema.parse(....)以便它們可以被正確編譯？

Answer 1

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