catalogue Snowflake Horizon

ClickHouse peut se connecter au catalogue Horizon de Snowflake via l’API REST Iceberg exposée par Horizon (basée sur Apache Polaris). Vous pouvez ainsi lire et écrire des tables Iceberg gérées par Snowflake depuis ClickHouse à l’aide du moteur de base de données DataLakeCatalog avec catalog_type = 'horizon'. Horizon est lié à Snowflake Open Catalog / Polaris auto-hébergé, mais il s’agit de solutions distinctes :

	Open Catalog / Polaris (`catalog_type = 'rest'`)	Horizon (`catalog_type = 'horizon'`)
Endpoint	URI d’Open Catalog ou de Polaris auto-hébergé	`https://<org>-<account>.snowflakecomputing.com/polaris/api/catalog`
Warehouse	Nom du catalogue / warehouse Polaris	Nom de la base de données Snowflake (généralement en majuscules)
Portée d’authentification	`PRINCIPAL_ROLE:ALL` (généralement)	`session:role:<ROLE>`
Identifiants	`client_id:client_secret`	PAT ou JWT par paire de clés comme `catalog_credential` (OAuth client_secret ; non séparé sur ’:’), ou en-tête d’autorisation `auth_header`

Cette fonctionnalité étant en bêta, activez-la avec : SET allow_experimental_database_iceberg = 1; (ou SET allow_database_iceberg = 1; selon votre version de ClickHouse).

Prérequis

Un compte Snowflake avec des tables Iceberg gérées par Snowflake
Endpoint REST Horizon Iceberg : https://<organization>-<account>.snowflakecomputing.com/polaris/api/catalog
Un rôle Snowflake disposant de privilèges sur les tables Iceberg (et de privilèges d’écriture si vous effectuez un INSERT)
Authentification via l’un des éléments suivants :
- Jeton d’accès programmatique (PAT)
- JWT à paire de clés échangé contre un jeton d’accès
- Jeton d’accès OAuth externe (en tant qu’en-tête auth_header Bearer)
Stockage d’objets accessible depuis ClickHouse (les identifiants fournis sont recommandés)
ClickHouse avec prise en charge d’Iceberg dans DataLakeCatalog

Création d’une connexion

Option A : jeton d’accès programmatique (recommandé)

SET allow_experimental_database_iceberg = 1;

CREATE DATABASE horizon_catalog
ENGINE = DataLakeCatalog('https://<org>-<account>.snowflakecomputing.com/polaris/api/catalog')
SETTINGS
    catalog_type = 'horizon',
    warehouse = 'ICEBERG_TEST_DB',
    catalog_credential = '<PAT>',
    auth_scope = 'session:role:DATA_ENGINEER',
    oauth_server_uri = 'https://<org>-<account>.snowflakecomputing.com/polaris/api/catalog/v1/oauth/tokens',
    vended_credentials = 1;

warehouse doit correspondre au nom de la base de données Snowflake (et non à un entrepôt virtuel Snowflake). Les identifiants Snowflake non entre guillemets sont en majuscules.

Option B : jeton d’accès Bearer obtenu au préalable

CREATE DATABASE horizon_catalog
ENGINE = DataLakeCatalog('https://<org>-<account>.snowflakecomputing.com/polaris/api/catalog')
SETTINGS
    catalog_type = 'horizon',
    warehouse = 'ICEBERG_TEST_DB',
    auth_header = 'Authorization: Bearer <ACCESS_TOKEN>',
    vended_credentials = 1;

Interroger des tables Iceberg

USE horizon_catalog;
SHOW TABLES;

SELECT count(*) FROM `PUBLIC.test_table`;
SHOW CREATE TABLE `PUBLIC.test_table`;

L’espace de noms (schéma) et la table sont généralement référencés sous la forme `SCHEMA.table`, sauf si les espaces de noms de table expérimentaux sont activés.

Chemin d’écriture

Avec un rôle disposant des autorisations INSERT/UPDATE/DELETE (et CREATE ICEBERG TABLE lors de la création de tables), ClickHouse peut écrire via le même catalogue :

-- Insert into an existing Snowflake-managed Iceberg table
INSERT INTO horizon_catalog.`PUBLIC.test_table`
SELECT
    number AS id,
    concat('name_', toString(number)) AS name
FROM numbers(100);

-- Create a new Iceberg table in the Horizon catalog (requires CREATE ICEBERG TABLE)
CREATE TABLE horizon_catalog.`PUBLIC.clickhouse_written`
(
    id Int64,
    name String
)
ENGINE = Iceberg;

La syntaxe exacte de CREATE TABLE dépend de la prise en charge des écritures ClickHouse Iceberg / DataLakeCatalog pour les REST catalogues dans votre version ; les problèmes de privilèges Snowflake se manifestent sous forme d’erreurs HTTP du catalogue.

Chargement dans MergeTree

CREATE TABLE my_clickhouse_table
(
    id Int64,
    name String
)
ENGINE = MergeTree
ORDER BY id;

INSERT INTO my_clickhouse_table
SELECT * FROM horizon_catalog.`PUBLIC.test_table`;

ClickHouse guides

Use case guides

Prérequis

Création d’une connexion

Option A : jeton d’accès programmatique (recommandé)

Option B : jeton d’accès Bearer obtenu au préalable

Interroger des tables Iceberg

Chemin d’écriture

Chargement dans MergeTree

​Prérequis

​Création d’une connexion

​Option A : jeton d’accès programmatique (recommandé)

​Option B : jeton d’accès Bearer obtenu au préalable

​Interroger des tables Iceberg

​Chemin d’écriture

​Chargement dans MergeTree

Prérequis

Création d’une connexion

Option A : jeton d’accès programmatique (recommandé)

Option B : jeton d’accès Bearer obtenu au préalable

Interroger des tables Iceberg

Chemin d’écriture

Chargement dans MergeTree