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 you have Cython installed, 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('some-file.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

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

Uploaded Source

Built Distribution

fastavro-0.2.2-py2.7-linux-x86_64.egg (100.0 kB view details)

Uploaded Source

File details

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

File metadata

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

File hashes

Hashes for fastavro-0.2.2.tar.gz
Algorithm Hash digest
SHA256 40e4eff91b74bae582160531c7dc8afb67b7c4713087cfe282e9d82bd43bcc9e
MD5 1f511cf7b28e6559514efbb7c3be6e5e
BLAKE2b-256 b438b6ca250674e5e60e8abb628c87e34c4d40c2cb581b3169740961cb60739a

See more details on using hashes here.

File details

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

File metadata

File hashes

Hashes for fastavro-0.2.2-py2.7-linux-x86_64.egg
Algorithm Hash digest
SHA256 0ca302c396e58d3a02b11d3ded39ca0c2ca9e3ad28701e7462c8eba7737a8ac9
MD5 c3a4b759a6ccc14dee442690a48643d6
BLAKE2b-256 4722a836e27e65231b799e945a05e2786df57e289b44a464f06399cce725f671

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