Skip to content
ClickHouse Docs
ClickHouse DocsClickHouse Docs
49.6kGet Started

连接到数据目录

View as MarkdownEdit this pageReport an issueSet up docs MCP

在上一节中，你通过直接传入存储路径来查询开放表格式。实际使用中，大多数组织都会通过数据目录管理表元数据——也就是一个集中式注册中心，用于跟踪表的位置、schema 和分区。当你使用 DataLakeCatalog 数据库引擎将 ClickHouse 连接到某个目录时，整个目录都会作为一个 ClickHouse 数据库对外暴露。目录中的每张表都会自动显示出来，并且都可以使用完整的 ClickHouse SQL 进行查询——无需知道各个表的具体路径，也无需为每张表单独管理凭证。

本指南将逐步介绍如何连接到 Databricks Unity Catalog。ClickHouse 还支持以下目录——完整设置说明请参阅各自的参考指南：

目录 参考指南
AWS Glue AWS Glue catalog
Iceberg REST Catalog REST catalog
Lakekeeper Lakekeeper catalog
Project Nessie Nessie catalog
Microsoft OneLake Fabric OneLake
SeaweedFS SeaweedFS catalog

连接到 Unity Catalog

Beta 版功能

为便于演示，我们将使用 Unity Catalog。

Databricks Unity Catalog 为 Databricks 湖仓中的数据提供集中式治理。

Databricks 的湖仓支持多种数据格式。借助 ClickHouse，你可以查询使用外部存储位置的 Unity Catalog Delta 表和 Iceberg 表。

在 Databricks 中配置 Unity

要让 ClickHouse 能与 Unity Catalog 交互，您需要确保 Unity Catalog 已配置为允许外部读取器访问。可按照“启用 Unity Catalog 的外部数据访问”指南进行配置。

除了启用外部访问外，还要确保负责配置该集成的主体对包含这些表的 schema 具有 EXTERNAL USE SCHEMA 权限。

配置好目录后，您还必须为 ClickHouse 生成 credentials。根据您与 Unity 的交互方式，可以采用两种不同的方法：

  • 对于 Iceberg 客户端，请使用服务主体进行身份验证。

  • 对于 Delta 客户端，请使用个人访问令牌 (PAT) 。

连接到目录

有了凭据后，您可以连接到相应的端点，查询 Iceberg 或 Delta 表。

应使用 Unity 目录 访问 Delta 格式的数据。

SET allow_experimental_database_unity_catalog = 1;

CREATE DATABASE unity
ENGINE = DataLakeCatalog('https://<workspace-id>.cloud.databricks.com/api/2.1/unity-catalog')
SETTINGS warehouse = 'CATALOG_NAME', catalog_credential = '<PAT>', catalog_type = 'unity';

列出表

与您的目录建立连接后，您就可以列出其中的表。

SHOW TABLES FROM unity
┌─name───────────────────────────────────────────────┐
│ unity.logs                                         │
│ unity.single_day_log                               │
└────────────────────────────────────────────────────┘

31 rows in set.

探索表 schema

我们可以使用标准的 SHOW CREATE TABLE 命令来查看这些表的创建方式。

以下内容假定查询的是 REST Iceberg 目录：

SHOW CREATE TABLE unity.`icebench.single_day_log`

CREATE TABLE unity.`icebench.single_day_log`
(
    `pull_request_number` Nullable(Int64),
    `commit_sha` Nullable(String),
    `check_start_time` Nullable(DateTime64(6, 'UTC')),
    `check_name` Nullable(String),
    `instance_type` Nullable(String),
    `instance_id` Nullable(String),
    `event_date` Nullable(Date32),
    `event_time` Nullable(DateTime64(6, 'UTC')),
    `event_time_microseconds` Nullable(DateTime64(6, 'UTC')),
    `thread_name` Nullable(String),
    `thread_id` Nullable(Decimal(20, 0)),
    `level` Nullable(String),
    `query_id` Nullable(String),
    `logger_name` Nullable(String),
    `message` Nullable(String),
    `revision` Nullable(Int64),
    `source_file` Nullable(String),
    `source_line` Nullable(Decimal(20, 0)),
    `message_format_string` Nullable(String)
)
ENGINE = Iceberg('s3://...')

查询表

支持所有 ClickHouse 函数。同样，命名空间和表名都应使用反引号括起来。

SELECT count()
FROM unity.`icebench.single_day_log`
┌───count()─┐
│ 282634391 │ -- 2.8263 亿
└───────────┘

1 row in set. Elapsed: 1.265 sec.

如需完整的设置说明，请参阅 Unity Catalog 参考指南。

Navigation