Skip to main content

Databricks SQL Connector for Python

Project description

Databricks SQL Connector for Python

PyPI Downloads

The Databricks SQL Connector for Python allows you to develop Python applications that connect to Databricks clusters and SQL warehouses. It is a Thrift-based client with no dependencies on ODBC or JDBC. It conforms to the Python DB API 2.0 specification and exposes a SQLAlchemy dialect for use with tools like pandas and alembic which use SQLAlchemy to execute DDL. Use pip install databricks-sql-connector[sqlalchemy] to install with SQLAlchemy's dependencies. pip install databricks-sql-connector[alembic] will install alembic's dependencies.

This connector uses Arrow as the data-exchange format, and supports APIs to directly fetch Arrow tables. Arrow tables are wrapped in the ArrowQueue class to provide a natural API to get several rows at a time.

You are welcome to file an issue here for general use cases. You can also contact Databricks Support here.

Requirements

Python 3.7 or above is required.

Documentation

For the latest documentation, see

Quickstart

Install the library with pip install databricks-sql-connector

Note: Don't hard-code authentication secrets into your Python. Use environment variables

export DATABRICKS_HOST=********.databricks.com
export DATABRICKS_HTTP_PATH=/sql/1.0/endpoints/****************
export DATABRICKS_TOKEN=dapi********************************

Example usage:

import os
from databricks import sql

host = os.getenv("DATABRICKS_HOST")
http_path = os.getenv("DATABRICKS_HTTP_PATH")
access_token = os.getenv("DATABRICKS_TOKEN")

connection = sql.connect(
  server_hostname=host,
  http_path=http_path,
  access_token=access_token)

cursor = connection.cursor()

cursor.execute('SELECT * FROM RANGE(10)')
result = cursor.fetchall()
for row in result:
  print(row)

cursor.close()
connection.close()

In the above example:

  • server-hostname is the Databricks instance host name.
  • http-path is the HTTP Path either to a Databricks SQL endpoint (e.g. /sql/1.0/endpoints/1234567890abcdef), or to a Databricks Runtime interactive cluster (e.g. /sql/protocolv1/o/1234567890123456/1234-123456-slid123)
  • personal-access-token is the Databricks Personal Access Token for the account that will execute commands and queries

Contributing

See CONTRIBUTING.md

License

Apache License 2.0

Project details


Release history Release notifications | RSS feed

Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

databricks_sql_connector-3.0.0b1.tar.gz (400.2 kB view details)

Uploaded Source

Built Distribution

databricks_sql_connector-3.0.0b1-py3-none-any.whl (412.7 kB view details)

Uploaded Python 3

File details

Details for the file databricks_sql_connector-3.0.0b1.tar.gz.

File metadata

File hashes

Hashes for databricks_sql_connector-3.0.0b1.tar.gz
Algorithm Hash digest
SHA256 821cca9c86bda92bc6ecdd0ab5880190063577ce9f82b74209b1cdf45839d2a6
MD5 edb960e71919403751c064ef5df1e06d
BLAKE2b-256 deaf4e0da6fb7fbc5acc88be5cb3c265fbbc540eaa6eb25b5acf7ad1c42948a2

See more details on using hashes here.

File details

Details for the file databricks_sql_connector-3.0.0b1-py3-none-any.whl.

File metadata

File hashes

Hashes for databricks_sql_connector-3.0.0b1-py3-none-any.whl
Algorithm Hash digest
SHA256 eae5f04621bc68dbd4535ddbe8bf5cad1e185c098f127d2b693fe8b06b8b713c
MD5 be03b058c556833b5e56e74217bf33c8
BLAKE2b-256 8b52a96e9ea260f2c77f3e1188a232eca0dd97dbf8facbc0fa6620e13d39afe8

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page