fastavro.json_read

json_reader(fo, schema)

Iterator over records in an avro json file.

Parameters
  • fo (file-like) – Input stream

  • reader_schema (dict) – Reader schema

Example:

from fastavro import json_reader
with open('some-file', 'r') as fo:
    avro_reader = json_reader(fo)
    for record in avro_reader:
        print(record)