跳转到主要内容

Databricks SQL Connector for Python

项目描述

Databricks SQL Connector for Python

PyPI Downloads

Python Databricks SQL 连接器允许您开发连接到 Databricks 集群和 SQL 仓库的 Python 应用程序。它是一个基于 Thrift 的客户端,不依赖于 ODBC 或 JDBC。它符合 Python DB API 2.0 规范,并公开了一个 SQLAlchemy 方言,用于与 pandasalembic 等工具一起使用,这些工具使用 SQLAlchemy 执行 DDL。使用 pip install databricks-sql-connector[sqlalchemy] 安装时包含 SQLAlchemy 的依赖项。使用 pip install databricks-sql-connector[alembic] 将安装 alembic 的依赖项。

此连接器使用 Arrow 作为数据交换格式,并支持直接获取 Arrow 表的 API。Arrow 表封装在 ArrowQueue 类中,以提供一次性获取多行数据的自然 API。

欢迎在此处提交关于一般用例的问题。您也可以通过 此处 联系 Databricks 支持。

要求

需要 Python 3.8 或更高版本。

文档

有关最新文档,请参阅

快速入门

使用 pip install databricks-sql-connector 安装库

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

示例用法

import os
from databricks import sql

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

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

cursor = connection.cursor()
cursor.execute('SELECT :param `p`, * FROM RANGE(10)', {"param": "foo"})
result = cursor.fetchall()
for row in result:
  print(row)

cursor.close()
connection.close()

在上面的示例中

  • server-hostname 是 Databricks 实例的主机名。
  • http-path 是 HTTP 路径,可以是 Databricks SQL 端点(例如,/sql/1.0/endpoints/1234567890abcdef)或 Databricks Runtime 交互式集群(例如,/sql/protocolv1/o/1234567890123456/1234-123456-slid123)的路径。

注意:此示例使用 Databricks OAuth U2M 进行目标 Databricks 用户帐户的认证,需要打开浏览器进行认证。因此,它只能在用户的机器上运行。

贡献

请参阅 CONTRIBUTING.md

许可

Apache License 2.0

项目详情


发布历史 发布通知 | RSS 源

下载文件

下载适合您平台的文件。如果您不确定选择哪个,请了解更多关于安装包的信息。

源分布

databricks_sql_connector-3.4.0.tar.gz (411.2 kB 查看哈希值)

上传时间

构建分布

databricks_sql_connector-3.4.0-py3-none-any.whl (428.3 kB 查看哈希值)

上传时间 Python 3

由以下支持

AWS AWS 云计算和安全赞助商 Datadog Datadog 监控 Fastly Fastly CDN Google Google 下载分析 Microsoft Microsoft PSF 赞助商 Pingdom Pingdom 监控 Sentry Sentry 错误日志 StatusPage StatusPage 状态页面