使用 databend-sqlalchemy 与 Databend Cloud 集成
在本教程中，我们将指导您如何使用 databend-sqlalchemy 库连接到 Databend Cloud，创建表，插入数据，并使用 Python 查询结果。
开始之前
在开始之前，请确保您已成功创建计算集群并获取了连接信息。有关如何操作，请参阅 连接到计算集群。
第一步：使用 pip 安装依赖项
pip install databend-sqlalchemy
第二步：使用 databend_sqlalchemy 连接
- 将以下代码复制并粘贴到文件
main.py中：
from databend_sqlalchemy import connector
# 使用您的凭据连接到 Databend Cloud（替换 PASSWORD、HOST、DATABASE 和 WAREHOUSE_NAME）
cursor = connector.connect(f"databend://cloudapp:{PASSWORD}@{HOST}:443/{DATABASE}?warehouse={WAREHOUSE_NAME}").cursor()
cursor.execute('DROP TABLE IF EXISTS data')
cursor.execute('CREATE TABLE IF NOT EXISTS data( Col1 TINYINT, Col2 VARCHAR )')
cursor.execute("INSERT INTO data (Col1, Col2) VALUES (%s, %s), (%s, %s)", [1, 'yy', 2, 'xx'])
cursor.execute("SELECT * FROM data")
print(cursor.fetchall())
- 运行
python main.py：
python main.py
[(1, 'yy'), (2, 'xx')]
