Skip to main content

Fast iteration of AVRO files

Project description

fastavro

The current Python avro package is packed with features but dog slow.

On a test case of about 10K records, it takes about 14sec to iterate over all of them. In comparison the JAVA avro SDK does it in about 1.9sec.

fastavro is less feature complete than avro, however it’s much faster. It iterates over the same 10K records in 2.9sec, and if you use it with PyPy it’ll do it in 1.5sec (to be fair, the JAVA benchmark is doing some extra JSON encoding/decoding).

If the options C extension (generated by Cython) is available, then fastavro will be even faster. For the same 10K records it’ll run in about 1.7sec.

Usage

from fastavro import iter_avro

with open('weather.avro', 'rb') as fo:
    avro = iter_avro(fo)
    schema = avro.schema

    for record in avro:
        process_record(record)

You can also use the fastavro module from the command line to dump avro files. Each record will be dumped to standard output in one line of JSON.

python -m fastavro weather.avro

You can also dump the avro schema:

python -m fastavro --schema weather.avro

Limitations

  • Support only iteration
    • No writing for you!

  • Supports only null and deflate codecs
    • avro also supports snappy

  • No reader schema

Contact

Miki Tebeka <miki.tebeka@gmail.com> https://bitbucket.org/tebeka/fastavro

Project details


Release history Release notifications | RSS feed

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

fastavro-0.3.0.tar.gz (39.8 kB view details)

Uploaded Source

Built Distribution

fastavro-0.3.0-py2.7-linux-x86_64.egg (100.1 kB view details)

Uploaded Source

File details

Details for the file fastavro-0.3.0.tar.gz.

File metadata

  • Download URL: fastavro-0.3.0.tar.gz
  • Upload date:
  • Size: 39.8 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No

File hashes

Hashes for fastavro-0.3.0.tar.gz
Algorithm Hash digest
SHA256 3c0e85f85a094c54411d9c821f40a8508d836f6fef0e92e347ee4553b698f93b
MD5 f175113ff2b5b4c73bb0d6a58ef15c83
BLAKE2b-256 1edc695d1fdb8d8a7ec1b8d9e48cfa3020b49b2b89d4e973309acf8f4e221dad

See more details on using hashes here.

File details

Details for the file fastavro-0.3.0-py2.7-linux-x86_64.egg.

File metadata

File hashes

Hashes for fastavro-0.3.0-py2.7-linux-x86_64.egg
Algorithm Hash digest
SHA256 e4e8dae9d399821a9a1c7f3e88b545979d4ffb5cda2ef9465448b87c03fcd198
MD5 e23b9590e981b13a16f9610ef7b8e1d0
BLAKE2b-256 e930c5ff79b0bde3e702792bb9db996c69eba7e3e3295b177e497ad7a4a2b0a3

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page