Databend 产品月报(2025年1月)

原创
02/07 14:10
阅读数 157

很高兴为您带来 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

DBeaver24.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

展开阅读全文
加载中
点击引领话题📣 发布并加入讨论🔥
0 评论
0 收藏
1
分享
返回顶部
顶部