Serialization Formats
Schema-Based Data Serialization
★ 4.5
Columnar Storage Format
★ 4.8
pip install avro-python3pip install pyarrowpip install avro-python3pip install pyarrowPython data engineers use `fastavro` to serialize and deserialize Avro records in Kafka-based pipelines. Schema Registry integration means Python producers validate records against the registered schema before publishing, and consumers deserialize binary Avro messages back to Python dicts automatically. Avro's compact binary encoding reduces Kafka topic storage costs compared to JSON.
Parquet is the standard output format for Python data pipelines writing to a data lake. Engineers use `pandas.to_parquet()` or `pyarrow.parquet.write_table()` to write DataFrames as efficiently compressed columnar files. Reading is equally simple — `pd.read_parquet('s3://bucket/prefix/')` reads an entire partitioned dataset, with DuckDB and Athena capable of querying Parquet files directly without loading.
Individual Tool Pages