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 script from the command line to dump avro files. Each record will be dumped to standard output in one line of JSON.

fastavro weather.avro

You can also dump the avro schema:

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

Hacking

As recommended by Cython, the C files output is distributed. This has the advantage that the end user does not need to have Cython installed. However it means that every time you change fastavro/pyfastavro.py you need to run make.

For make to succeed you need both python and python3 installed, cython on both of them. For ./test-install.sh you’ll need virtualenv.

Changes

See the ChangeLog

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.6.3.tar.gz (41.1 kB view details)

Uploaded Source

Built Distributions

fastavro-0.6.3-py3.2-linux-x86_64.egg (103.2 kB view details)

Uploaded Source

fastavro-0.6.3-py2.7-linux-x86_64.egg (102.6 kB view details)

Uploaded Source

File details

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

File metadata

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

File hashes

Hashes for fastavro-0.6.3.tar.gz
Algorithm Hash digest
SHA256 ce5827973f004fe48c57482002daa41ea6683848468be09c6552cf291c9b06f8
MD5 902e02ea0dda05b621ef2390d845873a
BLAKE2b-256 45034783c0b0db4e57994e520334db233ff55799fca52cc90bb377a63d36024e

See more details on using hashes here.

File details

Details for the file fastavro-0.6.3-py3.2-linux-x86_64.egg.

File metadata

File hashes

Hashes for fastavro-0.6.3-py3.2-linux-x86_64.egg
Algorithm Hash digest
SHA256 d4034ee25b30b1d49991dc61895fd9b2e0eeb52971ceb7c4eea86a49f898168a
MD5 83fedb92568b95e719f62d1c6d550bd5
BLAKE2b-256 8936d2c98863ce61cc7f9ef52ba59c81383d72bab449eb8373008f08b3bb32e7

See more details on using hashes here.

File details

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

File metadata

File hashes

Hashes for fastavro-0.6.3-py2.7-linux-x86_64.egg
Algorithm Hash digest
SHA256 8c3f57ac3caa415f542a6031e6ab14b015df0852e2227915682874560fd1ed35
MD5 9100cde4ee8a2012e4c06978f50d1429
BLAKE2b-256 2b37e61a7c3a402a4dc73b263faea5f24d9bd8d1e5a57dfa2b2c970fe88ffa2c

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