avro_object_container_file_serialize_and_read_users.py

1import avro.schema
2from avro.datafile import DataFileReader, DataFileWriter
3from avro.io import DatumReader, DatumWriter
4
5# Define the schema
6schema = avro.schema.parse(open("user.avsc", "rb").read())
7
8# Write data to a file
9writer = DataFileWriter(open("users.avro", "wb"), DatumWriter(), schema)
10writer.append({"name": "Alyssa", "favorite_number": 256})
11writer.append({"name": "Ben", "favorite_number": 7, "favorite_color": "red"})
12writer.close()
13
14# Read data from the file
15reader = DataFileReader(open("users.avro", "rb"), DatumReader())
16for user in reader:
17    print(user)
18reader.close()