AlloyDB Postgres ソースの設定ガイド

ClickPipes のソースとして AlloyDB Postgres インスタンスを設定する

​

サポート対象バージョン

ClickPipes を使用して AlloyDB インスタンスから ClickHouse Cloud にデータを連携するには、インスタンスで論理レプリケーションが設定されている必要があります。これは AlloyDB Version 14 以降でサポートされています。

​

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

AlloyDB インスタンスで論理レプリケーションが有効になっているかを確認するには、プライマリインスタンスに対して次のクエリを実行します。

SHOW  wal_level;

結果が logical の場合は、論理レプリケーションはすでに有効になっているため、次の手順に進んでください。結果が replica の場合は、プライマリ インスタンスで alloydb.enable_pglogical フラグと alloydb.logical_decoding フラグを on に設定する必要があります。

AlloyDB flags documentation にあるとおり、論理レプリケーションを有効にするフラグの変更には、プライマリ インスタンスの再起動が必要です。

これらのフラグを有効にするには、次の手順を実行します。

1. Google Cloud Console で AlloyDB の Clusters ページに移動します。プライマリ インスタンスの Actions メニューから Edit をクリックします。

2. 下にスクロールして Advanced configuration options セクションを展開します。Flags で Add a database flag をクリックします。

   • allowdb.enable_pglogical フラグを追加し、値を on に設定します
   • alloydb.logical_decoding フラグを追加し、値を on に設定します

3. Update instance をクリックして構成変更を保存します。この操作により、プライマリ インスタンスが再起動される点に注意してください。

4. インスタンスのステータスが Updating から Ready に変わったら、次のクエリをプライマリ インスタンスに対して実行し、論理レプリケーションが有効になっていることを確認します。

   SHOW  wal_level;
   

   結果は logical になるはずです。

​

ClickPipes ユーザーを作成し、レプリケーション権限を管理する

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

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 USER clickpipes_user WITH REPLICATION;
   

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

publication に含まれるテーブルには、主キー が定義されているか、replica identity が FULL に設定されている必要があります。スコープ設定のガイダンスについては、Postgres のよくある質問 を参照してください。

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

  CREATE PUBLICATION clickpipes FOR TABLE table_to_replicate, table_to_replicate2;
  

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

    CREATE PUBLICATION clickpipes FOR TABLES IN SCHEMA "public";
    

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

​

ネットワークアクセスを設定する

ClickPipes は Private Service Connect (PSC) 接続をサポートしていません。AlloyDB インスタンスへのパブリックアクセスを許可しない場合は、SSH トンネルを使用して安全に接続できます。PSC は今後サポートされる予定です。

次に、ClickPipes から AlloyDB インスタンスへの接続を許可する必要があります。

ClickPipes の IP を許可

1. Google Cloud Console で、AlloyDB の Clusters ページに移動します。プライマリインスタンスを選択して、概要 ページを開きます。

2. Instances in your cluster までスクロールし、Edit primary をクリックします。

3. Enable Public IP チェックボックスをオンにして、パブリックインターネット経由でインスタンスへの接続を許可します。Authorized external networks で、サービスのデプロイ先リージョンに対応する ClickPipes の静的 IP アドレス一覧 を入力します。

AlloyDB では、アドレスを CIDR 表記 で指定する必要があります。提供されている ClickPipes の静的 IP アドレス一覧の各アドレスに /32 を追加すると、この表記に合わせられます。

4. Network Security で、Require SSL Encryption (default) を選択します (まだ選択されていない場合) 。

5. Update instance をクリックして、ネットワークセキュリティ設定の変更を保存します。

SSH トンネルを使用

AlloyDB インスタンスへのパブリックアクセスを許可しない場合は、まず SSH 踏み台サーバーを用意し、SSH トンネル経由で安全に接続できるようにする必要があります。Google Cloud Platform で SSH 踏み台サーバーを設定するには、次の手順を実行します。

1. 公式ドキュメント に従って、Google Compute Engine (GCE) インスタンスを作成して起動します。

   • GCE インスタンスが AlloyDB インスタンスと同じ Virtual Private Network (VPC) 内にあることを確認します。
   • GCE インスタンスに 静的パブリック IP アドレス が割り当てられていることを確認します。ClickPipes を SSH 踏み台サーバーに接続する際、この IP アドレスを使用します。

2. SSH 踏み台サーバーのファイアウォールルールを更新し、サービスのデプロイ先リージョンに対応する ClickPipes の静的 IP アドレス一覧 からのトラフィックを許可します。

3. AlloyDB のファイアウォールルールを更新し、SSH 踏み台サーバーからのトラフィックを許可します。

​

次のステップ

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