跳到主要内容

使用 databend-sqlalchemy 集成 Databend Cloud

在本教程中,我们将引导您了解如何使用 databend-sqlalchemy 库连接到 Databend Cloud,创建表,插入数据以及使用 Python 查询结果。

准备工作

在开始之前,请确保您已成功创建计算集群并获得了连接信息。有关如何执行此操作,请参见 连接到计算集群

步骤 1:使用 pip 安装依赖项

pip install databend-sqlalchemy

步骤 2:使用 databend_sqlalchemy 连接

  1. 复制以下代码并粘贴到文件 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())
  1. 运行 python main.py
python main.py
[(1, 'yy'), (2, 'xx')]
开始使用 Databend Cloud
低成本
快速分析
多种数据源
弹性扩展
注册