Databend 产品月报（2025 年 1 月）

2025-02-07
福建
本文字数：1546 字
阅读完需：约 5 分钟

很高兴为您带来 Databend 2025 年 1 月的最新更新、新功能和改进！我们希望这些增强功能对您有所帮助，并期待您的反馈，祝您新春快乐！

本地计算集群

现在，您可以使用 SQL 命令管理本地计算集群，从而更轻松地在自托管的 Databend 环境中创建、扩展和提升查询性能。

CREATE WAREHOUSE my_warehouse (ASSIGN 1 NODESFROM      log_node,ASSIGN 2 NODESFROM      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 queriescursor = client.cursor()
# Drop the table if it existscursor.execute('DROP TABLE IF EXISTS data')
# Create the table if it doesn't existcursor.execute('CREATE TABLE IF NOT EXISTS data (x Int32, y String)')          
# Insert data into the tablecursor.execute("INSERT INTO data (x, y) VALUES (1, 'yy'), (2, 'xx')")
# Select all data from the tablecursor.execute('SELECT * FROM data')
# Fetch all rows from the resultrows = cursor.fetchall()
# Print the resultfor 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}