跳到主要内容

使用 databend-sqlalchemy 集成 Databend Cloud

在本教程中,我们将引导你使用 databend-sqlalchemy 库连接 Databend Cloud,并通过 Python 创建表、插入数据及查询结果。

在开始之前

开始前,请确保已成功创建计算集群(Warehouse)并获取连接信息。具体操作请参阅连接计算集群(Warehouse)

第一步:使用 pip 安装依赖项

pip install databend-sqlalchemy

第二步:使用 databend_sqlalchemy 连接

  1. 复制以下代码至文件 main.py
from sqlalchemy import create_engine, text
from sqlalchemy.engine.base import Connection, Engine

# Connecting to Databend Cloud with your credentials (replace PASSWORD, HOST, DATABASE, and WAREHOUSE_NAME)
engine = create_engine(
f"databend://{username}:{password}@{host_port_name}/{database_name}?sslmode=disable"
)
cursor = engine.connect()
cursor.execute(text('DROP TABLE IF EXISTS data'))
cursor.execute(text('CREATE TABLE IF NOT EXISTS data( Col1 TINYINT, Col2 VARCHAR )'))
cursor.execute(text("INSERT INTO data VALUES (1,'zz')"))
res = cursor.execute(text("SELECT * FROM data"))
print(res.fetchall())
  1. 运行 python main.py
python main.py
[(1, 'zz')]
开始使用 Databend Cloud
低成本
快速分析
多种数据源
弹性扩展
注册