Arrow Flight Samples
The Arrow Python bindings (also named “PyArrow”) have first-class integration with NumPy, pandas, and built-in Python objects. They are based on the C++ implementation of Arrow.
Queries can be sent and results retrieved as Pandas DataFrames. An example follows:
from pyarrow import flight
apiKey = '[API_KEY]'
query = 'SELECT * FROM eth.recent_blocks LIMIT 10;'
# Connect to the endpoint
client = flight.connect(f'grpc+tls://flight.spiceai.io')
# Authenticate with your app's API key
token_pair = client.authenticate_basic_token('', apiKey)
options = flight.FlightCallOptions(headers=[token_pair])
# Query and fetch a reader for the results
flight_info = client.get_flight_info(flight.FlightDescriptor.for_command(query), options)
reader = client.do_get(flight_info.endpoints.ticket, options)
# Convert to a Pandas DataFrame and print the results