Skip to main content

Databricks 的 SQLAlchemy 方言

项目描述

sqlalchemy-databricks

皮皮 版本

使用官方支持的databricks-sql-connector dbapi 的 Databricks 工作区和 sql 分析集群的 SQLAlchemy 方言。

安装

使用 pip 安装。

pip install sqlalchemy-databricks

用法

安装databricks+connector使用 SQLAlchemy 注册方言/驱动程序。传递引擎 URL 时填写必填信息。http 路径可以用于工作区或 sql 分析集群。

from sqlalchemy import *
from sqlalchemy.engine import create_engine


engine = create_engine(
    "databricks+connector://token:<databricks_token>@<databricks_host>:443/<database_or_schema_name>",
    connect_args={
        "http_path": "<cluster_http_path>",
    },
)

logs = Table("my_table", MetaData(bind=engine), autoload=True)
print(select([func.count("*")], from_obj=logs).scalar())

项目详情


下载文件

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

源分布

sqlalchemy-databricks-0.2.0.tar.gz (4.2 kB 查看哈希)

已上传 source

内置分布

sqlalchemy_databricks-0.2.0-py3-none-any.whl (4.3 kB 查看哈希

已上传 py3