メモ:
import fastavro
import pandas as pd
import cramjam
from io import BytesIO
def read_avro_file(filename):
records = []
with open(filename, 'rb') as f:
reader = fastavro.reader(f)
for record in reader:
records.append(record)
return records
avro_file = './allevents.avro'
# Read
avro_data = read_avro_file(avro_file)
# Dataframe magic!
df = pd.DataFrame(avro_data)
# display as table!
df