o i@sdZdZdeZddlZddlZddlZddlZejj Z ej j Z ejj Z ejj Z ejjZejjZejjZejjZejjZejjZddeDdgZdS)a3Fast Avro file iteration. Example usage:: # Reading import fastavro with open('some-file.avro', 'rb') as fo: reader = fastavro.reader(fo) schema = reader.schema for record in reader: process_record(record) # Writing from fastavro import writer schema = { 'doc': 'A weather reading.', 'name': 'Weather', 'namespace': 'test', 'type': 'record', 'fields': [ {'name': 'station', 'type': 'string'}, {'name': 'time', 'type': 'long'}, {'name': 'temp', 'type': 'int'}, ], } # 'records' can be an iterable (including generator) records = [ {u'station': u'011990-99999', u'temp': 0, u'time': 1433269388}, {u'station': u'011990-99999', u'temp': 22, u'time': 1433270389}, {u'station': u'011990-99999', u'temp': -11, u'time': 1433273379}, {u'station': u'012650-99999', u'temp': 111, u'time': 1433275478}, ] with open('weather.avro', 'wb') as out: writer(out, schema, records) ) rz%s.%s.%sNcCsg|] }|ds|qS)_) startswith).0nrW/var/www/html/karishye-ai-python/venv/lib/python3.10/site-packages/fastavro/__init__.py ?sr __version__)__doc____version_info__r fastavro.readfastavrofastavro.writefastavro.schemafastavro.validationreadreader json_read json_reader block_readerschemaless_readerwritewriter json_write json_writerschemaless_writeris_avro validationvalidateschema parse_schemalocalskeys__all__rrrr s$*