Module pyfx.api.avro

Utility functions to convert pandas DataFrames to avro.

Classes

class AvroStream (schema: Dict[str, Any], records_stream: Generator[Dict[str, Any], None, None])

Readable Avro Stream.

Static methods

def from_dataframe(dataframe: pandas.core.frame.DataFrame) ‑> AvroStream

Create an AvroStream from a pandas Dataframe.

Methods

def read(self, size: int) ‑> bytes

See RawIOBase corresponding method.