メインコンテンツへスキップ
メインコンテンツへスキップ

Neon Postgres ソースセットアップガイド

本ガイドでは、ClickPipes でレプリケーション元として利用できる Neon Postgres のセットアップ方法について説明します。 このセットアップのために、事前に Neon コンソール にサインインしておいてください。

権限を持つユーザーの作成​

管理者ユーザーとして Neon インスタンスに接続し、次のコマンドを実行します。

  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 に含めるテーブルには、主キー が定義されているか、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 には、指定したテーブルから生成される変更イベントのセットが含まれ、後でレプリケーションストリームを取り込むために使用されます。

ロジカルレプリケーションを有効化する​

Neon では、UI からロジカルレプリケーションを有効化できます。これは、ClickPipes の CDC（変更データキャプチャ）でデータをレプリケートするために必要です。 Settings タブに移動し、Logical Replication セクションを開きます。

ロジカルレプリケーションを有効化する

Enable をクリックして有効化します。有効化が完了すると、次のような成功メッセージが表示されます。

ロジカルレプリケーションが有効になった状態

Neon の Postgres インスタンスで、次の設定を確認しましょう：

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

IP ホワイトリスト登録（Neon Enterprise プラン向け）​

Neon Enterprise プランをご利用の場合、ClickPipes の IP アドレス をホワイトリストに登録することで、ClickPipes から Neon Postgres インスタンスへのレプリケーションを許可できます。 そのためには、Settings タブをクリックし、IP Allow セクションに移動します。

IP 許可画面

接続情報をコピーする​

ユーザーと publication の準備が整い、レプリケーションが有効になったので、新しい ClickPipe を作成するために接続情報をコピーします。 Dashboard を開き、接続文字列が表示されているテキストボックスで、 表示を Parameters Only に切り替えます。次の手順でこれらのパラメータを使用します。

接続情報

次のステップ​

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