У нас есть файлы для захвата событий в хранилище BLOB-объектов Azure.Файлы хранятся в формате avro со схемой:
{
"type":"record",
"name":"EventData",
"namespace":"Microsoft.ServiceBus.Messaging",
"fields":[
{"name":"SequenceNumber","type":"long"},
{"name":"Offset","type":"string"},
{"name":"EnqueuedTimeUtc","type":"string"},
{"name":"SystemProperties","type":{"type":"map","values":["long","double","string","bytes"]}},
{"name":"Properties","type":{"type":"map","values":["long","double","string","bytes"]}},
{"name":"Body","type":["null","bytes"]}
]
}
Внутри поля Body у нас есть запись JSON в кодировке UTF-8.
{
"Updates":[r1,r2,r3]
}
Нам нужно получить файлы Avro в качестве выводас записями r1, r2, r3 с другой схемой Avro.