> ## Documentation Index
> Fetch the complete documentation index at: https://clickhouse.com/docs/llms.txt
> Use this file to discover all available pages before exploring further.

# ClickPipes で ClickHouse に同期する

> 組み込みの CDC（変更データキャプチャ）機能を使用して、Postgres のデータを ClickHouse にレプリケートします

[ベータ](https://clickhouse.com/cloud/postgres)

ClickHouse Managed Postgres のインスタンスにはすべて、任意の ClickHouse service への CDC (変更データキャプチャ) 機能が標準で備わっています。これにより、Postgres インスタンス上のデータの一部またはすべてを ClickHouse に移行し、Postgres 側でのデータ変更を継続的かつほぼリアルタイムに ClickHouse へ反映できます。この機能は内部的に [ClickPipes](https://clickhouse.com/docs/ja/integrations/clickpipes/home.md) によって実現されています。

利用するには、Postgres インスタンスのサイドバーにある **Sync to ClickHouse** をクリックします。

![サイドバーに連携オプションを表示する ClickHouse 連携のランディングページ](https://mintcdn.com/private-7c7dfe99/7bwsXgjDg4ADP__Z/images/managed-postgres/clickhouse-integration-intro.webp?fit=max\&auto=format\&n=7bwsXgjDg4ADP__Z\&q=85\&s=e32d61f84fe019d735b5f18a6ba5ae47)

> [!NOTE]
>
> 次に進む前に、Postgres service に ClickPipes サービスからアクセスできることを確認してください。デフォルトではアクセス可能ですが、IP アクセスを制限している場合は、**ClickHouse service** が配置されているリージョンに応じて、[こちら](https://clickhouse.com/docs/ja/integrations/clickpipes/networking/static-ips.md)のリストに記載されたソース IP からのアクセスを許可する必要があります。

**Replicate data in ClickHouse** をクリックすると、ClickPipe のセットアップを開始できます。

**1. レプリケーションサービスの構成**

レプリケーションの設定を入力します。

* **インテグレーション名**: この ClickPipe の名前
* **ClickHouse service**: 既存の ClickHouse Cloud service を選択するか、新規に作成します
* **Postgres database**: レプリケーション元となるソースデータベース
* **Replication method**: 次のいずれかを選択します。
  * \*\*初期ロード + CDC (変更データキャプチャ) \*\*: 既存データを取り込み、その後もテーブルを新しい変更で更新し続けます (推奨)
  * **初期ロード only**: 既存データの snapshot を一度だけ取得し、以降の更新は行いません
  * **CDC (変更データキャプチャ)  only**: 初回 snapshot をスキップし、以降の新しい変更のみをキャプチャします

![インテグレーション名、宛先サービス、レプリケーション方式のオプションを示すレプリケーションサービスの構成画面](https://mintcdn.com/private-7c7dfe99/7bwsXgjDg4ADP__Z/images/managed-postgres/replication-service-step.webp?fit=max\&auto=format\&n=7bwsXgjDg4ADP__Z\&q=85\&s=3a4e607c9b176e79ecd13910e1498e6c)

**Next** をクリックして次に進みます。

**2. レプリケーション設定の構成**

データのレプリケーション方法を細かく調整します。

* **Sync interval (seconds)**: Postgres から変更を取得する頻度 (デフォルト: 60)
* **Parallel threads for 初期ロード**: 初回 snapshot 時に使用するスレッド数 (デフォルト: 4)
* **Pull バッチサイズ**: レプリケーション中に 1 バッチで取得する行数 (デフォルト: 100000)
* **Snapshot number of rows per partition**: 初回 snapshot 時のパーティションあたりの行数 (デフォルト: 100000)
* **Snapshot number of tables in parallel**: 同時に snapshot を取得するテーブル数 (デフォルト: 1)

![同期間隔、並列スレッド数、Pull バッチサイズ、snapshot 構成オプションを示すレプリケーション設定のステップ](https://mintcdn.com/private-7c7dfe99/7bwsXgjDg4ADP__Z/images/managed-postgres/integration-replication-settings.webp?fit=max\&auto=format\&n=7bwsXgjDg4ADP__Z\&q=85\&s=352b1f09ca383bb75d9553ba0def5f77)

**Next** をクリックして次に進みます。

**3. レプリケーションするテーブルの選択**

宛先データベースを選択し、レプリケーション対象のテーブルを指定します。

* **宛先データベース**: 既存の ClickHouse データベースを選択するか、新規に作成します
* **Prefix default destination table names with schema name**: 名前の競合を避けるため、Postgres のスキーマ名をプレフィックスとして付加します
* **Preserve NULL values from source**: 型のデフォルト値に変換せず、NULL 値をそのまま保持します。この設定はパイプ内のすべてのテーブルに適用され、パイプの作成後は変更できません。
* **Remove deleted rows during merges**: [ReplacingMergeTree](https://clickhouse.com/docs/ja/reference/engines/table-engines/mergetree-family/replacingmergetree.md) テーブルの場合、バックグラウンドの merge 中に削除済みの行を物理的に削除します

スキーマを展開し、レプリケーションするテーブルを個別に選択します。宛先テーブル名やカラム設定をカスタマイズすることもできます。

![データベースの選択、レプリケーションオプション、スキーマごとにグループ化されたテーブル選択画面を示すテーブル選択のステップ](https://mintcdn.com/private-7c7dfe99/1Nz1dAkMe4yV28t-/images/managed-postgres/select-tables-step.webp?fit=max\&auto=format\&n=1Nz1dAkMe4yV28t-\&q=85\&s=e0e4d8bcb77b0565490b12252841ccbe)

**Replicate data to ClickHouse** をクリックしてレプリケーションを開始します。

**4. ClickPipe の監視**

ClickPipe が開始されると、同じメニューに一覧表示されます。全データの初回 snapshot には、テーブルのサイズに応じて時間がかかる場合があります。

![実行中の ClickPipe と、その宛先サービスおよびステータスを示す ClickHouse 連携一覧](https://mintcdn.com/private-7c7dfe99/1Nz1dAkMe4yV28t-/images/managed-postgres/integration-running.webp?fit=max\&auto=format\&n=1Nz1dAkMe4yV28t-\&q=85\&s=487881b858fdac6860c3ad67b0ea66e3)

インテグレーション名をクリックすると、詳細なステータスの確認、進捗の監視、エラーの表示、ClickPipe の管理を行えます。ClickPipe が取り得るさまざまな状態については、[Postgres ClickPipe のライフサイクル](https://clickhouse.com/docs/ja/integrations/clickpipes/postgres/lifecycle.md)を参照してください。