dremio_client.flight package

Submodules

dremio_client.flight.command_pb2 module

dremio_client.flight.flight_auth module

class dremio_client.flight.flight_auth.HttpDremioClientAuthHandler(username, password)

Bases: pyarrow._flight.ClientAuthHandler

authenticate(self, outgoing, incoming)

Conduct the handshake with the server.

outgoing : ClientAuthSender

A channel to send messages to the server.

incoming : ClientAuthReader

A channel to read messages from the server.

get_token(self)

Get the auth token for a call.

Module contents

dremio_client.flight.connect(hostname='localhost', port=47470, username='dremio', password='dremio123', tls_root_certs_filename=None)

Connect to and authenticate against Dremio’s arrow flight server. Auth is skipped if username is None

Parameters:

• hostname – Dremio coordinator hostname
• port – Dremio coordinator port
• username – Username on Dremio
• password – Password on Dremio
• tls_root_certs_filename – use ssl to connect with root certs from filename

Returns:

arrow flight client

dremio_client.flight.query(sql, client=None, hostname='localhost', port=47470, username='dremio', password='dremio123', pandas=True, tls_root_certs_filename=False)

Run an sql query against Dremio and return a pandas dataframe or arrow table

Either host,port,user,pass tuple or a pre-connected client should be supplied. Not both

Parameters:

• sql – sql query to execute on dremio
• client – pre-connected client (optional)
• hostname – Dremio coordinator hostname (optional)
• port – Dremio coordinator port (optional)
• username – Username on Dremio (optional)
• password – Password on Dremio (optional)
• pandas – return a pandas dataframe (default) or an arrow table
• tls_root_certs_filename – use ssl to connect with root certs from filename

Returns: