![]()
很高兴为您带来 Databend 2025 年 1 月的最新更新、新功能和改进！我们希望这些增强功能对您有所帮助，并期待您的反馈，祝您新春快乐！
本地计算集群
现在，您可以使用 SQL 命令管理本地计算集群，从而更轻松地在自托管的 Databend 环境中创建、扩展和提升查询性能。
CREATE WAREHOUSE my_warehouse (
ASSIGN 1 NODES
FROM log_node,
ASSIGN 2 NODES
FROM infra_node
);
要详细了解相关概念和示例，请参阅 通过 SQL 管理本地查询计算集群。有关计算集群的相关命令，请参阅 计算集群相关命令。 ![]()
全新 Python 驱动：databend-driver
我们推出了适用于 Databend 的全新 Python 驱动 databend-driver，支持同步和异步接口，与 Databend 的交互更加流畅。借助该驱动，您可以更高效地执行 SQL 查询和管理数据操作。
-
教程 ：使用 databend-driver 集成 Databend Cloud
-
重要提醒 ：此前的 Python 驱动 databend-py 已被弃用。
from databend_driver import BlockingDatabendClient
Connecting to Databend Cloud with your credentials (replace PASSWORD, HOST, DATABASE, and WAREHOUSE_NAME)
client = BlockingDatabendClient(f"databend://cloudapp:{PASSWORD}@{HOST}:443/{DATABASE}?warehouse={WAREHOUSE_NAME}")
Get a cursor from the client to execute queries
cursor = client.cursor()
Drop the table if it exists
cursor.execute('DROP TABLE IF EXISTS data')
Create the table if it doesn't exist
cursor.execute('CREATE TABLE IF NOT EXISTS data (x Int32, y String)')
Insert data into the table
cursor.execute("INSERT INTO data (x, y) VALUES (1, 'yy'), (2, 'xx')")
Select all data from the table
cursor.execute('SELECT * FROM data')
Fetch all rows from the result
rows = cursor.fetchall()
Print the result
for row in rows: print(row.values())
从 MySQL 迁移至 Databend：使用 db-archiver
Databend 推荐使用 db-archiver 迁移 MySQL 数据。db-archiver 是 Databend 开发的原生归档工具，提供开箱即用的解决方案，可高效地将数据从数据库或其他来源归档到 Databend。
db-archiver 支持通过 JSON 配置文件定义迁移的源和目标详细信息。有关完整的迁移教程，请参阅 Migrating from MySQL with db-archiver。
{
// 将占位符替换为您的实际值：
"sourceHost": "127.0.0.1",
"sourcePort": 3306,
"sourceUser": "root",
"sourcePass": "root",
"sourceDB": "mydb",
"sourceTable": "my_table",
"sourceQuery": "select * from mydb.my_table",
"sourceSplitKey": "id",
"sourceWhereCondition": "id < 100",
"databendDSN": "https://cloudapp:{password}@{host}:443?warehouse={warehouse_name}",
"databendTable": "{database}.my_table",
"batchSize": 2,
"batchMaxInterval": 30,
"workers": 1,
"copyPurge": false,
"copyForce": false,
"disableVariantCheck": false,
"deleteAfterSync": false,
"maxThread": 10
}
教程：使用 DBeaver 连接到 Databend
DBeaver 从 24.3.1 版本开始支持使用内置驱动连接到 Databend。以下教程已更新：
关于 Databend
Databend 是一款开源、弹性、低成本，基于对象存储也可以做实时分析的新式数仓。期待您的关注，一起探索云原生数仓解决方案，打造新一代开源 Data Cloud。
👨💻 Databend Cloud：https://databend.cn
📖 Databend 文档：https://docs.databend.com
💻 Wechat：Databend
✨ GitHub：https://github.com/databendlabs/databend
很高兴为您带来 Databend 2025 年 1 月的最新更新、新功能和改进！我们希望这些增强功能对您有所帮助，并期待您的反馈，祝您新春快乐！
