Crunchy Bridge Postgres ソース設定ガイド

ClickPipes は Postgres バージョン 12 以降をサポートしています。

論理レプリケーションを有効化する

Crunchy Bridge では、論理レプリケーションが既定で有効になっています。以下の設定が正しく構成されていることを確認してください。そうでない場合は、必要に応じて調整してください。

SHOW wal_level; -- should be logical
SHOW max_wal_senders; -- should be 10
SHOW max_replication_slots; -- should be 10

ClickPipes ユーザーの作成と権限付与

postgres ユーザーで Crunchy Bridge Postgres に接続し、以下のコマンドを実行します。

1. ClickPipes 用の専用ユーザーを作成します:

   CREATE USER clickpipes_user PASSWORD 'some-password';
   

2. 前の手順で作成したユーザーに対して、スキーマ単位の読み取り専用アクセス権を付与します。次の例は public スキーマに対する権限を示しています。レプリケートしたいテーブルを含む各スキーマに対して、これらのコマンドを繰り返してください。

   GRANT USAGE ON SCHEMA "public" TO clickpipes_user;
   GRANT SELECT ON ALL TABLES IN SCHEMA "public" TO clickpipes_user;
   ALTER DEFAULT PRIVILEGES IN SCHEMA "public" GRANT SELECT ON TABLES TO clickpipes_user;
   

3. ユーザーにレプリケーション権限を付与します:

    ALTER ROLE clickpipes_user REPLICATION;
   

4. レプリケートしたいテーブルを含む publication を作成します。パフォーマンスへのオーバーヘッドを避けるため、publication には必要なテーブルのみを含めることを強く推奨します。

   注記

   publication に含めるテーブルはすべて、primary key が定義されているか、replica identity が FULL に設定されている必要があります。スコープ設定に関するガイダンスについては Postgres FAQs を参照してください。

   • 特定のテーブルに対する publication を作成する場合:

     CREATE PUBLICATION clickpipes FOR TABLE table_to_replicate, table_to_replicate2;
     

   • 特定のスキーマ内のすべてのテーブルに対する publication を作成する場合:

     CREATE PUBLICATION clickpipes FOR TABLES IN SCHEMA "public";
     

   clickpipes publication には、指定したテーブルから生成される変更イベント群が含まれ、後でレプリケーションストリームを取り込むために使用されます。

ClickPipes の IP アドレスを許可リストに追加する

Crunchy Bridge で Firewall Rules を追加して、ClickPipes IPs を許可リストに登録します。

次のステップ

これで、ClickPipe を作成し、Postgres インスタンスから ClickHouse Cloud へデータの取り込みを開始できます。 ClickPipe を作成する際に使用するため、Postgres インスタンスのセットアップ時に使用した接続情報を必ずメモしておいてください。