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 optional 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

import fastavro as avro

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

    for record in reader:
        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.5.0.tar.gz (40.8 kB view details)

Uploaded Source

Built Distribution

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

Uploaded Source

File details

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

File metadata

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

File hashes

Hashes for fastavro-0.5.0.tar.gz
Algorithm Hash digest
SHA256 bd2cd2f6312fb4bcc4276c0381178521ac0876c0c3019a7e614bce8a2c4846f1
MD5 86944feb49d03da69950f9e35d454baf
BLAKE2b-256 eca3c692c656f881ae83e50ff994701c01e2a82221df0ea6dd2c7a62908d4229

See more details on using hashes here.

File details

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

File metadata

File hashes

Hashes for fastavro-0.5.0-py2.7-linux-x86_64.egg
Algorithm Hash digest
SHA256 404c91b4bce968b49a7e8da4fb5de91c8b817c74b183ae38b76c9ab8c05a80f8
MD5 8d8058b3c2913346f3ec5848f632581c
BLAKE2b-256 dfb7bf2557b69489c7bbab56797062cb9bfe7652d0d151a3ea9d2ca2062e0e85

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