Skip to main content
Estuary は、ClickHouse のネイティブプロトコルネイティブフォーマットを使用する、ClickHouse 向けの直接マテリアライゼーションコネクタを提供します。 これにより、Estuary では次のことが可能です。
  • セルフホスト環境と ClickHouse Cloud インスタンスの両方にデータをマテリアライズする
  • テーブル作成やスキーマ進化などのタスクを自動的に処理する
  • 論理削除と物理削除をサポートする
  • 通常のマージ更新には ReplacingMergeTree、デルタ更新には MergeTree を使用する
  • exactly-once 配信を提供する
ClickPipes ワークフローについては、Estuary の Kafka ClickPipe インテグレーションを参照してください。

セットアップガイド

前提条件 以下が必要です。
  • Estuary アカウント
  • 任意のデータソースからデータを取得する、Estuary の 1 つ以上の キャプチャ
  • セルフホストの ClickHouse インスタンス、または ClickHouse Cloud アカウント
  • 認証情報を持つ ClickHouse データベースユーザー
1

インテグレーション用に ClickHouse を設定する

Estuary の ClickHouse コネクタをセットアップするには、ClickHouse インスタンスからいくつかの情報を収集し、ユーザー権限を設定する必要があります。
  1. データベースのホストエンドポイントをコピーします。 ポートには、TLS が有効な場合は 9440、無効な場合は 9000 を使用します。 ホストとポートを組み合わせたものが、Estuary に指定する アドレス になります。
  2. Estuary がアクセスするデータベースユーザーに権限を付与します。 Estuary がテーブルを自動的に作成・管理するには、移行先データベースに対する CREATESELECTINSERT などの権限に加え、メタデータ検出およびパーティション管理の権限が必要です。 次の SQL コマンドを実行し、<database><user> を実際の値に置き換えると、必要なすべての権限を付与できます。
  3. 必要に応じて、ユーザーのシステムアクセスを移行先データベースのみに制限します。 これは行レベルポリシーで設定できます。例:
その後、Estuary に移動してセットアップを完了できます。
2

Estuary のマテリアライゼーションを作成する

  1. Estuary のダッシュボードで、Destinations ページに移動します。
  2. + New Materialization をクリックします。
  3. ClickHouse コネクタを選択します。
  4. Materialization Details セクションに入力します。
    • マテリアライゼーションに一意の名前を付けます
    • データプレーン (クラウドプロバイダーとリージョン) を選択します
  5. Estuary が ClickHouse インスタンスに接続できるよう、Endpoint Config の詳細を入力します。
    • Address: インスタンスのホストとポート
    • Database: 移行先データベース名
    • Authentication: データベースユーザーのユーザー名とパスワード
    物理削除を使用するかどうかや SSL モードなど、任意の設定も構成できます。
3

ソースコレクションを設定する

Source Collections セクションで、ClickHouse にマテリアライズするログソースを選択します。
  1. 既存の キャプチャ をリンクするか、ClickHouse にマテリアライズする個別のデータコレクションを追加します。
  2. 必要に応じて追加設定するデータコレクションをリストから選択します。カスタマイズオプションには次が含まれます。
    • コレクションに別のテーブル名を指定する
    • コレクションのマージ動作を選択する (デルタ更新モードを使用するかどうか)
    • マテリアライズするフィールドを制御するため、フィールドの選択動作をカスタマイズする
  3. ClickHouse へのデータのマテリアライズ方法に問題がなければ、Next、次に Save and Publish をクリックします。
Estuary は選択したコレクションのデータを ClickHouse にバックフィルし始め、その後は更新が発生するたびにストリーミングします。

関連リソース

Estuary で ClickHouse コネクタを設定する方法については、Estuary のドキュメントを参照してください。
最終更新日 2026年8月14日