python을 이용한 avro 예제

python-avro-sample.py

import avro.schema
from avro.datafile import DataFileReader, DataFileWriter
from avro.io import DatumReader, DatumWriter

schema = avro.schema.parse("""{"namespace": "example.avro",
 "type": "record",
 "name": "User",
 "fields": [ {"name": "name", "type": "string"} ]
}""")

writer = DataFileWriter(open("users.avro", "wb"), DatumWriter(), schema)
writer.append({"name": "Alyssa"})
writer.close()

reader = DataFileReader(open("users.avro", "rb"), DatumReader())
for user in reader:
    print(user)
reader.close()