最近更新时间:2023.09.11 19:32:58
首次发布时间:2023.08.04 16:09:50
ByteHouse 提供了支持 Python 数据库 API 规范 v2.0 的驱动程序。 本文将介绍如何通过 Python 驱动的方式连接并访问 ByteHouse 云数仓。
请访问 github 项目主页,获取ByteHouse Python 驱动最新的文档和发布版本。
说明
需要 Python 3.7 或更高版本的支持。
可以通过如下命令,获取最新发布版本的 bytehouse-driver。
pip install bytehouse-driver
开发版本通过如下命令安装。
pip install git+https://github.com/bytehouse-cloud/driver-py@main#egg=bytehouse-driver
根据您的 Python 版本,您可能需要安装以下依赖项:
请参考通过驱动连接到 ByteHouse,了解如何通过API Token或用户名+密码的方式连接到ByteHouse。
可参考下面代码样例,注意替换连接语句中的client设置字段。
from bytehouse_driver import Client #Passing Parameters client = Client( host=HOST, port=PORT, account=ACCOUNT, user=USER, password=PASSWORD secure=true ) ### DDL Query client.execute("CREATE DATABASE demo_db") client.execute("CREATE TABLE demo_db.demo_tb (id INT) ENGINE=CnchMergeTree() ORDER BY tuple()") ### DML Query client.execute("INSERT INTO demo_db.demo_tb VALUES", [[1], [2], [3]]) ### DQL Query result_set = client.execute("SELECT * FROM demo_db.demo_tb") for result in result_set: print(result) client.execute("DROP DATABASE demo_db")