fastairport 0.2.0

The fast, Pythonic way to build Arrow Flight servers with Polars and Pydantic.

FastAirport

A tiny wrapper around Apache Arrow Flight for building analytical services.

from fastairport import FastAirport, Context
import pyarrow as pa

airport = FastAirport("Demo")

@airport.endpoint("echo")
def echo(data: pa.Table, ctx: Context) -> pa.Table:
    ctx.info(f"rows: {data.num_rows}")
    return data

airport.start()

Clients send and receive Arrow tables:

from fastairport import Client

client = Client("localhost:8815")
result = client.call("echo", pa.table({"a": [1, 2]}))
client.close()